ActiveMQ 故障转移连接不起作用，但适用于单个 IP

Question

我是 Java 新手，正在编写一个连接到 ActiveMQ 集群的微服务。当我使用一个代理 IP 地址时，我可以连接到集群并成功读取消息。但是，当我将所有 IP 作为故障转移配置传递时，连接不起作用。

工作配置：

    private static String url = "tcp://1.2.3.4:61616";
    ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(url);
    connectionFactory.setUserName("abc@abc");
    connectionFactory.setPassword("abc");
    connectionFactory.setClientID("testingClient");

配置失败：

    private static String url = "failover://(tcp://1.2.2.4:61616,tcp://17.3.2.50:61616,tcp://14.3.8.6:61616,tcp://2.3.0.4:61616,tcp://7.2.2.5:61616,tcp://32.33.1.6:61616)?randomize=false";
    ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(url);
    connectionFactory.setUserName("abc@abc");
    connectionFactory.setPassword("abc");
    connectionFactory.setClientID("testingClient"); 

Answer 1

故障转移 URL 中似乎有一个额外的

//

。尝试用这个代替：

private static String url = "failover:(tcp://1.2.2.4:61616,tcp://17.3.2.50:61616,tcp://14.3.8.6:61616,tcp://2.3.0.4:61616,tcp://7.2.2.5:61616,tcp://32.33.1.6:61616)?randomize=false";