導(dǎo)語(yǔ) ： 消息隊(duì)列是分布式系統(tǒng)中重要的組件，在很多生產(chǎn)環(huán)境如商品搶購(gòu)等需要控制并發(fā)量的場(chǎng)景下都需要用到。最近組內(nèi)需要做流水server的選型升級(jí)，這里對(duì)消息隊(duì)列及常見的消息隊(duì)列進(jìn)行了一次調(diào)研，整理了相關(guān)資料，分享給大家。

創(chuàng)新互聯(lián)主要從事網(wǎng)站設(shè)計(jì)、做網(wǎng)站、網(wǎng)頁(yè)設(shè)計(jì)、企業(yè)做網(wǎng)站、公司建網(wǎng)站等業(yè)務(wù)。立足成都服務(wù)東營(yíng)區(qū),10余年網(wǎng)站建設(shè)經(jīng)驗(yàn),價(jià)格優(yōu)惠、服務(wù)專業(yè),歡迎來電咨詢建站服務(wù):18980820575

一、消息隊(duì)列(MQ)概述

消息隊(duì)列（Message Queue），是分布式系統(tǒng)中重要的組件，其通用的使用場(chǎng)景可以簡(jiǎn)單地描述為：

當(dāng)不需要立即獲得結(jié)果，但是并發(fā)量又需要進(jìn)行控制的時(shí)候，差不多就是需要使用消息隊(duì)列的時(shí)候。

消息隊(duì)列主要解決了應(yīng)用耦合、異步處理、流量削鋒等問題。

當(dāng)前使用較多的消息隊(duì)列有RabbitMQ、RocketMQ、ActiveMQ、Kafka、ZeroMQ、MetaMq等，而部分?jǐn)?shù)據(jù)庫(kù)如Redis、Mysql以及phxsql也可實(shí)現(xiàn)消息隊(duì)列的功能。

二、消息隊(duì)列使用場(chǎng)景

消息隊(duì)列在實(shí)際應(yīng)用中包括如下四個(gè)場(chǎng)景：

• 應(yīng)用耦合：多應(yīng)用間通過消息隊(duì)列對(duì)同一消息進(jìn)行處理，避免調(diào)用接口失敗導(dǎo)致整個(gè)過程失??；

• 異步處理：多應(yīng)用對(duì)消息隊(duì)列中同一消息進(jìn)行處理，應(yīng)用間并發(fā)處理消息，相比串行處理，減少處理時(shí)間；

• 限流削峰：廣泛應(yīng)用于秒殺或搶購(gòu)活動(dòng)中，避免流量過大導(dǎo)致應(yīng)用系統(tǒng)掛掉的情況；

• 消息驅(qū)動(dòng)的系統(tǒng)：系統(tǒng)分為消息隊(duì)列、消息生產(chǎn)者、消息消費(fèi)者，生產(chǎn)者負(fù)責(zé)產(chǎn)生消息，消費(fèi)者(可能有多個(gè))負(fù)責(zé)對(duì)消息進(jìn)行處理；

下面詳細(xì)介紹上述四個(gè)場(chǎng)景以及消息隊(duì)列如何在上述四個(gè)場(chǎng)景中使用：

2.1 異步處理

具體場(chǎng)景：用戶為了使用某個(gè)應(yīng)用，進(jìn)行注冊(cè)，系統(tǒng)需要發(fā)送注冊(cè)郵件并驗(yàn)證短信。對(duì)這兩個(gè)操作的處理方式有兩種：串行及并行。

（1）串行方式：新注冊(cè)信息生成后，先發(fā)送注冊(cè)郵件，再發(fā)送驗(yàn)證短信；

在這種方式下，需要最終發(fā)送驗(yàn)證短信后再返回給客戶端。

（2）并行處理：新注冊(cè)信息寫入后，由發(fā)短信和發(fā)郵件并行處理；

