java - Activemq 消费者仅接收替代消息

Question

要求:一个 activemq 队列应该在一台机器(比如 machine1)上运行。那个队列应该从 machine1 和另一台机器(比如 machine2)访问。监听器将只在 machine1 上运行。所以，我的所有消息发送到 machine1，machine2 应进入 machine1 中可用的队列，并应由同一台机器(machine1)中可用的监听器接收。

问题:我发送到 machine1 和 machine2 的所有消息都进入队列，但监听器只接收替代消息。假设 1、3、5 并且它无法接收消息 2、4 .....

观察:假设如果 machine1 和 machine2 中有监听器，它正在正确接收，即； machine1 中的 listener 接收到 1, 3, 5 ..... 而 machine2 中的 listener 接收到 2,4,6 ......

Answer 1

ActiveMQ 默认使用 RoundRobin 分布。因此，如果如您所解释的那样，您的队列中有 2 个消费者(machine1 和 machine2)，machine1 将只收到一半的消息。即使您在 machine2 上没有处理消息的进程，该主机上的 ActiveMQ 客户端也可能正在使用它们。如果您希望 2 个客户端可以使用消息，您必须使用主题而不是队列。