gpt4 book ai didi

rabbitmq - 我可以在大众运输中的端点配置中使用 UsePartitioner 来对传递到同一队列的多种消息类型进行分区吗

转载 作者:行者123 更新时间:2023-12-03 22:30:08 25 4
gpt4 key购买 nike

我正在使用大众运输和rabbitmq。我的队列有各种类型的消息传递给它。这些类型中的大多数都实现了 IHaveOrganisationKey。我想在管道中添加一个分区器,以确保同时处理具有给定组织 key 的一条消息(任何类型的)。目标是限制并行处理同一组织的多个消息时出现的并发问题,同时允许并行处理来自不同组织的消息。

配置代码

sbc.ReceiveEndpoint(host, this.queueConfiguration.QueueName, ep =>
{
ep.PrefetchCount = this.busConfiguration.PrefetchCount;
this.queueConfiguration.ConfigureEndpoint(ep);
this.queueConfiguration.SubscribeMessages(worker, ep);
});

在队列配置中:
public override void ConfigureEndpoint(IRabbitMqReceiveEndpointConfigurator ep)
{
// This is incomplete. Am I on the right track here?
ep.UsePartitioner(1, x => x.TryGetMessage<IHaveOrganisationKey>());
}

最佳答案

在这种情况下,您需要单独创建分区器,然后将其传递给每个消息类型配置。

var p = ep.CreatePartitioner(8);

ep.Consumer<ConsumerA>(x => x.Message<A>(m => m.UsePartitioner(p, c => c.Message.OrgKey)));
ep.Consumer<ConsumerB>(x => x.Message<B>(m => m.UsePartitioner(p, c => c.Message.OrgKey)));

如果你的消费者有多种消息类型,你可以指定多个 Message配置中的语句。

关于rabbitmq - 我可以在大众运输中的端点配置中使用 UsePartitioner 来对传递到同一队列的多种消息类型进行分区吗,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/42932238/

25 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com