ActiveMQ 经典消息分组和自动重新平衡消费者

Question

我有几个应用程序发送到一个队列。就我而言，我需要使用消息组。添加另一个消费者时我可以以某种方式重新平衡吗？假设我有 2 个消费者，并且通过 4 个组发送了 50 条消息，因此每个消费者发送 2 个组。然后添加接下来的两个消费者，我想重新平衡，以便下一个消费者接管这两个添加组的处理。

我在5.12.1版本中使用activemq-spring。

我尝试在文档中查找信息，但没有任何具体信息。

Answer 1

ActiveMQ Classic 可以通过 JMX 操作清除队列上的消息组缓存来实现此目的。执行此操作将重新平衡消费者。

您想要重新平衡所有消费者的 JMX 操作：

removeAllMessageGroups

注意：您可能需要升级，因为 5.12.x 已经过时了。