ActiveMQ Artemis集群：JMS ConnectionFactory

Question

我已经尝试只使用一个节点，它正在工作。现在我必须修改代码中的ConnectionFactory，以便它能够与集群连接。

在ActiveMQ Artemis文档中，我发现了如下内容：

@Bean
public ConnectionFactory connectionFactory() {    
    TransportConfiguration transportConfiguration = new TransportConfiguration(NettyConnectorFactory.class.getName());
    ConnectionFactory cf = ActiveMQJMSClient.createConnectionFactoryWithHA(JMSFactoryType.CF, transportConfiguration);
    return cf;
}

JavaDoc表示：

@Bean
public ConnectionFactory connectionFactory() {    
    ConnectionFactory cf = new ActiveMQConnectionFactory("tcp://localhost:61616?sslEnabled=true&trustStorePath=activemq.example.truststore&trustStorePassword=activemqexample");
    return cf;
}

Answer 1

客户端接收的拓扑信息仅真正用于故障转移。要创建支持故障转移的JMS连接工厂URL，只需添加ha参数，其值为true，例如：

tcp://localhost:61616?ha=true

如果您需要SSL/TLS配置，您也可以添加该配置，例如：

tcp://localhost:61616?ha=true&sslEnabled=true&trustStorePath=activemq.example.truststore&trustStorePassword=activemqexample

如果您希望URL能够潜在地连接到集群中的任何节点，那么可以添加多个主机/端口元素，例如：

(tcp://node1:61616,tcp://node2:61616,tcp://node3:61616,tcp://node4:61616)?ha=true&sslEnabled=true&trustStorePath=activemq.example.truststore&trustStorePassword=activemqexample

udp://231.7.7.7:9876?ha=true&sslEnabled=true&trustStorePath=activemq.example.truststore&trustStorePassword=activemqexample