ActiveMQ Artemis使用故障转移和静态分配队列配置独立代理

Question

我正试图找出如何利用ActiveMQ Artemis来实现以下拓扑结构。我确实需要有几个生产者写到两个独立的Artemis代理上托管的队列。目前，每个生产者创建两个连接工厂，处理到两个代理的连接，并创建相应的队列。

    @Bean
    public ConnectionFactory jmsConnectionFactoryBroker1() {
        ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(brokerUrl_1,username,password);
        return connectionFactory;
    }

    @Bean
    public ConnectionFactory jmsConnectionFactoryBroker2() {
        ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(brokerUrl_2,username,password);
        return connectionFactory;
    }

我的主要问题是，我需要知道哪个队列被分配给哪个代理，同时我需要知道，如果一个代理由于某种原因停机，我可以动态地为另一个代理重新创建该队列，以避免丢失任何进一步的消息。所以我的方法是如下所示设置代理URL

artemis.brokerUrl_1=(tcp://myhost1:61616,tcp://myhost2:61616)?randomize=false
artemis.brokerUrl_2=(tcp://myhost2:61616,tcp://myhost1:61616)?randomize=false

因此，对每个代理url使用不同的JmsTemplate我的意图是，当引用JmsTemplate时，使用brokerurl_1将在myhost1上创建队列，对brokerurl_2创建相应的JmsTemplate也是如此。

我预计（由于随机化参数）每个队列都有某种代理的静态成员资格，在代理失败的情况下，将通过从头重新创建队列到另一个代理来进行某种迁移。

相反，我注意到，几乎每次队列创建的分布都不是按照预期的那样发生的，而是随机的，因为相同的队列可以出现在任一代理中，这对我的用例来说并不理想。

我如何处理这种情况并以一种方式解决我的问题，即我可以在预定义的代理上创建队列，并具有故障安全，如果一个代理关闭，生产者将为另一个代理创建相同的队列并继续？

Answer 1

randomize=false不适用于Artemis核心JMS客户机。它只适用于随ActiveMQ5.x分发的OpenWire JMS客户机。从URL中选择哪个连接器由连接负载平衡策略决定，如文档中所述。默认的连接负载平衡策略是org.apache.activemq.artemis.api.core.client.loadBalance.RoundRobinConnectionLoadBalancingPolicy，它将从URL列表中选择一个随机连接器，然后循环连接。还有其他策略可用，如果它们中没有一个给出您想要的行为，那么您可以实现自己的行为。

也就是说，听起来您真正想要/需要的是两对代理，其中每对由一个live和一个backup组成。这样，如果live broker失败，那么所有客户端都可以故障转移到备份，您就不必处理您试图实现的“假”故障转移功能的任何其他复杂性。

此外，由于您使用的是Spring的jmstemplate，您应该注意到它使用的一些众所周知的反模式，这些反模式可能会以负面的方式显著影响性能。