我们有一个Java应用程序,它使用Spring AMQP从rabbitmq获取消息 . 对于某些队列,消费者数量没有增加,导致消息传递速度变慢 . 例如即使最大消费者设置为50,消费者的数量在大多数情况下仍然为6,负载9000条消息 .
但是,其他队列不是这种情况 . 我......其他队列的消费者数量达到35 .
我们使用SimpleMessageListenerContainer的setMaxConcurrentConsumers API来设置最大消费者 .
有人可以帮我理解这个吗?
组态:
并发消费者数量:4
最大并发消费者数量:50
1 回答
在提出这样的问题时,您必须始终显示配置 . 使用完整详细信息编辑您的问题
这取决于您的配置 . 默认情况下,新的使用者仅每10秒添加一次,并且仅当现有使用者收到10条没有任何间隙的消息时 .
如果仍然没有解决这个问题,请将日志(至少覆盖
startConsumerMinInterval
毫秒)发布到像pastebin或dropbox这样的地方 .