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 消息中間件系統。

---