RabbitMQ 高可用与集群机制

RabbitMQ 高可用与集群机制

1. 前言

在生产环境中，单节点 RabbitMQ 可能因故障导致消息丢失或服务中断。
高可用（HA）和集群机制保证了 消息可靠性、节点容错、自动故障转移。

本文重点解析：

1. Mirrored Queue 高可用队列
2. 集群节点角色及同步机制
3. 故障检测与自动转移流程
4. 核心源码与消息一致性保障

---

2. Mirrored Queue 高可用队列

2.1 概念

• HA 队列在集群中多个节点有副本
• Master 队列负责处理所有入队、出队操作
• Slave 队列同步 Master 消息，确保数据冗余

2.2 配置示例

ha-mode: all         % 所有节点都镜像
ha-sync-mode: automatic % 自动同步

2.3 消息同步流程

1. Master 收到消息 → 入队
2. Master 推送消息到所有 Slave
3. Slave 确认消息同步完成
4. Master 确认消息持久化后 ACK 给生产者

2.4 源码解析

• rabbit_mirror_queue 模块管理 Master/Slave
• sync_slave/2：Slave 订阅 Master 队列
• deliver/2：消息投递同时写入 Master 与 Slave

---

3. 集群节点角色

3.1 节点类型

类型	角色
Disk Node	持久化节点，存储队列和消息
RAM Node	内存节点，仅保存队列元数据

3.2 节点职责

• Leader (Master)：处理客户端消息，管理队列
• Follower (Slave)：同步 Leader 队列数据
• 集群中每个队列至少有一个 Master 与若干 Slave

3.3 集群管理

• rabbit_cluster 模块维护节点信息
• 节点心跳（heartbeat）监测状态
• 节点故障 → 自动触发 failover

---

4. 故障检测与转移

4.1 心跳机制

• 每个节点定期发送心跳
• 心跳超时 → 节点被标记为不可用

4.2 故障判定

1. Master 不可达 → Slave 选举成为新 Master
2. 更新节点状态并广播给集群
3. 队列继续接收生产者消息，保证业务不中断

4.3 源码解析

• rabbit_ha_policy 管理 HA 策略
• mirror_sync 流程：

master_enqueue(Msg) ->send_to_slaves(Msg),wait_for_slave_acks(Msg),confirm_to_producer(Msg).

• failover/1：Slave 升级为 Master，更新所有绑定队列

---

5. 消息一致性与可靠性

5.1 消息同步保证

• Master 写入消息 → 同步到所有 Slave → ACK
• 消息持久化到 Disk Node
• 消费者从 Master 队列拉取，确保顺序一致

5.2 消费者处理

• 消费者只连接 Master 队列
• Master 确认消息被所有 Slave 接收后才回 ACK
• 避免在 Master 故障时消息丢失

---

6. 高可用集群部署建议

1. 集群节点 ≥ 3，保证多数派可用
2. 每个队列配置至少一个 Slave
3. Master 配置 Disk Node，Slave 可为 RAM Node 或 Disk Node
4. HA 队列使用 ha-sync-mode: automatic 自动同步
5. 定期监控心跳、队列状态、消息同步延迟

---

7. 小结

本文解析了 RabbitMQ 高可用与集群机制：

1. Mirrored Queue：Master/Slave 消息同步，高可用队列
2. 集群节点角色：Disk Node、RAM Node，Master/Slave 协作
3. 故障检测与自动转移：心跳机制 + failover
4. 消息一致性保障：同步 ACK + 消费者确认

📌 通过 HA 队列与集群机制，RabbitMQ 实现了 消息可靠性、高可用、容错能力，为生产环境提供稳定支持。

---