负载均衡配置

RabbitMQ集群通过前端负载均衡器实现连接分发，避免单点过载。

定义

负载均衡器位于RabbitMQ集群前端，将生产者、消费者或管理请求分发至集群中的不同节点，实现流量均匀分布与故障自动转移。

负载均衡模式

1. TCP层负载均衡

直接转发AMQP协议的TCP连接（默认端口5672）。

适用场景：

• 对消息内容无感知，纯连接级分发
• 支持所有AMQP操作（发布、消费、管理）

配置示例（HAProxy）：

frontend rabbitmq_frontend
    bind *:5672
    default_backend rabbitmq_nodes

backend rabbitmq_nodes
    mode tcp
    balance roundrobin
    option tcp-check
    server node1 rabbitmq-node1:5672 check
    server node2 rabbitmq-node2:5672 check
    server node3 rabbitmq-node3:5672 check

2. HTTP层负载均衡

针对RabbitMQ Management HTTP API（默认端口15672）进行分发。

适用场景：

• 管理操作（队列创建、用户管理、监控）
• 需要解析HTTP请求内容的场景

Java Client 连接配置

import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.Connection;

public class LoadBalancerExample {
    public static void main(String[] args) throws Exception {
        ConnectionFactory factory = new ConnectionFactory();
        
        // 指向负载均衡器地址，而非单个节点
        factory.setHost("loadbalancer.example.com");
        factory.setPort(5672);
        factory.setUsername("admin");
        factory.setPassword("secret");
        factory.setVirtualHost("/");
        
        // 连接配置
        factory.setRequestedHeartbeat(60);
        factory.setConnectionTimeout(30000);
        
        try (Connection connection = factory.newConnection()) {
            System.out.println("已连接至负载均衡后的RabbitMQ集群");
            System.out.println("当前连接节点: " + connection.getAddress());
        }
    }
}

负载均衡策略选择

注意事项

队列是绑定到特定节点的，消费者连接到不同节点可能访问不同队列。使用镜像队列（Mirrored Queues）或Quorum Queues可解决此问题。

负载均衡器健康检查间隔不宜过短（建议10-30秒），避免频繁摘除恢复中的节点。

生产者连接负载均衡需配合重试机制，当目标节点故障时自动切换。

高可用配合

import com.rabbitmq.client.Address;
import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.Connection;

public class HighAvailabilityConnection {
    public static void main(String[] args) throws Exception {
        ConnectionFactory factory = new ConnectionFactory();
        factory.setUsername("admin");
        factory.setPassword("secret");
        
        // 配置多个地址作为备用
        Address[] addresses = new Address[]{
            new Address("loadbalancer-primary.example.com", 5672),
            new Address("loadbalancer-secondary.example.com", 5672)
        };
        
        // 启用自动重连
        factory.setAutomaticRecoveryEnabled(true);
        factory.setNetworkRecoveryInterval(5000);
        
        try (Connection connection = factory.newConnection(addresses)) {
            System.out.println("已连接至集群");
        }
    }
}

要点总结

• 负载均衡器实现集群连接的均匀分发与故障转移
• TCP层负载均衡适用于AMQP协议，HTTP层适用于Management API
• Java Client指向负载均衡器地址而非单个节点
• 配合队列镜像/Quorum Queues实现完整高可用方案
• 启用自动重连与多地址配置提升连接可靠性
• 健康检查间隔建议10-30秒，避免频繁节点摘除