在這種方式下，發(fā)短信和發(fā)郵件 需處理完成后再返回給客戶端。

假設(shè)以上三個(gè)子系統(tǒng)處理的時(shí)間均為50ms，且不考慮網(wǎng)絡(luò)延遲，則總的處理時(shí)間：

串行：50+50+50=150ms 并行：50+50 = 100ms

若使用消息隊(duì)列：

并在寫入消息隊(duì)列后立即返回成功給客戶端，則總的響應(yīng)時(shí)間依賴于寫入消息隊(duì)列的時(shí)間，而寫入消息隊(duì)列的時(shí)間本身是可以很快的，基本可以忽略不計(jì)，因此總的處理時(shí)間相比串行提高了2倍，相比并行提高了一倍；

2.2 應(yīng)用耦合

具體場(chǎng)景：用戶使用QQ相冊(cè)上傳一張圖片，人臉識(shí)別系統(tǒng)會(huì)對(duì)該圖片進(jìn)行人臉識(shí)別，一般的做法是，服務(wù)器接收到圖片后，圖片上傳系統(tǒng)立即調(diào)用人臉識(shí)別系統(tǒng)，調(diào)用完成后再返回成功，如下圖所示：

該方法有如下缺點(diǎn)：

• 人臉識(shí)別系統(tǒng)被調(diào)失敗，導(dǎo)致圖片上傳失?。?/p>

• 延遲高，需要人臉識(shí)別系統(tǒng)處理完成后，再返回給客戶端，即使用戶并不需要立即知道結(jié)果；

• 圖片上傳系統(tǒng)與人臉識(shí)別系統(tǒng)之間互相調(diào)用，需要做耦合；

若使用消息隊(duì)列：

客戶端上傳圖片后，圖片上傳系統(tǒng)將圖片信息如uin、批次寫入消息隊(duì)列，直接返回成功；而人臉識(shí)別系統(tǒng)則定時(shí)從消息隊(duì)列中取數(shù)據(jù)，完成對(duì)新增圖片的識(shí)別。

此時(shí)圖片上傳系統(tǒng)并不需要關(guān)心人臉識(shí)別系統(tǒng)是否對(duì)這些圖片信息的處理、以及何時(shí)對(duì)這些圖片信息進(jìn)行處理。事實(shí)上，由于用戶并不需要立即知道人臉識(shí)別結(jié)果，人臉識(shí)別系統(tǒng)可以選擇不同的調(diào)度策略，按照閑時(shí)、忙時(shí)、正常時(shí)間，對(duì)隊(duì)列中的圖片信息進(jìn)行處理。

2.3 限流削峰

具體場(chǎng)景：購(gòu)物網(wǎng)站開展秒殺活動(dòng)，一般由于瞬時(shí)訪問量過大，服務(wù)器接收過大，會(huì)導(dǎo)致流量暴增，相關(guān)系統(tǒng)無(wú)法處理請(qǐng)求甚至崩潰。而加入消息隊(duì)列后，系統(tǒng)可以從消息隊(duì)列中取數(shù)據(jù)，相當(dāng)于消息隊(duì)列做了一次緩沖。

該方法有如下優(yōu)點(diǎn)：

1. 請(qǐng)求先入消息隊(duì)列，而不是由業(yè)務(wù)處理系統(tǒng)直接處理，做了一次緩沖,極大地減少了業(yè)務(wù)處理系統(tǒng)的壓力；

2. 隊(duì)列長(zhǎng)度可以做限制，事實(shí)上，秒殺時(shí)，后入隊(duì)列的用戶無(wú)法秒殺到商品，這些請(qǐng)求可以直接被拋棄，返回活動(dòng)已結(jié)束或商品已售完信息；

2.4 消息驅(qū)動(dòng)的系統(tǒng)

