xDev Asia

使用 RabbitMQ Cluster Operator、仲裁佇列、TLS、監控和微服務訊息傳遞最佳實踐在 Kubernetes 上部署 RabbitMQ HA 叢集。

使用 Kubernetes HA 在本地部署微服務

第 5 部分：訊息佇列 HA（RabbitMQ、Kafka、Redis）

xdev.asia

🎯 課程目標__HTMLTAG_68___

✅ 了解 RabbitMQ 叢集架構和訊息傳遞模式

✅ 使用 Cluster Operator 部署 RabbitMQ 3 節點叢集

✅ 為 HA 設定仲裁佇列

✅ 設定 TLS 加密與驗證

✅ 使用 Prometheus 監控 RabbitMQ 叢集

✅ 最佳實務：訊息持久性、DLQ、流量控制

第 1 部分：RABBITMQ 叢集架構

1.1。消息传递模式

___程式碼區塊_0___

1.2。 RabbitMQ 集群架构

___程式碼區塊_1___

Quorum Queue：Raft 共識 → 多數人複製數據經典佇列：僅在 1 個節點上（鏡像 = 已棄用）

___HTMLTAG_93__HTMLTAG_94___功能___HTMLTAG_95__HTMLTAG_96___經典佇列___HTMLTAG_97__HTMLTAG_98___仲裁佇列___HTMLTAG_99__HTMLTAG_100___流___HTMLTAG_1佇列___HTMLTAG_99__HTMLTAG_100___流___HTMLTAG_101__10G_101__1 ___HTMLTAG_105__HTMLTAG_106___複製___HTMLTAG_107__HTMLTAG_108___無（鏡像已棄用）___HTMLTAG_109__HTMLTAG_110___基於Raft（大多數）____HTMLTAG_111__HTMLTAG_110___基於Raft（大多數）____HTMLTAG_111__HTMLTAG_1110___ ___HTMLTAG_115__HTMLTAG_116___資料安全___HTMLTAG_117__HTMLTAG_118___低___HTMLTAG_119__HTMLTAG_120___高___HTMLTAG_121__HTMLTAG_122______高___HTMLTAG_1HTMLTAG_121__HTMLTAG_122______高___HTMLTAG_123124_____ ___HTMLTAG_125__HTMLTAG_126___效能___HTMLTAG_127__HTMLTAG_128___最高___HTMLTAG_129__HTMLTAG_130___良好（稍低）___HTMLTAG_131__HTMLTAG_132_______ML ___HTMLTAG_135__HTMLTAG_136___用例___HTMLTAG_137__HTMLTAG_138___臨時/非關鍵___HTMLTAG_139__HTMLTAG_140___關鍵業務___HTMLTAG_141__HTMLTAG_1422___事件流___MLTAGML____14141____1____422___ ___HTMLTAG_145__HTMLTAG_146___排序____HTMLTAG_147__HTMLTAG_148___FIFO___HTMLTAG_149__HTMLTAG_150___FIFO___HTMLTAG_151__HTMLTAG_152___ML_1532___ML

第 2 部分：安裝 RABBITMQ 叢集運算子

2.1。安裝運算子

___程式碼區塊_2___

2.2。為訊息傳遞建立命名空間

___程式碼區塊_3___

第 3 部分：部署 RABBITMQ HA 叢集

3.1。 RabbitmqCluster CRD

___程式碼區塊_4___

程式碼區塊_5

第 4 部分：法定人數佇列與策略

4.1。建立仲裁隊列

___程式碼區塊_6___

4.2。虛擬主機和使用者

___程式碼區塊_7___

第 5 部分：TLS 加密

程式碼區塊_8

第 6 部分：監控

程式碼區塊_9

程式碼區塊_10

第 7 部分：應用程式整合

程式碼區塊_11

程式碼區塊_12

💡 重點

___HTMLTAG_190__HTMLTAG_191___仲裁佇列：基於 Raft 的複製，一律用於生產 ___HTMLTAG_194__HTMLTAG_195___叢集運算子：K8s 上的宣告式 RabbitMQ，自動叢集 ___HTMLTAG_198__HTMLTAG_199___3 節點叢集：容忍 1 個節點故障（多數 = 2） ___HTMLTAG_202__HTMLTAG_203___死信佇列：處理有害訊息，重試邏輯 ___HTMLTAG_206__HTMLTAG_207___TLS + 虛擬主機：隔離服務，在傳輸過程中加密 ___HTMLTAG_210__HTMLTAG_211___pause_minority：防止裂腦分區處理

🎯 練習

練習 1：RabbitMQ HA 實驗室

部署 3 節點 RabbitMQ 叢集
使用 DLQ 建立仲裁佇列
發布 10,000 則訊息，殺死 1 個節點，驗證沒有訊息遺失

練習 2：監控設定__HTMLTAG_229___

設定 PodMonitor

導入 RabbitMQ Grafana 儀表板（ID：10991）

為佇列積壓 > 5000 建立警報

📚 下一篇文章

在 第 22 課：使用 Strimzi Operator 的 Apache Kafka 群集 中，我們將部署 Kafka 進行高吞吐量事件流處理。

第 21 課：Kubernetes 上的 RABBITMQ HA 集群