Kafka、RocketMq、ActiveMQ、RabbitMQ和Apache Pulsar都是現(xiàn)在使用的比較多的主流MQ，下面我們來介紹RabbitMQ的架構設計。

    RabbitMQ使用Erlang語言開發(fā)消息隊列系統(tǒng)，基于AMQP協(xié)議（高級消息隊列協(xié)議）實現(xiàn)的一個開源的消息中間件，它允許應用程序之間進行異步通信，并且RabbitMQ提供了一種高效、可擴展、可靠的消息傳遞機制。

1、RabbitMQ的架構

    RabbitMQ有生產者和消費者，并且生產者和消費者之間是通過RabbitMQ Server來進行連接的，這樣的異步通訊方式使得生產者和消費者之間沒有強關聯(lián)，RabbitMQ的架構圖如下所示：

圖片

    RabbitMQ中有虛擬機（Virtual Host），虛擬機的作用是在一個完整的微服務架構可以使用同一個套RabbitMQ服務，在不同的微服務之間是根據(jù)虛擬機來進行區(qū)分的，如訂單系統(tǒng)使用一個虛擬機，商品系統(tǒng)使用自己的虛擬機，這樣不同的微服務使用它自己的虛擬機即可。

    同時虛擬機與虛擬機之間的數(shù)據(jù)是相互隔離，并不會互相產生影響，在虛擬機里面就存在了交換機（Exchange）和隊列（queue）。

    RabbitMQ與生產者、消費者之間的連接是通過多個信道實現(xiàn)的，信道是建立在Connection之上的虛擬連接，當應用程序與RabbitMQ Broker建立TCP連接的時候，客戶端緊接著可以創(chuàng)建一個AMQP信道(Channel)，每個信道都會被指派一個唯一的ID，RabbitMQ是使用長連接來處理請求。

2、RabbitMQ的組件

2.1 生產者

    生產者是消息的發(fā)送方，它主要是負責產生并發(fā)送消息到RabbitMQ，生產者通常將消息發(fā)送到交換機（Exchange），如下圖所示：

圖片

    為什么RabbitMQ將消息發(fā)送到交換機呢？假設RabbitMQ直接將消息投遞到隊列，如下圖所示：

圖片

    在電商系統(tǒng)中如果用戶支付成功之后，需要通知訂單系統(tǒng)修改訂單的訂單狀態(tài)，通知商品系統(tǒng)扣減商品的庫存，此時支付系統(tǒng)的作為消息的生產者就需要通知消費者訂單系統(tǒng)和商品系統(tǒng)。

    如果采用直接將消息發(fā)送給隊列的方式，由于訂單系統(tǒng)、商品系統(tǒng)是消費的不同的隊列，此時支付系統(tǒng)就需要發(fā)送兩條訂單支付成功的MQ消息，為了解決這樣的問題，在RabbitMQ里面通常是先將消息發(fā)送到交換機，然后交換機再分發(fā)到不同的queue中。

2.2 交換機

    交換機（Exchange）是消息的分發(fā)中心，負責將接收到的消息路由到一個或多個隊列，如下圖所示：

圖片

    交換機定義了消息的傳遞規(guī)則，可以根據(jù)規(guī)則將消息發(fā)送到一個或多個隊列上，如下是RabbitMQ的交換機類型：

（1）直連交換機(Direct Exchange)：將消息路由到與消息中的路由鍵(Routing Key)完全匹配的隊列。生產者在發(fā)送消息的時候可以添加一個routing key，同時在隊列中也會設置一個key，如果這兩個key完全匹配上了，才會將消息路由到這個隊列中。

（2）主題交換機(Topic Exchange)：根據(jù)通配符匹配路由鍵，將消息路由到一個或多個隊列。

（3）扇出交換機(Fanout Exchange)：將消息廣播到所有與交換機綁定的隊列，忽略路由鍵。

（4）頭部交換機(Headers Exchange)：根據(jù)消息頭中的屬性進行匹配，將消息路由到與消息頭匹配的隊列?，F(xiàn)在使用的比較少，因為它的性能比較低。

RabbitMQ的交換機推薦使用直連交換機和主題交換機和扇出交換機。

2.3 隊列

    消息隊列介于生產者和消費者，本質上就是一個類似鏈表的獨立進程，列表里的每個節(jié)點是一個消息，如下圖所示：

圖片

    實際的業(yè)務中，消息也分很多種類，如訂單消息、用戶消息、支付消息等等，為了更好的管理不同種類的消息數(shù)據(jù)進而提供多個隊列，生產者生產的消息根據(jù)需要被投遞到不同的隊列中。同時每個隊列都設計為獨立的進程，某個進程掛了后不影響其他進程正常工作，如下圖所示：

圖片

    消息最終會被消費者從隊列中取出并處理，每個隊列不僅有一個名稱，并且可以綁定到一個或多個交換機。

2.4 消費者

    消費者是消息的接收方，負責從隊列中獲取消息并進行處理。消費者通過訂閱隊列來接收消息。

2.5 綁定

    綁定是交換機和隊列之間的關聯(lián)關系。生產者將消息發(fā)送到交換機，隊列通過綁定與交換機關聯(lián)，從而接收到消息，如下圖所示：

圖片

2.6 虛擬主機

    虛擬主機是RabbitMQ的基本工作單元，每個虛擬主機擁有自己獨立的用戶、權限、交換機、隊列等資源，完全隔離于其他虛擬主機。

2.7 連接

    連接是指生產者、消費者與RabbitMQ之間的網絡連接。每個連接可以包含多個信道(Channel)，每個信道是一個獨立的會話通道，可以進行獨立的消息傳遞。

3、RabbitMQ的消息生產和消費過程

圖片

    RabbitMQ中生產者通過長鏈接的方式連接到Broker，然后生產的消息被發(fā)送到對應的交換機上，此時交換機會將消息發(fā)送到對應的隊列上存儲，最后消費者就會來拉取消息來進行處理，處理成功之后就會將這個消息進行移除。