在高并發(fā)業(yè)務場景下，典型的阿里雙11秒殺等業(yè)務，消息隊列中間件在流量削峰、解耦上有不可替代的作用。

今天我們一起來探討：

全量的消息隊列究竟有哪些？ Kafka、RocketMQ、RabbitMQ的優(yōu)劣勢比較，以及消息隊列的選型。

最全MQ消息隊列有哪些？

那么目前在業(yè)界有哪些比較知名的消息引擎呢？如下圖所示：

這里面幾乎完全列舉了當下比較知名的消息引擎，包括：

 ZeroMQ

 推特的Distributedlog

 ActiveMQ：Apache旗下的老牌消息引擎

 RabbitMQ、Kafka：AMQP的默認實現(xiàn)。

 RocketMQ

 Artemis：Apache的ActiveMQ下的子項目

 Apollo：同樣為Apache的ActiveMQ的子項目的號稱下一代消息引擎

 商業(yè)化的消息引擎IronMQ

 以及實現(xiàn)了JMS(Java Message Service)標準的OpenMQ。

MQ消息隊列的技術應用

1.解耦

解耦是消息隊列要解決的最本質(zhì)問題。

2.最終一致性

最終一致性指的是兩個系統(tǒng)的狀態(tài)保持一致，要么都成功，要么都失敗。

最終一致性不是消息隊列的必備特性，但確實可以依靠消息隊列來做最終一致性的事情。

3.廣播

消息隊列的基本功能之一是進行廣播。

有了消息隊列，我們只需要關心消息是否送達了隊列，至于誰希望訂閱，是下游的事情，無疑極大地減少了開發(fā)和聯(lián)調(diào)的工作量。

4.錯峰與流控

典型的使用場景就是秒殺業(yè)務用于流量削峰場景。

由于篇幅的關系，本文重點介紹消息隊列比較，詳細應用場景請參考：《什么是流量削峰？如何解決秒殺業(yè)務的削峰場景》。

Kafka、RocketMQ、RabbitMQ比較

1.ActiveMQ

優(yōu)點：

 單機吞吐量：萬級

 topic數(shù)量都吞吐量的影響：

 時效性：ms級

 可用性：高，基于主從架構(gòu)實現(xiàn)高可用性

 消息可靠性：有較低的概率丟失數(shù)據(jù)

 功能支持：MQ領域的功能極其完備

缺點:

官方社區(qū)現(xiàn)在對ActiveMQ 5.x維護越來越少，較少在大規(guī)模吞吐的場景中使用。

2.Kafka

號稱大數(shù)據(jù)的殺手锏，談到大數(shù)據(jù)領域內(nèi)的消息傳輸，則繞不開Kafka，這款為大數(shù)據(jù)而生的消息中間件，以其百萬級TPS的吞吐量名聲大噪，迅速成為大數(shù)據(jù)領域的寵兒，在數(shù)據(jù)采集、傳輸、存儲的過程中發(fā)揮著舉足輕重的作用。

Apache Kafka它最初由LinkedIn公司基于獨特的設計實現(xiàn)為一個分布式的提交日志系統(tǒng)( a distributed commit log)，之后成為Apache項目的一部分。

目前已經(jīng)被LinkedIn，Uber, Twitter, Netflix等大公司所采納。

優(yōu)點：

 性能好，單機寫入TPS約在百萬條/秒，優(yōu)點，就是吞吐量高。

 時效性：ms級

 可用性：非常高，kafka是分布式的，一個數(shù)據(jù)多個副本，少數(shù)機器宕機，不會丟失數(shù)據(jù)，不會導致不可用

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

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

 在日志領域比較成熟，被多家公司和多個開源項目使用；

 功能支持：功能較為簡單，主要支持簡單的MQ功能，在大數(shù)據(jù)領域的實時計算以及日志采集被大規(guī)模使用

缺點：

 Kafka單機超過64個隊列/分區(qū)，Load會發(fā)生明顯的飆高現(xiàn)象，隊列越多，load越高，發(fā)送消息響應時間變長

 使用短輪詢方式，實時性取決于輪詢間隔時間；

 消費失敗不支持重試；

 支持消息順序，但是一臺代理宕機后，就會產(chǎn)生消息亂序；

 社區(qū)更新較慢；

3.RabbitMQ

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

RabbitMQ優(yōu)點：

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

 吞吐量到萬級，MQ功能比較完備  

 健壯、穩(wěn)定、易用、跨平臺、支持多種語言、文檔齊全；

 開源提供的管理界面非常棒，用起來很好用  

 社區(qū)活躍度高；

RabbitMQ缺點：

 erlang開發(fā)，很難去看懂源碼，基本職能依賴于開源社區(qū)的快速維護和修復bug，不利于做二次開發(fā)和維護。

 RabbitMQ確實吞吐量會低一些，這是因為他做的實現(xiàn)機制比較重。  

 需要學習比較復雜的接口和協(xié)議，學習和維護成本較高。

4.RocketMQ

RocketMQ出自 阿里公司的開源產(chǎn)品，用 Java 語言實現(xiàn)，在設計時參考了 Kafka，并做出了自己的一些改進。

RocketMQ在阿里集團被廣泛應用在訂單，交易，充值，流計算，消息推送，日志流式處理，binglog分發(fā)等場景。

RocketMQ優(yōu)點：

 單機吞吐量：十萬級

 可用性：非常高，分布式架構(gòu)

 消息可靠性：經(jīng)過參數(shù)優(yōu)化配置，消息可以做到0丟失

 功能支持：MQ功能較為完善，還是分布式的，擴展性好

 支持10億級別的消息堆積，不會因為堆積導致性能下降

 源碼是java，我們可以自己閱讀源碼，定制自己公司的MQ，可以掌控 

RocketMQ缺點：

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

 社區(qū)活躍度一般

 沒有在 mq 核心中去實現(xiàn)JMS等接口，有些系統(tǒng)要遷移需要修改大量代碼 

消息隊列選擇建議

1.Kafka

Kafka主要特點是基于Pull的模式來處理消息消費，追求高吞吐量，一開始的目的就是用于日志收集和傳輸，適合產(chǎn)生大量數(shù)據(jù)的互聯(lián)網(wǎng)服務的數(shù)據(jù)收集業(yè)務。

大型公司建議可以選用，如果有日志采集功能，肯定是kafka了。

2.RocketMQ

天生為金融互聯(lián)網(wǎng)領域而生，對于可靠性要求很高的場景，尤其是電商里面的訂單扣款，以及業(yè)務削峰，在大量交易涌入時，后端可能無法及時處理的情況。

RoketMQ在穩(wěn)定性上可能更值得信賴，這些業(yè)務場景在阿里雙11已經(jīng)經(jīng)歷了多次考驗，如果你的業(yè)務有上述并發(fā)場景，建議可以選擇RocketMQ。

3.RabbitMQ

RabbitMQ :結(jié)合erlang語言本身的并發(fā)優(yōu)勢，性能較好，社區(qū)活躍度也比較高，但是不利于做二次開發(fā)和維護。不過，RabbitMQ的社區(qū)十分活躍，可以解決開發(fā)過程中遇到的bug。

如果你的數(shù)據(jù)量沒有那么大，小公司優(yōu)先選擇功能比較完備的RabbitMQ。