具體場(chǎng)景：用戶新上傳了一批照片， 人臉識(shí)別系統(tǒng)需要對(duì)這個(gè)用戶的所有照片進(jìn)行聚類，聚類完成后由對(duì)賬系統(tǒng)重新生成用戶的人臉?biāo)饕?加快查詢)。這三個(gè)子系統(tǒng)間由消息隊(duì)列連接起來，前一個(gè)階段的處理結(jié)果放入隊(duì)列中，后一個(gè)階段從隊(duì)列中獲取消息繼續(xù)處理。

該方法有如下優(yōu)點(diǎn)：

• 避免了直接調(diào)用下一個(gè)系統(tǒng)導(dǎo)致當(dāng)前系統(tǒng)失?。?/p>

• 每個(gè)子系統(tǒng)對(duì)于消息的處理方式可以更為靈活，可以選擇收到消息時(shí)就處理，可以選擇定時(shí)處理，也可以劃分時(shí)間段按不同處理速度處理；

三、消息隊(duì)列的兩種模式

消息隊(duì)列包括兩種模式，點(diǎn)對(duì)點(diǎn)模式（point to point， queue）和發(fā)布/訂閱模式（publish/subscribe，topic）。

3.1 點(diǎn)對(duì)點(diǎn)模式

點(diǎn)對(duì)點(diǎn)模式下包括三個(gè)角色：

• 消息隊(duì)列

• 發(fā)送者 (生產(chǎn)者)

• 接收者（消費(fèi)者）

消息發(fā)送者生產(chǎn)消息發(fā)送到queue中，然后消息接收者從queue中取出并且消費(fèi)消息。消息被消費(fèi)以后，queue中不再有存儲(chǔ)，所以消息接收者不可能消費(fèi)到已經(jīng)被消費(fèi)的消息。

點(diǎn)對(duì)點(diǎn)模式特點(diǎn)：

• 每個(gè)消息只有一個(gè)接收者（Consumer）(即一旦被消費(fèi)，消息就不再在消息隊(duì)列中)；

• 發(fā)送者和接收者間沒有依賴性，發(fā)送者發(fā)送消息之后，不管有沒有接收者在運(yùn)行，都不會(huì)影響到發(fā)送者下次發(fā)送消息；

• 接收者在成功接收消息之后需向隊(duì)列應(yīng)答成功，以便消息隊(duì)列刪除當(dāng)前接收的消息；

3.2 發(fā)布/訂閱模式

發(fā)布/訂閱模式下包括三個(gè)角色：

• 角色主題（Topic）

• 發(fā)布者(Publisher)

• 訂閱者(Subscriber)

發(fā)布者將消息發(fā)送到Topic,系統(tǒng)將這些消息傳遞給多個(gè)訂閱者。

發(fā)布/訂閱模式特點(diǎn)：

• 每個(gè)消息可以有多個(gè)訂閱者；

• 發(fā)布者和訂閱者之間有時(shí)間上的依賴性。針對(duì)某個(gè)主題（Topic）的訂閱者，它必須創(chuàng)建一個(gè)訂閱者之后，才能消費(fèi)發(fā)布者的消息。

• 為了消費(fèi)消息，訂閱者需要提前訂閱該角色主題，并保持在線運(yùn)行；

四、常用消息隊(duì)列介紹

本部分主要介紹四種常用的消息隊(duì)列（RabbitMQ/ActiveMQ/RocketMQ/Kafka）的主要特性、優(yōu)點(diǎn)、缺點(diǎn)。

4.1 RabbitMQ

RabbitMQ 2007年發(fā)布，是一個(gè)在AMQP(高級(jí)消息隊(duì)列協(xié)議)基礎(chǔ)上完成的，可復(fù)用的企業(yè)消息系統(tǒng)，是當(dāng)前最主流的消息中間件之一。

主要特性：

1. 可靠性: 提供了多種技術(shù)可以讓你在性能和可靠性之間進(jìn)行權(quán)衡。這些技術(shù)包括持久性機(jī)制、投遞確認(rèn)、發(fā)布者證實(shí)和高可用性機(jī)制；

