RabbitMQ 簡介及使用場景
阿新 • • 發佈：2018-12-30
目錄
一. RabbitMQ 簡介
MQ全稱為Message Queue, 訊息佇列（MQ）是一種應用程式對應用程式的通訊方法。應用程式通過讀寫出入佇列的訊息（針對應用程式的資料）來通訊，而無需專用連線來連結它們。訊息傳遞指的是程式之間通過在訊息中傳送資料進行通訊，而不是通過直接呼叫彼此來通訊，直接呼叫通常是用於諸如遠端過程呼叫的技術。排隊指的是應用程式通過 佇列來通訊。佇列的使用除去了接收和傳送應用程式同時執行的要求。
二. RabbitMQ 使用場景
1. 解耦（為面向服務的架構（SOA）提供基本的最終一致性實現）
場景說明：使用者下單後，訂單系統需要通知庫存系統。傳統的做法是，訂單系統呼叫庫存系統的介面。
傳統模式的缺點：
- 假如庫存系統無法訪問，則訂單減庫存將失敗，從而導致訂單失敗
- 訂單系統與庫存系統耦合
引入訊息佇列
- 訂單系統：使用者下單後，訂單系統完成持久化處理，將訊息寫入訊息佇列，返回使用者訂單下單成功
- 庫存系統：訂閱下單的訊息，採用拉/推的方式，獲取下單資訊，庫存系統根據下單資訊，進行庫存操作
- 假如：在下單時庫存系統不能正常使用。也不影響正常下單，因為下單後，訂單系統寫入訊息佇列就不再關心其他的後續操作了。實現訂單系統與庫存系統的應用解耦
- 為了保證庫存肯定有，可以將佇列大小設定成庫存數量，或者採用其他方式解決。
基於訊息的模型，關心的是“通知”，而非“處理”。
簡訊、郵件通知、快取重新整理等操作使用訊息佇列進行通知。
訊息佇列和RPC的區別與比較：
RPC: 非同步呼叫，及時獲得呼叫結果，具有強一致性結果，關心業務呼叫處理結果。
訊息佇列：兩次非同步RPC呼叫，將呼叫內容在佇列中進行轉儲，並選擇合適的時機進行投遞（錯峰流控）
2. 非同步提升效率
場景說明：使用者註冊後，需要發註冊郵件和註冊簡訊。傳統的做法有兩種 1.序列的方式；2.並行方式
（1）序列方式：將註冊資訊寫入資料庫成功後，傳送註冊郵件，再發送註冊簡訊。以上三個任務全部完成後，返回給客戶端
（2）並行方式：將註冊資訊寫入資料庫成功後，傳送註冊郵件的同時，傳送註冊簡訊。以上三個任務完成後，返回給客戶端。與序列的差別是，並行的方式可以提高處理的時間
（3）引入訊息佇列，將不是必須的業務邏輯，非同步處理。改造後的架構如下：
3. 流量削峰
流量削鋒也是訊息佇列中的常用場景，一般在秒殺或團搶活動中使用廣泛
應用場景：秒殺活動，一般會因為流量過大，導致流量暴增，應用掛掉。為解決這個問題，一般需要在應用前端加入訊息佇列。
- 可以控制活動的人數
- 可以緩解短時間內高流量壓垮應用
- 使用者的請求，伺服器接收後，首先寫入訊息佇列。假如訊息佇列長度超過最大數量，則直接拋棄使用者請求或跳轉到錯誤頁面
- 秒殺業務根據訊息佇列中的請求資訊，再做後續處理
