java - Spring boot AMQP并发监听器顺序执行？

Question

我有一个 Spring AMQP 监听器定义如下:-

@RabbitListener(queues = "spring-boot-durable", concurrency="10")
public void recieve(String message) {
   ....some code here
}

现在，在rabbitmq管理门户中，当上述服务关闭时，我将发布30条消息，并启动监听器服务。

当我这样做时，消息是按顺序(一个接一个)执行的，而不是并行执行的(一次 10 个)，尽管我将并发度设置为 10，如上面的代码所示。

发生这种情况的任何原因以及解决方法吗？

Answer 1

我相信您会受到 prefetchCount 的影响 - 默认情况下为 250，因此所有消息都会发送给一个使用者。

减少它以分配给消费者，但我建议将其保持高于 1；否则会影响性能。