2. 靈活的路由： 消息在到達(dá)隊(duì)列前是通過交換機(jī)進(jìn)行路由的。RabbitMQ為典型的路由邏輯提供了多種內(nèi)置交換機(jī)類型。如果你有更復(fù)雜的路由需求，可以將這些交換機(jī)組合起來使用，你甚至可以實(shí)現(xiàn)自己的交換機(jī)類型，并且當(dāng)做RabbitMQ的插件來使用；

3. 消息集群：在相同局域網(wǎng)中的多個(gè)RabbitMQ服務(wù)器可以聚合在一起，作為一個(gè)獨(dú)立的邏輯代理來使用；

4. 隊(duì)列高可用：隊(duì)列可以在集群中的機(jī)器上進(jìn)行鏡像，以確保在硬件問題下還保證消息安全；

5. 多種協(xié)議的支持：支持多種消息隊(duì)列協(xié)議；

6. 服務(wù)器端用Erlang語(yǔ)言編寫，支持只要是你能想到的所有編程語(yǔ)言；

7. 管理界面: RabbitMQ有一個(gè)易用的用戶界面，使得用戶可以監(jiān)控和管理消息Broker的許多方面；

8. 跟蹤機(jī)制：如果消息異常，RabbitMQ提供消息跟蹤機(jī)制，使用者可以找出發(fā)生了什么；

9. 插件機(jī)制：提供了許多插件，來從多方面進(jìn)行擴(kuò)展，也可以編寫自己的插件；

使用RabbitMQ需要：

• ErLang語(yǔ)言包

• RabbitMQ安裝包

RabbitMQ可以運(yùn)行在Erlang語(yǔ)言所支持的平臺(tái)之上：

Solaris

BSD

Linux

MacOSX

TRU64

Windows NT/2000/XP/Vista/Windows 7/Windows 8

Windows Server 2003/2008/2012

Windows 95, 98

VxWorks

優(yōu)點(diǎn)：

1. 由于erlang語(yǔ)言的特性，mq 性能較好，高并發(fā)；

2. 健壯、穩(wěn)定、易用、跨平臺(tái)、支持多種語(yǔ)言、文檔齊全；

3. 有消息確認(rèn)機(jī)制和持久化機(jī)制，可靠性高；

4. 高度可定制的路由；

5. 管理界面較豐富，在互聯(lián)網(wǎng)公司也有較大規(guī)模的應(yīng)用；

6. 社區(qū)活躍度高；

缺點(diǎn)：

1. 盡管結(jié)合erlang語(yǔ)言本身的并發(fā)優(yōu)勢(shì)，性能較好，但是不利于做二次開發(fā)和維護(hù)；

2. 實(shí)現(xiàn)了代理架構(gòu)，意味著消息在發(fā)送到客戶端之前可以在中央節(jié)點(diǎn)上排隊(duì)。此特性使得RabbitMQ易于使用和部署，但是使得其運(yùn)行速度較慢，因?yàn)橹醒牍?jié)點(diǎn)增加了延遲，消息封裝后也比較大；

3. 需要學(xué)習(xí)比較復(fù)雜的接口和協(xié)議，學(xué)習(xí)和維護(hù)成本較高；

4.2 ActiveMQ

ActiveMQ是由Apache出品，ActiveMQ 是一個(gè)完全支持JMS1.1和J2EE 1.4規(guī)范的 JMS Provider實(shí)現(xiàn)。它非?？焖?，支持多種語(yǔ)言的客戶端和協(xié)議，而且可以非常容易的嵌入到企業(yè)的應(yīng)用環(huán)境中，并有許多高級(jí)功能。

主要特性：

