RabbitMQ镜像集群高可用依赖服务端Policy配置、真实集群基础和客户端自动故障转移协同实现；Java层无需控制副本，仅需配合声明队列、多节点连接及启用自动恢复。
镜像队列靠 Policy 驱动，不是 Java 控制
镜像行为由 RabbitMQ 服务端统一策略（Policy）决定，Java 客户端声明队列时无需传 x-ha-policy 等参数——否则可能与服务端 Policy 冲突。只要队列名匹配 Policy 的正则表达式（如 ^ha\.），RabbitMQ 就自动为其创建主从副本。
- 用
rabbitmqctl set_policy设置策略，例如：rabbitmqctl set_policy ha-two "^ha\." '{"ha-mode":"exactly","ha-params":2,"ha-sync-mode":"automatic"}' -
ha-mode可选all（全节点）、exactly（指定数量）、nodes（指定节点列表） -
ha-sync-mode推荐automatic：主节点写入后异步同步到从节点，故障时自动补全；设为manual则需人工触发同步，生产环境不推荐
集群必须真实可用，不是“连得上”就行
镜像队列依赖集群正常运转。单节点或伪集群无法生效，常见失败原因多是基础配置没对齐：
- 所有节点必须加入同一集群：
rabbitmqctl cluster_status显示running_nodes包含全部节点，且角色一致（至少一个磁盘节点） - Erlang cookie 必须完全相同（
~/.erlang.cookie），否则节点间无法通信 - 防火墙开放
25672（集群通信）和5672（AMQP）端口 - 各节点 hostname 能互相解析（建议 /etc/hosts 静态绑定），避免 Erlang 分布式通信失败
Java 客户端要支持自动故障转移
客户端不能只连一个 IP。一旦主节点宕机，连接必须能自动切到其他存活节点，否则即使队列已镜像，应用也会中断：
deep-java-review
下载
Java项目代码review工具。分析Git变更+完整调用链路上下文，推断业务需求，进行多维度评分和分类汇总，生成完整PRD文档。包含细粒度Java代码审查清单（Null安全、异常处理、Streams、并发、equals/hashCode、资源管理、API设计、性能、MyBatis/ORM、事务边界、SQL/DD...
- 使用
Address[]构造连接工厂，传入多个 RabbitMQ 节点地址 - 开启自动恢复：
factory.setAutomaticRecoveryEnabled(true) - 启用网络恢复监听器（可选但推荐），便于日志追踪重连过程
- 避免在代码里硬编码单个 host，建议通过配置中心或 DNS 负载均衡（如 HAProxy、Keepalived VIP）统一入口
验证镜像是否真正生效
不能只看代码跑通，要确认服务端状态和容错表现：
立即学习“Java免费学习笔记（深入）”；
- 进管理界面（
http://ip:15672），Queue 页面看目标队列 Features 列是否显示 HA - 点击队列名 → Node 标签页，确认列出多个节点，且明确标出 Master 和 Slaves
- 手动停掉 Master 所在节点，观察几秒内是否自动选出新 Master，消费者/生产者无感知继续收发
- 检查消息是否未丢失：发送带
mandatory和publisher confirms的持久化消息，再模拟故障，验证消费端能收到全部消息
