如何强制ActiveMQ连接为新消费者随机选择代理？

Question

我使用以下 url 来创建 ActiveMQConnactionFactory：

failover:(tcp://server1:port,tcp://server2:port,tcp://server2:port)

我想要做的是从该代理网络创建多个消息使用者。 以下不是真正的代码，但它有助于理解我是如何做到这一点的：

ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory("BROKER_URL");
connection = connectionFactory.createConnection();
connection.start();

for (int i=0; i<10; i++) {
session = connection.createSession(false, Session.CLIENT_ACKNOWLEDGE);
Destination queue = consumerSession.createQueue("QUEUE_NAME");
consumer = consumerSession.createConsumer(queue);
consumer.setMessageListener(new MessageListener());
}

问题是所有消费者都将连接到一个随机选择的经纪人。 但我希望它们在经纪人网络上保持平衡。

我相信通过与工厂建立多个连接是可以做到这一点的。

但最佳实践是什么？ 这是我想要的好事吗？ :)

Answer 1

实际上，消费者不会连接到随机选择的经纪人。

连接是连接到代理的部分。使用您提供的连接字符串，您将有一个连接映射到一个随机选择的代理。所有消费者都有自己的会话，但这些会话将使用与该 ONE 代理相同的 ONE 连接。

我所知道的唯一设置是，您可以通过在连接字符串上设置 ?randomize=false 来禁用故障转移协议的随机行为。这意味着您的连接将首先尝试第一个，然后是第二个，然后是第三个，依此类推。

但要达到您的要求。我会让每个消费者都有自己的连接。这与故障转移协议中的随机功能一起可以对消费者进行负载平衡；但不是真的，那里没有智能，只是“随机化”它所连接的经纪人。

这意味着，我将执行以下操作（根据您的代码）

ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory("BROKER_URL");

for (int i=0; i<10; i++) {

connection = connectionFactory.createConnection();
connection.start();
session = connection.createSession(false, Session.CLIENT_ACKNOWLEDGE);
Destination queue = consumerSession.createQueue("QUEUE_NAME");
consumer = consumerSession.createConsumer(queue);
consumer.setMessageListener(new MessageListener());

}

这样​​，每个消费者都将拥有与故障转移连接字符串的“a”代理的连接

问题更改后更新：

如果您愿意要让 ActiveMQ 为每个消费者随机选择一个代理，上述解决方案是可行的方法。

最佳实践是让消费者和生产者尽可能靠近。为此，我建议降低网络消费者优先级，因此本地消费者和生产者将具有最高优先级。只有当本地消费者不空闲时，它才会通过网络进一步分发给其他消费者。

除此之外，如果消费者端的操作长时间运行以设置较低的预取值，这将是一个好主意，这样消息就可以在代理网络周围实现负载平衡，而不是一个消费者抢夺 1,000 条消息，而其他消费者则抢走 1,000 条消息。消费者闲着。