1. 服從 JMS 規(guī)范：JMS 規(guī)范提供了良好的標(biāo)準(zhǔn)和保證，包括：同步或異步的消息分發(fā)，一次和僅一次的消息分發(fā)，消息接收和訂閱等等。遵從 JMS 規(guī)范的好處在于，不論使用什么 JMS 實(shí)現(xiàn)提供者，這些基礎(chǔ)特性都是可用的；

2. 連接性：ActiveMQ 提供了廣泛的連接選項(xiàng)，支持的協(xié)議有：HTTP/S，IP 多播，SSL，STOMP，TCP，UDP，XMPP等等。對(duì)眾多協(xié)議的支持讓 ActiveMQ 擁有了很好的靈活性。

3. 支持的協(xié)議種類多：OpenWire、STOMP、REST、XMPP、AMQP ；

4. 持久化插件和安全插件：ActiveMQ 提供了多種持久化選擇。而且，ActiveMQ 的安全性也可以完全依據(jù)用戶需求進(jìn)行自定義鑒權(quán)和授權(quán)；

5. 支持的客戶端語(yǔ)言種類多：除了 Java 之外，還有：C/C++，.NET，Perl，PHP，Python，Ruby；

6. 代理集群：多個(gè) ActiveMQ 代理可以組成一個(gè)集群來提供服務(wù)；

7. 異常簡(jiǎn)單的管理：ActiveMQ 是以開發(fā)者思維被設(shè)計(jì)的。所以，它并不需要專門的管理員，因?yàn)樗峁┝撕?jiǎn)單又使用的管理特性。有很多中方法可以監(jiān)控 ActiveMQ 不同層面的數(shù)據(jù)，包括使用在 JConsole 或者 ActiveMQ 的Web Console 中使用 JMX，通過處理 JMX 的告警消息，通過使用命令行腳本，甚至可以通過監(jiān)控各種類型的日志。

使用ActiveMQ需要：

• Java JDK

• ActiveMQ安裝包

ActiveMQ可以運(yùn)行在Java語(yǔ)言所支持的平臺(tái)之上。

優(yōu)點(diǎn)：

1. 跨平臺(tái)(JAVA編寫與平臺(tái)無(wú)關(guān)有，ActiveMQ幾乎可以運(yùn)行在任何的JVM上)

2. 可以用JDBC：可以將數(shù)據(jù)持久化到數(shù)據(jù)庫(kù)。雖然使用JDBC會(huì)降低ActiveMQ的性能，但是數(shù)據(jù)庫(kù)一直都是開發(fā)人員最熟悉的存儲(chǔ)介質(zhì)。將消息存到數(shù)據(jù)庫(kù)，看得見摸得著。而且公司有專門的DBA去對(duì)數(shù)據(jù)庫(kù)進(jìn)行調(diào)優(yōu)，主從分離；

3. 支持JMS ：支持JMS的統(tǒng)一接口;

4. 支持自動(dòng)重連；

5. 有安全機(jī)制：支持基于shiro，jaas等多種安全配置機(jī)制，可以對(duì)Queue/Topic進(jìn)行認(rèn)證和授權(quán)。

6. 監(jiān)控完善：擁有完善的監(jiān)控，包括Web Console，JMX，Shell命令行，Jolokia的REST API；

7. 界面友善：提供的Web Console可以滿足大部分情況，還有很多第三方的組件可以使用，如hawtio；

缺點(diǎn)：

1. 社區(qū)活躍度不及RabbitMQ高；

2. 根據(jù)其他用戶反饋，會(huì)出莫名其妙的問題，會(huì)丟失消息；

3. 目前重心放到activemq6.0產(chǎn)品-apollo，對(duì)5.x的維護(hù)較少；

4. 不適合用于上千個(gè)隊(duì)列的應(yīng)用場(chǎng)景；

4.3 RocketMQ

RocketMQ出自 阿里公司的開源產(chǎn)品，用 Java 語(yǔ)言實(shí)現(xiàn)，在設(shè)計(jì)時(shí)參考了 Kafka，并做出了自己的一些改進(jìn)，消息可靠性上比 Kafka 更好。RocketMQ在阿里集團(tuán)被廣泛應(yīng)用在訂單，交易，充值，流計(jì)算，消息推送，日志流式處理，binglog分發(fā)等場(chǎng)景。

