activemq负载均衡客户端链接

ActiveMQ 是一个开源的消息中间件，支持多种消息协议，如 JMS、AMQP 等，在实际应用中，为了提高可用性和可扩展性，通常会将 ActiveMQ 部署在多台服务器上，构建 ActiveMQ 集群。

ActiveMQ 集群

ActiveMQ 集群可以分为两种类型：主从集群和网络集群，主从集群中，一个节点作为主节点，负责消息的生产和消费，其他节点作为从节点，用于备份和负载均衡，网络集群中，所有节点都是平等的，每个节点都可以生产和消费消息，节点之间通过网络连接进行通信。

ActiveMQ 集群配置

主从集群配置

1、主节点配置：在主节点的配置文件中，需要设置brokerName 属性为master，表示当前节点为主节点，需要设置networkConnectors 属性，指定从节点的连接信息。

   <broker xmlns="http://activemq.apache.org/schema/core" brokerName="master" dataDirectory="${activemq.data}/master" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://activemq.apache.org/schema/core http://activemq.apache.org/schema/core/activemq-core.xsd">
     <networkConnectors>
       <networkConnector uri="static:(tcp://slave:61616)"/>
     </networkConnectors>
   </broker>

2、从节点配置：在从节点的配置文件中，需要设置brokerName 属性为slave，表示当前节点为从节点，需要设置networkConnectors 属性，指定主节点的连接信息。

   <broker xmlns="http://activemq.apache.org/schema/core" brokerName="slave" dataDirectory="${activemq.data}/slave" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://activemq.apache.org/schema/core http://activemq.apache.org/schema/core/activemq-core.xsd">
     <networkConnectors>
       <networkConnector uri="static:(tcp://master:61616)"/>
     </networkConnectors>
   </broker>

3、客户端连接：在客户端连接时，需要指定failover 协议，并设置主从节点的地址和端口号。

   String brokerUrl = "failover:(tcp://master:61616,tcp://slave:61616)";
   ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(brokerUrl);
   Connection connection = connectionFactory.createConnection();

网络集群配置

1、节点配置：在每个节点的配置文件中，需要设置brokerName 属性，用于标识当前节点的名称，需要设置networkConnectors 属性，用于指定其他节点的连接信息。

   <broker xmlns="http://activemq.apache.org/schema/core" brokerName="node1" dataDirectory="${activemq.data}/node1" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://activemq.apache.org/schema/core http://activemq.apache.org/schema/core/activemq-core.xsd">
     <networkConnectors>
       <networkConnector uri="static:(tcp://node2:61616)"/>
       <networkConnector uri="static:(tcp://node3:61616)"/>
     </networkConnectors>
   </broker>

2、客户端连接：在客户端连接时，需要指定failover 协议，并设置所有节点的地址和端口号。

   String brokerUrl = "failover:(tcp://node1:61616,tcp://node2:61616,tcp://node3:61616)";
   ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(brokerUrl);
   Connection connection = connectionFactory.createConnection();

ActiveMQ 客户端负载均衡机制

ActiveMQ 提供了多种客户端负载均衡机制，包括随机负载均衡、轮询负载均衡、权重负载均衡等，在客户端连接时，可以通过设置不同的参数来使用不同的负载均衡机制。

1、随机负载均衡：随机选择一个可用的节点进行连接，在客户端连接时，需要设置randomize 属性为true。

   String brokerUrl = "failover:(tcp://node1:61616,tcp://node2:61616,tcp://node3:61616)?randomize=true";
   ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(brokerUrl);
   Connection connection = connectionFactory.createConnection();

2、轮询负载均衡：按照顺序依次选择节点进行连接，在客户端连接时，可以设置use 属性为roundrobin。

   String brokerUrl = "failover:(tcp://node1:61616,tcp://node2:61616,tcp://node3:61616)?use=roundrobin";
   ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(brokerUrl);
   Connection connection = connectionFactory.createConnection();

3、权重负载均衡：根据节点的权重来选择节点进行连接，在客户端连接时，可以设置weight 属性来指定节点的权重。

   String brokerUrl = "failover:(tcp://node1:61616?weight=1,tcp://node2:61616?weight=2,tcp://node3:61616?weight=3)";
   ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(brokerUrl);
   Connection connection = connectionFactory.createConnection();

示例代码

以下是一个简单的 Java 示例，展示了如何使用 Spring Boot 和 ActiveMQ 客户端负载均衡组件来实现客户端负载均衡：

1、添加 Maven 依赖：

   <dependency>
     <groupId>com.github.fonoisrev</groupId>
     <artifactId>spring-boot-starter-activemq-clientSideLoadBalance</artifactId>
     <version>1.1.0</version>
   </dependency>

2、配置 ActiveMQ broker 的 URL 地址：在 Spring Boot 应用的配置文件（properties 或 yaml 格式）中添加以下配置：

   activemq:
     loadbalance:
       enabled: true
       urls:
         tcp://localhost:61616
         tcp://localhost:61617
         tcp://localhost:61618

3、创建 Spring Boot 应用：创建一个 Spring Boot 应用，并在其中使用@JmsListener 注解来接收消息。

   import org.springframework.boot.SpringApplication;
   import org.springframework.boot.autoconfigure.SpringBootApplication;
   import org.springframework.jms.annotation.JmsListener;
   import org.springframework.messaging.handler.annotation.SendTo;
   import org.springframework.stereotype.Component;
   @SpringBootApplication
   public class Application {
       public static void main(String[] args) {
           SpringApplication.run(Application.class, args);
       }
       @Bean
       public MyMessageListener messageListener() {
           return new MyMessageListener();
       }
   }
   @Component
   public class MyMessageListener {
       @JmsListener(destination = "myQueue")
       public void receiveMessage(String message) {
           System.out.println("Received message: " + message);
       }
       @SendTo("anotherQueue")
       public String processMessage(String message) {
           return "Processed " + message;
       }
   }