權露
消息隊列(MQ),是一種應用程序對應用程序的通信方法。應用程序通過寫和檢索出入列隊的針對應用程序的數據(消息)來通信,而無需專用連接來鏈接它們。
ActiveMQ
Apache ActiveMQ是最流行的開源、多協議、基于Java的消息代理。它支持行業標準協議,因此用戶可以從多種語言和平臺的客戶端選擇中獲益。從JavaScript、C、C++、Python、.NET等多個客戶端連接。使用無處不在的AMQP協議集成多平臺應用程序。使用STOMP over WebSocket在Web應用程序之間交換消息。使用MQTT管理您的物聯網設備。支持您現有的JMS基礎架構及其他基礎架構。ActiveMQ提供了支持任何消息傳遞用例的能力和靈活性。
優點
單機吞吐量萬級,時效性ms級,可用性高,基于主從架構實現高可用性、消息可靠性較低的概率丟失數據。
缺點
官方社區現在對ActiveMQ 5.x維護越來越少,高吞吐量場景較少使用。
Kafka
Apache Kafka是一個開放源代碼的分布式事件流平臺,被數千家公司用于高性能數據管道、流分析、數據集成和任務關鍵型應用程序。如今,有超過80%的財富100強公司信任并使用Kafka。
優點
性能卓越,單機寫入TPS每秒約在百萬條,最大的優點,就是吞吐量高。時效性毫秒級、可用性非常高,Kafka是分布式的,一個數據多個副本,少數機器宕機不會丟失數據,也不會導致不可用。消費者采用Pull方式獲取的消息,消息有序,通過控制能夠保證所有消息被消費且僅被消費一次。
有優秀的第三方Kafka,Web管理界面Kafka-Manager,在日志領域比較成熟,被多家公司和多個開源項目使用。功能較為簡單,主要支持簡單的MQ功能,在大數據領域的實時計算以及日志采集被大規模使用。
缺點
Kafka單機超過64個隊列/分區,Load會發生明顯的飆高現象,隊列越多Load越高,發送消息響應時間變長,使用短輪詢方式,實時性取決于輪詢間隔時間,消費失敗不支持重試。它支持消息順序,但是一臺代理宕機后,就會產生消息亂序,且社區更新較慢。
RocketMQ
由于ActiveMQ和Kafka不能滿足阿里的需求,他們決定發明一種新的消息傳遞引擎來處理更廣泛的用例集,從傳統的發布/訂閱場景到高容量實時零丟失容錯事務系統。相信這個解決方案是有益的,所以希望向社區開放源代碼,今天,有100多家公司在其業務中使用開源版本的RocketMQ。
優點
單機吞吐量10萬級,可用性非常高,分布式架構,消息可以做到零丟失。MQ功能較為完善,擴展性好,支持10億級別的消息堆積,不會因為堆積導致性能下降,源碼是Java可以自己閱讀源碼,定制自己公司的MQ。
缺點
支持的客戶端語言不多,目前是java及C++,其中C++不成熟,社區活躍度一般,沒有在MQ核心中去實現JMS等接口,有些系統要遷移需要修改大量代碼。
RabbitMQ
RabbitMQ是部署最廣泛的開源消息代理,擁有數萬用戶,是最流行的開源消息代理之一。從T-Mobile到Runtastic,RabbitMQ在世界各地的小型初創公司和大型企業中使用。
RabbitMQ是輕量級的,易于在本地和云中部署,支持多種消息傳遞協議,可以在分布式和聯合配置中部署,以滿足高規模、高可用性需求。
RabbitMQ運行在許多操作系統和云環境上,并為最流行的語言提供了廣泛的開發工具。
優點
由于erlang語言的高并發特性,性能較好,吞吐量達到萬級,MQ功能比較完備,健壯、穩定、易用、跨平臺且支持多種語言,如:Python、Ruby、.NET、Java、JMS、C、PHP、ActionScript、XMPP、STOMP等。支持AJAX文檔齊全,開源提供的管理界面非常棒,很好用,社區活躍度和更新頻率也相當高。
缺點
商業版需要收費,且學習成本較高。
ActiveMQ
ActiveMQ支持任何消息傳遞用例的能力和靈活性,較適合吞吐量比較小的公司使用,也是MQ起步學習的首選。
Kafka
Kafka主要特點是基于Pull的模式來處理消息消費,追求高吞吐量,一開始的目的就是用于日志收集和傳輸,適合產生大量數據的互聯網服務的數據收集業務。大型公司可以選用,它是大數據分析必備,如果有日志采集功能,肯定是首選。
RocketMQ
天生為金融互聯網領域而生,對于可靠性要求很高的場景,尤其是電商里面的訂單扣款,以及業務削峰,在大量交易涌入時,后端可能無法及時處理的情況。RoketMQ在穩定性上更值得信賴,這些業務場景在阿里的“雙11”已經經歷了多次考驗,如果你的業務有上述并發場景,建議可以選擇RocketMQ。
RabbitMQ
結合erlang語言本身的并發優勢,性能好、時效性可達到微秒級,社區活躍度也比較高,管理界面用起來十分方便,如果的數據量沒有那么大,中小型公司優先選擇功能比較完備的RabbitMQ。