消息隊列是分布式應(yīng)用間交換信息的重要組件，消息隊列可駐留在內(nèi)存或磁盤上, 隊列可以存儲消息直到它們被應(yīng)用程序讀走。

通過消息隊列，應(yīng)用程序可以在不知道彼此位置的情況下獨(dú)立處理消息，或者在處理消息前不需要等待接收此消息。

所以消息隊列可以解決應(yīng)用解耦、異步消息、流量削鋒等問題，是實(shí)現(xiàn)高性能、高可用、可伸縮和最終一致性架構(gòu)中不可以或缺的一環(huán)。

現(xiàn)在比較常見的消息隊列產(chǎn)品主要有ActiveMQ、RabbitMQ、ZeroMQ、Kafka、RocketMQ等。今天為大家介紹一下每個消息隊列及各自特點(diǎn)，并為大家準(zhǔn)備了一套學(xué)習(xí)資料，感興趣的就讀下去吧~

ps：學(xué)習(xí)資料已打包，文末領(lǐng)取！

1、ActiveMQ

ActiveMQ 是Apache出品，最流行的，能力強(qiáng)勁的開源消息總線。ActiveMQ 是一個完全支持JMS1.1和J2EE 1.4規(guī)范的 JMS Provider實(shí)現(xiàn)，盡管JMS規(guī)范出臺已經(jīng)是很久的事情了，但是JMS在當(dāng)今的J2EE應(yīng)用中間仍然扮演著特殊的地位。

pdf來源網(wǎng)絡(luò)，侵刪

最新使用文檔請移步至官網(wǎng)：
https://activemq.apache.org/

教程分享：《ActiveMQ使用手冊》

本文檔第二部分介紹了 ActiveMQ 的原理和重要配置介紹，第三部門介紹群集搭建方式 ， 分析各種集群方式的優(yōu)缺點(diǎn) ，第四部分實(shí)戰(zhàn)搭建Master-Slave+Broker-Custer 的群集，第五部分是對 ActiveMQ 的監(jiān)控，可以通過JMX 接口直接獲取當(dāng)前的消息情況，第六部分是對 ActiveMQ 使用要注意的情況。對于清楚 JMS 和 ActiveMQ 熟悉的，需要對 ActiveMQ 做集群處理，可以跳過第二、三章直接看第四章實(shí)踐。

2、RabbitMQ

RabbitMQ是流行的開源消息隊列系統(tǒng)，用erlang語言開發(fā)。RabbitMQ是AMQP（高級消息隊列協(xié)議）的標(biāo)準(zhǔn)實(shí)現(xiàn)。支持多種客戶端，如：Python、Ruby、.NET、Java、JMS、C、PHP、ActionScript、XMPP、STOMP等，支持AJAX，持久化。用于在分布式系統(tǒng)中存儲轉(zhuǎn)發(fā)消息，在易用性、擴(kuò)展性、高可用性等方面表現(xiàn)不俗。

教程分享：《RabbitMQ中文文檔》

pdf來源網(wǎng)絡(luò)，侵刪

最新使用文檔請移步至官網(wǎng)：https://www.rabbitmq.com

入門教程分為6大部分，對純小白來說有一定參考意義

3、ZeroMQ

號稱史上最快的消息隊列，它實(shí)際類似于Socket的一系列接口，他跟Socket的區(qū)別是：普通的socket是端到端的（1:1的關(guān)系），而ZMQ卻是可以N：M 的關(guān)系，人們對BSD套接字的了解較多的是點(diǎn)對點(diǎn)的連接，點(diǎn)對點(diǎn)連接需要顯式地建立連接、銷毀連接、選擇協(xié)議（TCP/UDP）和處理錯誤等，而ZMQ屏蔽了這些細(xì)節(jié)，讓你的網(wǎng)絡(luò)編程更為簡單。ZMQ用于node與node間的通信，node可以是主機(jī)或者是進(jìn)程。

