牛逼哄哄的 RabbitMQ 到底有啥用？

mq全稱為message queue, 訊息佇列（mq）是一種應用程式對應用程式的通訊方法。應用程式通過讀寫出入佇列的訊息（針對應用程式的資料）來通訊，而無需專用連線來鏈結它們。

訊息傳遞指的是程式之間通過在訊息中傳送資料進行通訊，而不是通過直接呼叫彼此來通訊，直接呼叫通常是用於諸如遠端過程呼叫的技術。排隊指的是應用程式通過佇列來通訊。佇列的使用除去了接收和傳送應用程式同時執行的要求。

rabbitmq是使用erlang語言開發的開源訊息佇列系統，基於amqp協議來實現。amqp的主要特徵是面向訊息、佇列、路由(包括點對點和發布/訂閱)、可靠性、安全。

amqp協議更多用在企業系統內，對資料一致性、穩定性和可靠性要求很高的場景，對效能和吞吐量的要求還在其次。

1. 解耦（為面向服務的架構（soa）提供基本的最終一致性實現）

場景說明：使用者下單後，訂單系統需要通知庫存系統。傳統的做法是，訂單系統呼叫庫存系統的介面。

傳統模式的缺點：

引入訊息佇列

基於訊息的模型，關心的是「通知」，而非「處理」。

簡訊、郵件通知、快取重新整理等操作使用訊息佇列進行通知。

訊息佇列和rpc的區別與比較：

rpc: 非同步呼叫，及時獲得呼叫結果，具有強一致性結果，關心業務呼叫處理結果。

訊息佇列：兩次非同步rpc呼叫，將呼叫內容在佇列中進行轉儲，並選擇合適的時機進行投遞（錯峰流控）

2. 非同步提公升效率

場景說明：使用者註冊後，需要發註冊郵件和註冊簡訊。傳統的做法有兩種

1.序列的方式；2.並行方式

（1）序列方式：將註冊資訊寫入資料庫成功後，傳送註冊郵件，再傳送註冊簡訊。以上三個任務全部完成後，返回給客戶端

（2）並行方式：將註冊資訊寫入資料庫成功後，傳送註冊郵件的同時，傳送註冊簡訊。以上三個任務完成後，返回給客戶端。與序列的差別是，並行的方式可以提高處理的時間

（3）引入訊息佇列，將不是必須的業務邏輯，非同步處理。改造後的架構如下：

3. 流量削峰

流量削鋒也是訊息佇列中的常用場景，一般在秒殺或團搶活動中使用廣泛。

應用場景：系統其他時間a系統每秒請求量就100個，系統可以穩定執行。系統每天晚間八點有秒殺活動，每秒併發請求量增至1萬條，但是系統最大的處理能力只能每秒處理1000個請求，於是系統崩潰，伺服器宕機。

之前架構：大量使用者（100萬使用者）通過瀏覽器在晚上八點高峰期同時參與秒殺活動。大量的請求湧入我們的系統中，高峰期達到每秒鐘5000個請求，大量的請求打到mysql上，每秒鐘預計執行3000條sql。

但是一般的mysql每秒鐘扛住2000個請求就不錯了，如果達到3000個請求的話可能mysql直接就癱瘓了，從而系統無法被使用。但是高峰期過了之後，就成了低峰期，可能也就1萬使用者訪問系統，每秒的請求數量也就50個左右，整個系統幾乎沒有任何壓力。

引入mq：100萬使用者在高峰期的時候，每秒請求有5000個請求左右，將這5000請求寫入mq裡面，系統a每秒最多只能處理2000請求，因為mysql每秒只能處理2000個請求。

系統a從mq中慢慢拉取請求，每秒就拉取2000個請求，不要超過自己每秒能處理的請求數量即可。mq，每秒5000個請求進來，結果只有2000個請求出去，所以在秒殺期間（將近一小時）可能會有幾十萬或者幾百萬的請求積壓在mq中。

這個短暫的高峰期積壓是沒問題的，因為高峰期過了之後，每秒就只有50個請求進入mq了，但是系統還是按照每秒2000個請求的速度在處理，所以說，只要高峰期一過，系統就會快速將積壓的訊息消費掉。

我們在此計算一下，每秒在mq積壓3000條訊息，1分鐘會積壓18萬，1小時積壓1000萬條訊息，高峰期過後，1個多小時就可以將積壓的1000萬訊息消費掉。

優點

優點就是以上的那些場景應用，就是在特殊場景下有其對應的好處，解耦、非同步、削峰。

缺點

所以總結來說，訊息佇列是一種十分複雜的架構，引入它有很多好處，但是也得針對它帶來的壞處做各種額外的技術方案和架構來規避。

引入mq系統複雜度提公升了乙個數量級，但是在有些場景下，就是複雜十倍百倍，還是需要使用mq。