如何让所有消费者参与处理未决消息？

Question

Activemq 中有 10 条消息，我们启动了 2 个消费者。但只有第一个消费者消费和处理消息。第二个消费者不消费消息。

如果我在第一个消费者处理时间时再向Queue 发送一条消息，则第二个消费者只消费和处理该特定消息（我们在第一个消费者处理时间时发送了一条消息）。在它不消费待处理消息之后。

最后我的理解是，所有待处理的消息都由第一个消费者处理，而不是剩余的消费者。

我想让所有消费者参与处理待处理的消息。

谢谢。

Answer 1

我认为您正在查看的是 prefetch limit 导致一个消费者预先占用一堆消息，从而使其他消费者挨饿。您需要降低消费者prefetch 限制，以便代理不会急切地将消息发送给第一个连接的消费者，并允许其他消费者上线以帮助平衡负载。

在您的情况下，预取限制为 1 将允许所有消费者加入并获得一些工作。