引用官方的說法：“ZMQ(以下ZeroMQ簡稱ZMQ)是一個簡單好用的傳輸層，像框架一樣的一個socket library，他使得Socket編程更加簡單、簡潔和性能更高。是一個消息處理隊列庫，可在多個線程、內(nèi)核和主機(jī)盒之間彈性伸縮。ZMQ的明確目標(biāo)是“成為標(biāo)準(zhǔn)網(wǎng)絡(luò)協(xié)議棧的一部分，之后進(jìn)入Linux內(nèi)核”。現(xiàn)在還未看到它們的成功。但是，它無疑是極具前景的、并且是人們更加需要的“傳統(tǒng)”BSD套接字之上的一 層封裝。ZMQ讓編寫高性能網(wǎng)絡(luò)應(yīng)用程序極為簡單和有趣。”

教程分享：《ZeroMQ官方文檔中文版》

pdf來源網(wǎng)絡(luò)，侵刪

最新使用文檔請移步至官網(wǎng)：https://zeromq.org/

本篇文檔共300+頁，五大章內(nèi)容：

第一章 ZeroMQ 基礎(chǔ)

第二章 ZeroMQ 進(jìn)階

第三章 高級請求-應(yīng)答模式

第四章 可靠的請求-應(yīng)答模式

第五章 高級發(fā)布-訂閱模式

4、Kafka

Kafka是一種高吞吐量的分布式發(fā)布訂閱消息系統(tǒng)，它可以處理消費(fèi)者規(guī)模的網(wǎng)站中的所有動作流數(shù)據(jù)。這種動作（網(wǎng)頁瀏覽，搜索和其他用戶的行動）是在現(xiàn)代網(wǎng)絡(luò)上的許多社會功能的一個關(guān)鍵因素。這些數(shù)據(jù)通常是由于吞吐量的要求而通過處理日志和日志聚合來解決。對于像Hadoop的一樣的日志數(shù)據(jù)和離線分析系統(tǒng)，但又要求實(shí)時處理的限制，這是一個可行的解決方案。Kafka的目的是通過Hadoop的并行加載機(jī)制來統(tǒng)一線上和離線的消息處理，也是為了通過集群機(jī)來提供實(shí)時的消費(fèi)。

教程分享：《Kafka官方中文文檔》

pdf來源網(wǎng)絡(luò)，侵刪

最新使用文檔請移步至官網(wǎng)：http://kafka.apache.org/

Kafka官方中文文檔既適合小白入門也適合有一定基礎(chǔ)的同學(xué)進(jìn)階提升。這份文檔共分為9大部分：Kafka基礎(chǔ)入門，APIS，Kafka配置，Kafka設(shè)計思想及實(shí)現(xiàn)，操作，安全，Kafka 連接器及Kafka streams。幾乎涵蓋了Kafka所有的知識點(diǎn)。

第一部分：Kafka基礎(chǔ)入門

這一部分是學(xué)習(xí)Kafka的準(zhǔn)備階段，Kafka的發(fā)展，使用案例，下載及歷史版本，都在這一部分進(jìn)行了詳細(xì)的描述。

第二部分：APIS

kafka包括五個核心APIS，在這一部分中分別對其進(jìn)行了詳解。

1. Producer API允許應(yīng)用程序?qū)?shù)據(jù)流發(fā)送到Kafka集群中的主題。
2. Consumer API允許應(yīng)用程序從Kafka集群中的主題讀取數(shù)據(jù)流。
3. Streams API允許將輸入主題中的數(shù)據(jù)流轉(zhuǎn)換為輸出主題。
4. Connect API允許實(shí)現(xiàn)將數(shù)據(jù)不斷從某些源系統(tǒng)或應(yīng)用程序中輸入Kafka的連接器，或從Kafka輸入某些接收器系統(tǒng)或應(yīng)用程序。
5. AdminClient API允許管理和檢查主題，代理和其他Kafka對象。

第三部分：配置

