0

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

如果我Queue在第一个消费者处理时间时再发送一条消息,第二个消费者消费并处理该特定消息(我们在第一个消费者处理时间时发送了 1 条消息)。在它不消费待处理消息之后。

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

我想让所有消费者参与处理未决消息。

谢谢。

4

1 回答 1

1

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

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

于 2013-09-13T18:41:38.420 回答