Find centralized, trusted content and collaborate around the technologies you use most.
Teams
Q&A for work
Connect and share knowledge within a single location that is structured and easy to search.
我们有 10 条消息,Activemq我们启动了 2 个消费者。但只有第一个消费者消费和处理消息。第二个消费者不消费消息。
Activemq
如果我Queue在第一个消费者处理时间时再发送一条消息,第二个消费者消费并处理该特定消息(我们在第一个消费者处理时间时发送了 1 条消息)。在它不消费待处理消息之后。
Queue
最后我理解的是,所有待处理的消息都由第一个消费者处理,而不是剩余的消费者。
我想让所有消费者参与处理未决消息。
谢谢。
我认为您正在查看的是预取限制导致一个消费者预先占用一堆消息,从而使其他消费者挨饿。您需要降低消费者预取限制,以便代理不会急切地向第一个连接的消费者发送消息,并允许其他消费者上线以帮助平衡负载。
在您的情况下,一个预取限制将允许所有消费者加入并获得一些工作。