1.什么是消息中間件

? ? ? ?消息中間件是指：利用高效可靠的消息傳遞機制進行與平臺無關的數據交流，并基于數據通信來進行分布式系統的集成。通過提供消息傳遞和消息排隊模型，可以在分布式架構下擴展進程之間的通信。

2.消息中間件能做什么

? ? ? ?消息中間件主要解決的就是分布式系統之間消息傳遞的問題，它能夠屏蔽各種平臺以及協議之間的特性，實現應用程序之間的協同。

? ? ? ?使用消息中間件，主要有如下兩個特點：①異步化? ?②解耦。我們可以從如下兩個實例來入手，具體了解消息中間件在項目中的具體使用場景。

場景一：電商平臺用戶注冊功能

? ? ? ?用戶注冊這一服務，并不單單只是向數據庫中insert一條數據即可，有些時候比如我們使用郵箱來注冊，還需要發送激活郵件等操作。新用戶還有可能會給你發送新人紅包、發送短信等來提示你注冊成功等等操作。

? ? ? ?我們從上圖這個注冊服務可以看到，信息入庫、發送激活短信...等每一個操作都是獨立的。同時，基于領域劃分(請參考：領域驅動設(DDD))以后，發送郵件短信、發送新人紅包、發送注冊成功短信等都屬于不同的子域。所以我們可以對這些子模塊來異步化執行，類似于多線程并行處理的概念。

? ? ? ?如何實現異步化呢？多線程當然可以實現，只是消息的持久化、消息的重發這些條件，多線程并不能滿足。所以需要借助一些開源中間件來解決。而分布式消息隊列就是一個非常好的解決辦法，引入分布式消息隊列以后，架構圖就變成這樣了(下圖是異步消息隊列的場景)。通過引入分布式隊列，就能夠大大提升程序的處理效率，并且還解決了各個模塊之間的耦合問題。

? ? ?? 具體步驟為：用戶注冊成功后，發送一條信息到消息中間件，其他的幾個子域如果有需要的話，只需要訂閱/關注該消息中間件，就能夠實現異步化操作了。這就是分布式消息隊列異步化 && 解耦 的一個場景。

? ? ? 注冊接口并不依賴其他三個子域的操作的結果。成功或失敗，與主流程是沒有任何影響的。做解耦，只需要在當前功能關心核心領域即可，不需要關心其他子域，只需要保證其他子域的正確性即可。

? ? ? ?假如說這里面每一部操作都需要消耗1s，按照基礎一個Conntroller開發，將這4步都寫在一個Controller中，整個注冊過程就需要消耗4s才能響應給客戶。使用消息中間件之后，則整個過程只需要消耗1s多，便能夠響應給客戶，明顯縮短了響應時間，這就是異步化所帶來的好處。

場景二：流量削峰(秒殺、搶購情景)

? ? ? ?比如在電商平臺的秒殺場景下，流量會非常大。通過消息隊列的方式可以很好的緩解高流量的問題，異步的消息隊列，可以通過排隊的機制，來很好的解決這一問題。

? ? ? 具體步驟如下：①用戶提交過來的請求，先寫入到消息隊列。消息隊列是有長度的，如果消息隊列長度超過指定長度，直接拋棄；?②秒殺的具體核心處理業務，接收消息隊列中消息，并進行下一步處理。

其他場景使用：??

? ? ? ?消息中間件還有更多應用場景，比如在弱一致性事務模型中，可以采用分布式消息隊列的實現最大能力通知方式來實現數據的最終一致性等等?

3.常用的消息中間件有哪些

①ActiveMQ

? ? ? ?ActiveMQ 是Apache出品，最流行的，能力強的開源消息總線。ActiveMQ 是一個完全支持JMS1.1和J2EE 1.4規范的 JMS Provider實現。官網：https://activemq.apache.org/

②RabbitMQ

? ? ? ? AMQP協議的領導實現，支持多種場景。淘寶的MySQL集群內部有使用它進行通訊，OpenStack開源云平臺的通信組件，最先在金融行業得到運用。官網：http://www.rabbitmq.com/

③ZeroMQ

? ? ? ? 史上最快的消息隊列系統，這屬于是一個類庫，直接使用能不快嗎。官網：https://zeromq.org/

④Kafka

? ? ? ?Apache下的一個子項目 。特點：高吞吐，在一臺普通的服務器上即可以達到10w/s的吞吐速率；完全的分布式系統。適合處理海量數據。官網：http://kafka.apache.org/

⑤RocketMQ

? ? ? ? RocketMQ是阿里開源的消息中間件，目前已經捐獻給Apache基金會。它是由Java語言開發的，具備高吞吐量、高可用性、適合大規模分布式系統應用等特點，經歷過雙11的洗禮，實力不容小覷。官網：http://rocketmq.apache.org/

其他一些消息中間件，使用也不是很多，這里就不再過多羅列了

END

總結

以上是生活随笔為你收集整理的分布式--消息中间件的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。