主要特性：

1. 是一個(gè)隊(duì)列模型的消息中間件，具有高性能、高可靠、高實(shí)時(shí)、分布式特點(diǎn)；

2. Producer、Consumer、隊(duì)列都可以分布式；

3. Producer向一些隊(duì)列輪流發(fā)送消息，隊(duì)列集合稱為Topic，Consumer如果做廣播消費(fèi)，則一個(gè)consumer實(shí)例消費(fèi)這個(gè)Topic對(duì)應(yīng)的所有隊(duì)列，如果做集群消費(fèi)，則多個(gè)Consumer實(shí)例平均消費(fèi)這個(gè)topic對(duì)應(yīng)的隊(duì)列集合；

4. 能夠保證嚴(yán)格的消息順序；

5. 提供豐富的消息拉取模式；

6. 高效的訂閱者水平擴(kuò)展能力；

7. 實(shí)時(shí)的消息訂閱機(jī)制；

8. 億級(jí)消息堆積能力；

9. 較少的依賴；

使用RocketMQ需要：

• Java JDK

• 安裝git、Maven

• RocketMQ安裝包

RocketMQ可以運(yùn)行在Java語(yǔ)言所支持的平臺(tái)之上。

優(yōu)點(diǎn)：

1. 單機(jī)支持 1 萬(wàn)以上持久化隊(duì)列

2. RocketMQ 的所有消息都是持久化的，先寫入系統(tǒng) PAGECACHE，然后刷盤，可以保證內(nèi)存與磁盤都有一份數(shù)據(jù)，

訪問時(shí)，直接從內(nèi)存讀取。

1. 模型簡(jiǎn)單，接口易用（JMS 的接口很多場(chǎng)合并不太實(shí)用）；

2. 性能非常好，可以大量堆積消息在broker中；

3. 支持多種消費(fèi)，包括集群消費(fèi)、廣播消費(fèi)等。

4. 各個(gè)環(huán)節(jié)分布式擴(kuò)展設(shè)計(jì)，主從HA；

5. 開發(fā)度較活躍，版本更新很快。

缺點(diǎn)：

支持的客戶端語(yǔ)言不多，目前是java及c++，其中c++不成熟；

RocketMQ社區(qū)關(guān)注度及成熟度也不及前兩者；

沒有web管理界面，提供了一個(gè)CLI(命令行界面)管理工具帶來查詢、管理和診斷各種問題；

沒有在 mq 核心中去實(shí)現(xiàn)JMS等接口；

4.4 Kafka

Apache Kafka是一個(gè)分布式消息發(fā)布訂閱系統(tǒng)。它最初由LinkedIn公司基于獨(dú)特的設(shè)計(jì)實(shí)現(xiàn)為一個(gè)分布式的提交日志系統(tǒng)( a distributed commit log)，，之后成為Apache項(xiàng)目的一部分。Kafka系統(tǒng)快速、可擴(kuò)展并且可持久化。它的分區(qū)特性，可復(fù)制和可容錯(cuò)都是其不錯(cuò)的特性。

主要特性：

1. 快速持久化，可以在O(1)的系統(tǒng)開銷下進(jìn)行消息持久化；

2. 高吞吐，在一臺(tái)普通的服務(wù)器上既可以達(dá)到10W/s的吞吐速率；

3. .完全的分布式系統(tǒng)，Broker、Producer、Consumer都原生自動(dòng)支持分布式，自動(dòng)實(shí)現(xiàn)負(fù)載均衡；

4. 支持同步和異步復(fù)制兩種HA；

5. 支持?jǐn)?shù)據(jù)批量發(fā)送和拉??；

6. zero-copy：減少IO操作步驟；

