rabbitmq高可用集群通过rabbitmq cluster + queue mirror + haproxy + keepalived实现：三节点集群支持2台故障，队列镜像至所有节点；haproxy四层负载均衡并健康检查；keepalived提供vip主备漂移，java客户端仅需连接vip即可透明访问。
Java 应用本身不直接配置 HAProxy 或 Keepalived——它们是部署在操作系统层的中间件组件。Java 客户端只需连接到 HAProxy 暴露的统一入口（VIP 或代理 IP），就能透明使用后端 RabbitMQ 集群的高可用能力。关键在于服务端架构搭建正确，客户端配置简洁可靠。
RabbitMQ 集群基础必须稳固
HAProxy 和 Keepalived 起作用的前提，是 RabbitMQ 本身已组成健康、可协同工作的集群：
- 三台节点（如 192.168.1.101/102/103）安装相同版本 RabbitMQ（推荐 3.8+），且运行同一 Erlang 版本
- 所有节点共享完全一致的
/var/lib/rabbitmq/.erlang.cookie（权限严格设为400） - /etc/hosts 中互相解析主机名（如
rabbit1、rabbit2、rabbit3），避免 DNS 不稳定影响集群握手 - 主节点执行
rabbitmqctl start_app后，其余节点以join_cluster --ram rabbit@rabbit1加入（至少保留一个磁盘节点） - 启用镜像队列：运行
rabbitmqctl set_policy ha-all "^" '{"ha-mode":"all"}'，确保队列自动跨节点同步
HAProxy 做 TCP 层负载均衡（4 层）
HAProxy 不解析 AMQP 协议内容，只做连接转发与健康检查，对 Java 客户端完全透明：
linux-sysadmin
下载
Linux系统管理专家，覆盖12大模块：用户权限、SSH、存储、网络、systemd、防火墙、日志监控、备份恢复、TLS证书、Ansible、容器、IaC。提供配置、验证、加固、监控、备份、自动化、故障排查、回滚闭环。关键词：useradd、sudo、sshd_config、chmod、SEL...
- 监听端口（如
5672）设为mode tcp，禁用 HTTP 模式 - 后端 server 使用真实 RabbitMQ 节点 IP + 5672 端口，开启
check参数（如inter 5000 rise 2 fall 3） - 轮询策略足够，无需复杂算法；避免使用
source等会话绑定策略，因 AMQP 连接天然无状态 - 建议开放管理监控页（如
:8100/stats），便于实时查看节点状态和连接分布
Keepalived 提供 VIP 故障漂移
两台 HAProxy 服务器（如 192.168.1.201/202）分别部署 Keepalived，共用一个虚拟 IP（VIP，如 192.168.1.250）：
- Master 节点
state MASTER，Backup 节点state BACKUP，优先级区分主备 -
vrrp_script检查 HAProxy 进程是否存活（例如killall -0 haproxy && exit 0 || exit 1） - 当 Master 上的 HAProxy 异常退出，Keepalived 自动触发 VIP 迁移到 Backup，整个过程通常
- 确保两台机器的防火墙放行 VRRP 协议（协议号 112）、且绑定网卡在同一子网
Java 客户端连接方式极简
你的 Spring Boot 或原生 AMQP 代码，只需把连接地址指向 VIP 即可，无需感知后端拓扑：
- Spring Boot 配置示例：
spring.rabbitmq.host=192.168.1.250、spring.rabbitmq.port=5672 - 手动 ConnectionFactory 设置：
factory.setHost("192.168.1.250")、factory.setPort(5672) - 连接失败时，AMQP 客户端会自动重试（配合
setAutomaticRecoveryEnabled(true)更健壮） - 无需在 Java 侧做多地址轮询或故障转移逻辑——那是 HAProxy 的职责
Java免费学习笔记：立即使用
解锁 Java 大师之旅：从入门到精通的终极指南
