RabbitMQ 高可用实战篇（Mirrored Queue + Cluster + 持久化整合）

1. 前言

在生产环境中，单节点 RabbitMQ 容易因故障导致消息丢失或业务中断。
通过高可用队列、集群部署和持久化策略，可以保证 消息可靠性、节点容错和持续服务。

本文重点：

1. 高可用队列（Mirrored Queue）实战配置
2. 集群节点部署与角色
3. 消息持久化与可靠性整合
4. 内存管理和流控策略
5. 核心源码解析

---

2. 高可用队列（Mirrored Queue）实战

2.1 配置示例

ha-mode: all
ha-sync-mode: automatic

• ha-mode = all：队列在所有节点创建副本
• ha-sync-mode = automatic：新节点加入时自动同步消息

2.2 消息同步流程

1. Master 队列接收消息
2. Master 将消息异步推送到所有 Slave
3. Slave 确认同步
4. Master ACK 给生产者，保证消息已持久化

2.3 源码解析

• rabbit_mirror_queue 模块管理 Master/Slave
• sync_slave/2 订阅 Master 队列
• deliver/2 投递消息到消费者并同步 Slave

---

3. 集群节点部署与角色

3.1 节点类型

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

3.2 集群角色

• Master：负责入队、出队、消费者投递
• Slave：同步 Master 数据，备用节点
• 多节点组成集群，实现容错与负载均衡

3.3 实战部署

• 节点 ≥ 3，保证多数派可用
• Master 部署在 Disk Node
• Slave 可部署在 RAM 或 Disk Node
• 使用 Erlang cookie 保证集群节点互信

---

4. 消息持久化与可靠性整合

4.1 队列与消息持久化

• 队列设置 durable = true
• 消息设置 persistent = true
• Broker 重启或节点故障可恢复消息

4.2 ACK/NACK 与 DLX

• 消费者手动 ACK，保证消息处理可靠
• NACK 或 TTL 过期 → 消息发送到 Dead Letter Exchange
• 配合 HA 队列，实现全链路可靠性

4.3 源码调用链

Producer.basic_publish ->rabbit_channel:handle_cast({basic_publish, Msg}, State) ->rabbit_exchange:route(Msg, Exchange) ->rabbit_mirror_queue:enqueue(Msg) ->deliver_to_slave(Msg) ->rabbit_queue:deliver(Consumer) ->rabbit_channel:handle_ack(MsgTag)

---

5. 内存管理与流控策略

5.1 内存告警

• vm_memory_high_watermark 阈值触发 Flow Control
• 超过阈值 → 阻塞生产者

5.2 消息过期与回收

• TTL 控制消息存活
• 队列空闲过期自动删除
• Erlang VM 自动回收出队消息

5.3 高并发优化

• Publisher Confirms 替代事务模式
• Queue 异步入队 + 异步投递
• 多进程 Actor 模型保障高吞吐量

---

6. 实战案例总结

1. 高可用队列：Master/Slave 同步，保证节点故障时消息不丢失
2. 集群部署：Disk Node + RAM Node，Master/Slave 协作
3. 消息持久化：队列和消息双持久化，结合 ACK/NACK
4. 内存管理：Flow Control + 消息 TTL + 队列回收
5. 源码分析：rabbit_mirror_queue、rabbit_queue、rabbit_channel、rabbit_exchange

---

7. 小结

通过本篇实战篇，整合了 RabbitMQ 高可用和可靠性机制：

• 配置 HA 队列，实现消息冗余
• 集群节点角色分工，实现容错和负载均衡
• 消息持久化 + ACK/NACK + DLX，保证消息链路可靠
• 内存管理与异步投递，保障高并发稳定性

📌 完整掌握这些机制后，可以在生产环境中搭建 高可用、可靠、高性能的 RabbitMQ 消息中间件系统。

---