代码之家 › 专栏 › 技术社区 › xLokos

RabbitMQ MassTransit批处理竞争消费者

masstransit rabbitmq

xLokos · 技术社区 · 3 年前

我已经设置了一个活动的批处理消费者 ExampleEvent 并将其设置为 ConcurrencyLimit = 16 , MessageLimit = 100 , TimeLimit = 5 sec 和分组依据 ExampleEvent.GroupingKey 领域

这很好,在Rabbit上显示为消费者 PrefetchCount = 1600 。问题是,我有一个多吊舱环境,并且有多个像这样的消费者连接到同一队列。我读到Rabbit使用循环算法分发消息,但我也读到它将试图使一个消费者饱和,直到 PrefetchCount 已达到未确认消息的限制。事实似乎并非如此(或者我错过了什么?)。

现在的主要问题是,一些本可以与使用者1上的其他消息进行批处理的消息正在发送到使用者2(副本)。根据日志,它们在不到一秒钟的时间内被拿走,而且远未达到消息限制。

是否可以以某种方式强制在消费者1上进行批量处理?

1 回复 | 直到 3 年前

Chris Patterson 3 年前

当运行同一服务的多个实例/pod时,队列上的消息将在所有实例/pod之间实现负载平衡。无法在RabbitMQ中控制这些消息的方向,从而使它们只能到达特定的实例。

推荐文章

Red Riding Hood · 如何在docker compose中使用主机名连接到RabbitMQ流插件

2 年前

J. Maciel · 无法读取未定义的属性(读取“voto”)和其他属性

2 年前

moumout · AMQPCPP消费者和发布者不创建交换和队列

2 年前

trung · 如何用python测试消费者rabbitmq的基准测试

2 年前

nkalfov · .NET客户端无法通过TLS连接到端口5671上的AMQP Windows Server 2019标准版1809

2 年前

mthgh0818 · rabbitmq-mqt如何获取设备的联机状态

2 年前

sirineBEJI · 在带有Azure AD的rabbitmq上使用OAuth2时拒绝访问

2 年前

Community wiki · Java和RabbitMQ-排队和多线程-或Couchbase作为作业队列

2 年前

nealsu · RabbitMQ是否允许管理UI使用OAuth和AMPQ连接来使用基本身份验证?

3 年前

ankit12 · 消费者:与代理的连接丢失。尝试重新建立Rabbit MQ和Celery的连接

3 年前