Java应用连接RabbitMQ集群时，必须通过HAProxy统一入口（如5670端口）实现负载均衡与故障转移，避免直连单节点导致ConnectException；配置需启用TCP模式、健康检查（rise 2 fall 3）及轮询算法，客户端连接HAProxy地址并开启重试机制。
Java 应用连接 RabbitMQ 集群时，不能直接写死单个节点的 IP 和端口（比如 192.168.10.128:5672），否则该节点宕机就会抛 ConnectException，程序中断。真正可行的方案是：在集群前端加一层 HAProxy，作为统一入口，实现自动负载分发与故障转移。
HAProxy 安装与启用
以 Ubuntu 系统为例：
- 更新并安装：
sudo apt update && sudo apt install haproxy -y - 设为开机自启并启动：
sudo systemctl enable haproxy && sudo systemctl start haproxy - 验证状态：
systemctl status haproxy（看到active (running)即成功）
关键配置项说明（/etc/haproxy/haproxy.cfg）
核心是两段配置：管理界面 + AMQP 代理。以下是最简实用配置：
1. Web 管理界面（可选但推荐）
立即学习“Java免费学习笔记（深入）”；
listen stats bind *:8100 mode http stats enable stats uri /stats stats auth admin:admin
访问 http://<span style="color:#0000FF">你的HAProxy服务器IP</span>:8100/stats，输入账号密码即可实时查看各 RabbitMQ 节点健康状态。
deep-java-review
下载
Java项目代码review工具。分析Git变更+完整调用链路上下文，推断业务需求，进行多维度评分和分类汇总，生成完整PRD文档。包含细粒度Java代码审查清单（Null安全、异常处理、Streams、并发、equals/hashCode、资源管理、API设计、性能、MyBatis/ORM、事务边界、SQL/DD...
2. RabbitMQ 负载均衡主配置
listen rabbitmq bind *:5670 mode tcp balance roundrobin 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
注意点：
-
bind *:5670：对外暴露统一端口，避开默认 5672，避免冲突；Java 客户端连的就是这个地址 -
mode tcp：AMQP 是二进制 TCP 协议，必须用 TCP 模式，不能用 HTTP -
balance roundrobin：轮询分发；高并发场景可换leastconn（按当前连接数分配） -
check启用健康检查；rise 2 fall 3表示连续 2 次通则上线、连续 3 次不通则下线
Java 客户端连接方式调整
不再指定单个节点，而是连接 HAProxy 入口：
- 连接地址改为：
amqp://guest:guest@<span style="color:#0000FF">haproxy-ip</span>:5670/ - 确保开启自动恢复和重连（Spring Boot 示例）：
spring:
rabbitmq:
host: <span style="color:#0000FF">haproxy-ip</span>
port: 5670
username: guest
password: guest
listener:
simple:
retry:
enabled: true
acknowledge-mode: manual
这样即使某台 RabbitMQ 节点宕机，HAProxy 会自动剔除它，Java 客户端重连时自然落到其他健康节点，全程无感知。
配套集群前提不能少
HAProxy 只解决“连谁”的问题，不解决“消息存哪”和“队列是否可用”。必须同步做好：
- 所有 RabbitMQ 节点使用相同的
.erlang.cookie，且/etc/hosts正确解析节点名 - 集群中至少有一个磁盘节点（Disk Node），防止元数据丢失
- 队列必须用
quorum类型（RabbitMQ 3.8+ 推荐）或镜像策略（x-ha-policy: all），否则消息仍只存单节点 - 防火墙放行节点间通信端口
25672（Erlang 分布式端口）
做完这些，Java 应用就真正接入了具备负载能力与故障自愈能力的 RabbitMQ 高可用体系。
