RabbitMQ集群需叠加HAProxy与Keepalived实现高可用：先启用仲裁队列或镜像队列保障消息冗余，再用HAProxy做TCP层负载均衡与健康检查，最后通过Keepalived提供虚拟IP实现Proxy主备切换。

RabbitMQ 本身不自带负载均衡和自动故障转移能力，集群节点间只同步元数据（如交换器、队列定义、绑定关系），但消息实际只存于创建它的那个节点。如果该节点宕机，普通队列中的消息就不可用——哪怕集群其他节点还在运行。因此，要真正实现“连接不中断、请求自动切换、服务持续可用”，必须在 RabbitMQ 集群之上叠加外部组件。核心思路是：用 HAProxy 做四层负载均衡 + 故障探测，再用 Keepalived 提供虚拟 IP 实现双机高可用。

---

✅ 必须先确保 RabbitMQ 集群具备数据高可用基础

负载均衡和故障转移的前提，是后端节点的数据能扛住单点失效。否则，即使流量切过去了，也消费不到消息。

• 禁用普通集群模式（仅同步元数据）：它无法解决消息丢失问题。
• 启用仲裁队列（Quorum Queue）或镜像队列（Mirrored Queue）：
  • quorum 队列基于 Raft 协议，强一致、自动选主、推荐用于新项目；
  • mirrored 队列需通过 policy 设置（如 ha-mode: all 或 exactly），要求所有/指定数量副本同步成功才返回 ACK。
• 所有节点使用相同 Erlang Cookie，并配置 /etc/hosts 确保主机名互通；
• 至少一个磁盘节点，避免重启后元数据丢失。

示例：创建仲裁队列（客户端声明时指定）

channel.queueDeclare("order.events", true, false, false, 
    Map.of("x-queue-type", "quorum"));

---

✅ 用 HAProxy 实现连接层负载与健康检查

HAProxy 作为 TCP 层（L4）代理，把客户端对 RabbitMQ 的 AMQP 连接（默认 5672）统一转发到多个集群节点，并实时探测节点存活状态。

• 安装（Ubuntu）：

  sudo apt update && sudo apt install haproxy -y
  sudo systemctl enable haproxy && sudo systemctl start haproxy

• 关键配置 /etc/haproxy/haproxy.cfg：

  listen rabbitmq
    bind *:5672          # 对外暴露统一端口（可替换为 5670 避开默认）
    mode tcp
    balance roundrobin   # 或 leastconn，按连接数分发
    option tcp-check
    default-server inter 5s rise 2 fall 3
  
    server node1 192.168.10.128:5672 check
    server node2 192.168.10.129:5672 check
    server node3 192.168.10.130:5672 check

• check 启用健康检查；rise 2 fall 3 表示连续 2 次成功则上线，连续 3 次失败则下线；

• 客户端只需连接 haproxy-ip:5672，无需感知后端节点变化。

  

  Java Maven Common

  Java Maven 项目审查工作流的通用输入处理。当 Java Maven 项目以 ZIP压缩包或 GitLab 仓库 URL 形式提供且需要...时使用。

  下载

---

✅ 用 Keepalived 防止单点代理失效

单个 HAProxy 是新的单点瓶颈。引入 Keepalived 构建主备 Proxy，对外提供一个浮动 VIP（Virtual IP），主挂了备自动接管。

• 两台 HAProxy 服务器安装 Keepalived：

  sudo apt install keepalived -y

• 主节点 /etc/keepalived/keepalived.conf：

  vrrp_instance VI_1 {
      state MASTER
      interface eth0
      virtual_router_id 51
      priority 100
      advert_int 1
      authentication {
          auth_type PASS
          auth_pass mypass
      }
      virtual_ipaddress {
          192.168.10.200/24  # 客户端连接这个 VIP
      }
  }

• 备节点配置相同，仅 state BACKUP 和 priority 99；

• 启动后，VIP 始终绑定在健康主节点上，客户端无感切换。

---

✅ 客户端连接方式要适配高可用

• 不写死某个 RabbitMQ 节点 IP，而是连接 Keepalived 提供的 VIP：

  ConnectionFactory factory = new ConnectionFactory();
  factory.setHost("192.168.10.200"); // → 自动路由到存活的 HAProxy → 再转到健康 RabbitMQ 节点
  factory.setPort(5672);

• 开启连接重试（建议配合 Automatic Recovery）：

  factory.setAutomaticRecoveryEnabled(true);
  factory.setTopologyRecoveryEnabled(true);

这样，当任意 RabbitMQ 节点宕机，HAProxy 会自动剔除它；当主 HAProxy 故障，Keepalived 秒级切换 VIP；客户端连接几乎不受影响。

不复杂但容易忽略