"RabbitMQ？""Kafka？""RocketMQ？"...在日常學習與開發過程中，我們常常聽到消息隊列這個關鍵詞。我也在我的多篇文章中提到了這個概念。可能你是熟練使用消息隊列的老手，又或者你是不懂消息隊列的新手，不論你了不了解消息隊列，本文都將帶你搞懂消息隊列的一些基本理論。如果你是老手，你可能從本文學到你之前不曾注意的一些關于消息隊列的重要概念，如果你是新手，相信本文將是你打開消息隊列大門的一板磚。

一、什么是消息隊列

我們可以將消息隊列與用于存儲消息的容器進行比較。當需要使用消息時，我們可以取出消息以供自己使用。消息隊列是分布式系統中的重要組件。消息隊列的使用主要是為了提高系統性能和峰值削波，并通過異步處理減少系統耦合。當前，最常用的消息隊列是ActiveMQ，RabbitMQ，Kafka，RocketMQ。稍后我們將一一比較這些消息隊列。

另外，我們知道Queue是先進先出的數據結構，因此在使用消息時，它也是按順序使用的。例如，生產者向消費者發送消息1,2,3 ...，他們將以1,2,3 ...的順序消費。但是，有時，消息消費順序可能不正確。例如，消息使用失敗或具有多個使用者的隊列可能導致消息使用順序錯誤。我們必須確保消息使用順序正確。

除了上面提到的消息消費順序問題之外，使用消息隊列，我們還必須考慮如何確保消息不會被重復消費？如何確保消息的可靠傳輸(如何處理消息丟失的問題)？ ... 等等。因此，消息隊列的使用并不完美。使用它還會降低系統可用性并增加復雜性。另外，我們需要確保一致性和其他問題。

二、拆解學習

消息隊列學習大綱

三、RabbitMQ

本學習文檔共分為11部分，前后章節都有相關的聯系，基本上按照由淺入深、由表及里的層次逐層進行講解。

主要針對消息中間件做一個摘要性介紹，包括什么是消息中間件、消息中間件的作用及特點等。之后引入RabbitMQ,對其歷史和相關特點做一個簡要概述。 最后介紹RabbitMQ的安裝及生產、消費的使用示例。

主要講述RabbitMQ的入門知識，包括生產者、消費者、隊列、交換器、路由鍵、綁定、連接及信道等基本術語。還闡述了RabbiMQ與AMQP協議的對應關系。

主要介紹RabbitMQ客戶端開發的簡單使用，按照一個生命周期對連接、 創建、生產、消費及關閉等幾個方面進行宏觀的介紹。

介紹數據可靠性的一些細節，并展示RabbitMQ的幾種已具備或衍生的高級特性，包括TTL、死信隊列、延遲隊列、優先級隊列、RPC 等，這些功能在實際使用中可以讓某些應用的實現變得事半功倍。

主要圍繞RabbitMQ管理這個主題展開，包括多租戶、權限、用戶、應用和集群管理、服務端狀態等方面，并且從側面講述rbbingctl工具和abbitonq managemnent 插件的使用。

主要講述RabbiMQ的配置，以此可以通過環境變量、配置文件、運行時參數(和策略)等三種方式來定制化相應的服務。

主要圍繞運維層面展開論述，主要包括集群搭建、日志查看、故障恢復、集群遷移、集群監控這幾個方面。

主要講述Federation和Shovel這兩個插件的使用、細節及相關原理。區別于第7節中集群的部署方式，Federation 和Shovel可以部署在廣域網中，為RabbitMQ提供更廣泛的應用空間。

介紹RabbitMQ相關的一些原理， 主要內容包括RabbiMQ存儲機制、磁盤和內存告警、流控機制、鏡像隊列。了解這些實現的細節及原理十分必要，它們可以讓讀者在遇到問題時能夠透過現象看本質。

四、RocketMQ

本文檔旨在描述 RocketMQ 的多個關鍵特性的實現原理，并對消息中間件遇到的各種問題進行總結，闡述RocketMQ 如何解決這些問題。文中主要引用了 JMS 規范與 CORBA Notification 規范，規范為我們設計系統指明了方向，但是仍有不少問題規范沒有提及，對于消息中間件又至關重要。RocketMQ 并不遵循任何規范，但是參考了各種規范與同類產品的設計思想

更多RocketMQ資料請參考小編之前的文章：

RocketMQ全貌解析，阿里不愧是阿里

五、Kafka

全學習文檔分為4篇：

介紹了消息隊列和Kafka、安裝與配置Kafka環境

介紹了Kafka的基礎操作、生產者和消費者、存儲及管理數據

介紹了更高級的Kafka知識及應用，包括安全機制、連接器、流處理、監控與測試

是對前面知識的綜合及實際應用，包括ELK套件整合實戰、Spark實時計算引擎整合實戰、Kafka Eagle監控系統設計與實現實戰。

開源軟件Kafa的應用越來越廣泛。Katka 簡單易學，其學習曲線平緩且學習周期短。只需要較短的時間學習，就可以學會Kafka應用開發，完成一個高可用集群的部署和高可用應用程序的編寫。

面對Kafka的普及和學習熱潮，小編愿意分享自己多年的開發經驗，帶領大家比較輕松地掌握Kafka的相關知識。這便是小編編寫本學習文檔的原因。

更多Kafka資料請參考小編之前的文章：

java開發必知必會的技能,沒有系統掌握Kafka,你就缺少核心競爭力

六、面試講解

1. 面試題

RabbitMQ

RabbitMQ 中的 broker 是指什么？cluster 又是指什么？

什么是元數據？元數據分為哪些類型？包括哪些內容？與 cluster 相關的元數據 有哪些？元數據是如何保存的？元數據在 cluster 中是如何分布的

RAM node 和 disk node 的區別？

RabbitMQ 上的一個 queue 中存放的 message 是否有數量限制？

RabbitMQ 概念里的 channel、exchange 和 queue 這些東東是邏輯概念，還是對 應著進程實體？這些東東分別起什么作用？

Kafka

Kafka 的設計時什么樣的呢？

數據傳輸的事物定義有哪三種？

Kafka 判斷一個節點是否還活著有那兩個條件？

producer 是否直接將數據發送到 broker 的 leader(主節點)？

Kafa consumer 是否可以消費指定分區消息？

學習感悟

如果你掌握了消息隊列的底層技術，無論使用哪種消息隊列產品，你都可以從原理層面來分析問題，再簡單看一下它的 API和相關配置項，就能很快知道該如何配置消息隊列，寫出高性能并且可靠的程序！

說明：

本文所涉及的學習文檔，面試資料都是小編自己收集整理而來的，正在學習"消息隊列"或者有需要的朋友可以幫忙評論+轉發一下，然后在這里@Java架構師丨蘇先生私信【隊列】即可獲取以上所有的學習資料的免費領取方式

總結

以上是生活随笔為你收集整理的消息队列 策略_太狠了!京东T8架构师建议吃透这40W字消息队列文档,涨薪15K不是梦...的全部內容，希望文章能夠幫你解決所遇到的問題。

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