7. 數(shù)據(jù)遷移、擴(kuò)容對(duì)用戶透明；

8. 無(wú)需停機(jī)即可擴(kuò)展機(jī)器；

9. 其他特性：嚴(yán)格的消息順序、豐富的消息拉取模型、高效訂閱者水平擴(kuò)展、實(shí)時(shí)的消息訂閱、億級(jí)的消息堆積能力、定期刪除機(jī)制；

使用Kafka需要：

• Java JDK

• Kafka安裝包

優(yōu)點(diǎn)：

1. 客戶端語(yǔ)言豐富，支持java、.net、php、ruby、python、go等多種語(yǔ)言；

2. 性能卓越，單機(jī)寫入TPS約在百萬(wàn)條/秒，消息大小10個(gè)字節(jié)；

3. 提供完全分布式架構(gòu), 并有replica機(jī)制, 擁有較高的可用性和可靠性, 理論上支持消息無(wú)限堆積；

4. 支持批量操作；

5. 消費(fèi)者采用Pull方式獲取消息, 消息有序, 通過控制能夠保證所有消息被消費(fèi)且僅被消費(fèi)一次;

6. 有優(yōu)秀的第三方Kafka Web管理界面Kafka-Manager；

7. 在日志領(lǐng)域比較成熟，被多家公司和多個(gè)開源項(xiàng)目使用；

缺點(diǎn)：

1. Kafka單機(jī)超過64個(gè)隊(duì)列/分區(qū)，Load會(huì)發(fā)生明顯的飆高現(xiàn)象，隊(duì)列越多，load越高，發(fā)送消息響應(yīng)時(shí)間變長(zhǎng)

2. 使用短輪詢方式，實(shí)時(shí)性取決于輪詢間隔時(shí)間；

3. 消費(fèi)失敗不支持重試；

4. 支持消息順序，但是一臺(tái)代理宕機(jī)后，就會(huì)產(chǎn)生消息亂序；

5. 社區(qū)更新較慢；

4.5 RabbitMQ/ActiveMQ/RocketMQ/Kafka對(duì)比

這里列舉了上述四種消息隊(duì)列的差異對(duì)比：

結(jié)論:

Kafka在于分布式架構(gòu)，RabbitMQ基于AMQP協(xié)議來實(shí)現(xiàn)，RocketMQ/思路來源于kafka，改成了主從結(jié)構(gòu)，在事務(wù)性可靠性方面做了優(yōu)化。廣泛來說，電商、金融等對(duì)事務(wù)性要求很高的，可以考慮RabbitMQ和RocketMQ，對(duì)性能要求高的可考慮Kafka。

五、參考資料：

5.1 消息隊(duì)列：

1. 大型網(wǎng)站架構(gòu)之分布式消息隊(duì)列 http://blog.csdn.net/shaobingj126/article/details/50585035

2. 消息隊(duì)列的使用場(chǎng)景 https://www.zhihu.com/question/34243607/answer/127666030

3. 淺談異步消息隊(duì)列模型 http://www.cnblogs.com/sunkeydev/p/5248855.html

4. 消息隊(duì)列的兩種模式 http://blog.csdn.net/heyutao007/article/details/50131089

5.2 RabbitMQ

1. RabbitMQ主頁(yè) https://www.rabbitmq.com/

2. RabbitMQ學(xué)習(xí)教程 https://www.rabbitmq.com/getstarted.html

3. 專欄:RabbitMQ從入門到精通 http://blog.csdn.net/column/details/rabbitmq.html

4. RabbitMQ能為你做些什么 http://rabbitmq.mr-ping.com/description.html

5. RabbitMQ指南(1)-特性及功能 https://blog.zenfery.cc/archives/79.html

5.3 ActiveMQ

1. ActiveMQ主頁(yè) http://activemq.apache.org/

2. Apache ActiveMQ介紹 http://jfires.iteye.com/blog/1187688