第四部分：設(shè)計思想

這一部分介紹了Kafka的設(shè)計思想以及一些重要概念解析：生產(chǎn)者，備份，消息分發(fā)策略，日志壓縮······

第五部分：實(shí)現(xiàn)思路

第五部分承接第四部分的內(nèi)容，對Kafka的實(shí)現(xiàn)思路進(jìn)行了詳盡介紹。

第六部分：Kafka操作

接下來就進(jìn)入了實(shí)操階段，基本原理，基礎(chǔ)概念了解清楚之后正式開始上手，這一部分的內(nèi)容會比較多，是基于LinkedIn使用Kafka作為生產(chǎn)系統(tǒng)的一些使用經(jīng)驗(yàn)。基礎(chǔ)配置，硬件操作系統(tǒng)及監(jiān)控，zookeeper等內(nèi)容都需要在本章掌握。

第七部分：Kafka安全

Kafka具有特性，通過單獨(dú)使用或者?起使用這些特性，提高了Kafka集群的安全性。

第八部分：Kafka連接器

這一部分主要介紹了：Kafka Connect ——?款可擴(kuò)展并且可靠地在 Apache Kafka 和其他系統(tǒng)之間進(jìn)行數(shù)據(jù)傳輸?shù)墓ぞ摺?/span>

Kafka Connect 可以攝取數(shù)據(jù)庫數(shù)據(jù)或者收集應(yīng)用程序的 metrics 存儲到 Kafka topics，使得數(shù)據(jù)可以用于低延遲的流處理。一個導(dǎo)出的 job 可以將來自 Kafkatopic 的數(shù)據(jù)傳輸?shù)蕉壌鎯Γ糜谙到y(tǒng)查詢或者批量進(jìn)行離線分析。

第九部分：Kafka Streams

Kafka Streams 是一個用于處理和分析存儲在 Kafka 系統(tǒng)中的數(shù)據(jù)的客戶端庫。它建立在重要的流處理概念上，如恰當(dāng)?shù)貐^(qū)分事件時間（event time）和處理時間（processing time），支持窗口操作（window），exactly-once 處理語義以及簡單高效的應(yīng)用程序狀態(tài)管理。Kafka Streams 的入門門檻很低。我們可以在單節(jié)點(diǎn)環(huán)境上快速實(shí)現(xiàn)一個小規(guī)模的驗(yàn)證性的程序，只要程序能在多節(jié)點(diǎn)的集群環(huán)境成功運(yùn)行即可部署到高負(fù)載的生產(chǎn)環(huán)境。Kafka Streams 通過利用Kafka 的并行模型實(shí)現(xiàn)對相同應(yīng)用程序的多個實(shí)例的負(fù)載平衡，這對于用戶來說是透明的。

5、 RocketMQ

RocketMQ是阿里開源的消息中間件，純Java開發(fā)，具有高吞吐量、高可用性、適合大規(guī)模分布式系統(tǒng)應(yīng)用的特點(diǎn)。RocketMQ思路起源于Kafka，但并不是簡單的復(fù)制，它對消息的可靠傳輸及事務(wù)性做了優(yōu)化，目前在阿里集團(tuán)被廣泛應(yīng)用于交易、充值、流計算、消息推送、日志流式處理、binglog分發(fā)等場景，支撐了阿里多次雙十一活動。

因?yàn)槭前⒗飪?nèi)部從實(shí)踐到產(chǎn)品的產(chǎn)物，因此里面很多接口、api并不是很普遍適用。可靠性毋庸置疑，而且與Kafka一脈相承（甚至更優(yōu)），性能強(qiáng)勁，支持海量堆積。

教程分享：《Apache RocketMQ v4.7.1 開發(fā)者指南》

pdf來源網(wǎng)絡(luò)，侵刪

最新使用文檔請移步至官網(wǎng)：
http://rocketmq.apache.org/

所有教程獲取方式

微信掃描下方二維碼

備注：消息隊列合集