3. ActiveMQ的簡(jiǎn)介與安裝 http://blog.csdn.net/sl1992/article/details/72824562

4. ActiveMQ 和消息簡(jiǎn)介 http://www.cnblogs.com/craftsman-gao/p/7002605.html

5.4 RocketMQ

1. 主頁(yè) https://github.com/alibaba/RocketMQ

2. RocketMQ 原理簡(jiǎn)介 http://alibaba.github.io/RocketMQ-docs/document/design/RocketMQ_design.pdf

3. RocketMQ與kafka對(duì)比（18項(xiàng)差異） http://jm.taobao.org/2016/03/24/rmq-vs-kafka/

5.5 Kafka

1.Kafka主頁(yè)： http://kafka.apache.org/

1. Kafka特性 http://www.cnblogs.com/lsx1993/p/4847719.html

2. Kafka客戶端支持語(yǔ)言 https://cwiki.apache.org/confluence/display/KAFKA/Clients

5.6 RabbitMQ/ActiveMQ/RocketMQ/Kafka對(duì)比

1. RocketMQ，隊(duì)列選型 http://www.zmannotes.com/index.php/2016/01/17/rocketmq/

2. RabbitMQ和Kafka http://www.dongcoder.com/detail-416804.html

3. 即時(shí)通信RabbitMQ二-性能測(cè)試 http://www.jianshu.com/p/d31ae9e3bfb6

4. RabbitMq、ActiveMq、ZeroMq、kafka之間的比較,資料匯總 http://blog.csdn.net/linsongbin1/article/details/47781187

5. 消息隊(duì)列軟件產(chǎn)品大比拼 http://www.cnblogs.com/amityat/archive/2011/08/31/2160293.html

總結(jié)：

消息隊(duì)列利用高效可靠的消息傳遞機(jī)制進(jìn)行平臺(tái)無(wú)關(guān)的數(shù)據(jù)交流，并基于數(shù)據(jù)通信來進(jìn)行分布式系統(tǒng)的集成。目前業(yè)界有很多的MQ產(chǎn)品，例如RabbitMQ、RocketMQ、ActiveMQ、Kafka、ZeroMQ、MetaMq等，也有直接使用數(shù)據(jù)庫(kù)redis充當(dāng)消息隊(duì)列的案例。而這些消息隊(duì)列產(chǎn)品，各有側(cè)重，在實(shí)際選型時(shí)，需要結(jié)合自身需求及MQ產(chǎn)品特征，綜合考慮。

另外有需要云服務(wù)器可以了解下創(chuàng)新互聯(lián)scvps.cn，海內(nèi)外云服務(wù)器15元起步，三天無(wú)理由+7*72小時(shí)售后在線，公司持有idc許可證，提供“云服務(wù)器、裸金屬服務(wù)器、高防服務(wù)器、香港服務(wù)器、美國(guó)服務(wù)器、虛擬主機(jī)、免備案服務(wù)器”等云主機(jī)租用服務(wù)以及企業(yè)上云的綜合解決方案，具有“安全穩(wěn)定、簡(jiǎn)單易用、服務(wù)可用性高、性價(jià)比高”等特點(diǎn)與優(yōu)勢(shì)，專為企業(yè)上云打造定制，能夠滿足用戶豐富、多元化的應(yīng)用場(chǎng)景需求。

網(wǎng)站欄目：常見消息隊(duì)列介紹以及比較總結(jié)-創(chuàng)新互聯(lián)
網(wǎng)頁(yè)URL：http://www.rwnh.cn/article24/pddce.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供做網(wǎng)站、網(wǎng)站維護(hù)、響應(yīng)式網(wǎng)站、自適應(yīng)網(wǎng)站、用戶體驗(yàn)、軟件開發(fā)

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請(qǐng)盡快告知，我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng)，如需處理請(qǐng)聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來源： 創(chuàng)新互聯(lián)