更新時間:2021-08-09 16:20:43 來源:動力節(jié)點 瀏覽1019次
即Message Queue,我們從數(shù)據(jù)結構來理解的話,Queue是一種先進先出的數(shù)據(jù)結構。所以意思就是將信息(通常指傳輸?shù)臄?shù)據(jù))放入一個隊列中。
消息隊列的兩種模式:
可以看到,點對點模式下有可以有多個消費者,但是對于同一個消息,只會有一個消費者能訪問。通常可以用于異步推送消息,保存日志等。
發(fā)布訂閱模式下,對于同一個主題(topic),任何訂閱了topic的消費者都能拉取此消息。通常可以用于構建消息系統(tǒng)。
由Apache軟件基金會所開源,基于java語言開發(fā)。算是一個很老的MQ框架了,同時也是一個非常成熟的框架了,早期在很多互聯(lián)網(wǎng)公司得到廣泛的應用。
文檔齊全,支持多種語言,支持多種的高級特性,如消息組、通配符、組合隊列等。同時對Spring有很好的支持,可以輕易的通過配置文件集成到系統(tǒng)中。
基于Erlang語言編寫的一套開源(MPL)的消息隊列服務軟件,Erlang語言以高性能、健壯、可伸縮出名,所以RabbitMQ性能很強,吞吐量也很高,支持多種協(xié)議,集群化,消息的可靠執(zhí)行特性等優(yōu)勢,很適合企業(yè)的開發(fā)。
吞吐量較低。
由于RabbitMQ支持的協(xié)議多,所以如果要好好學習的話,成本較高。
由linkedin開源的,基于scala語言實現(xiàn)的一個高性能分布式Publish/Subscribe消息隊列系統(tǒng)。
其實Kafka的由來也挺有意思的。話說linkedin起初是使用ActiveMQ來進行數(shù)據(jù)系統(tǒng)中數(shù)據(jù)交換的,上面都說了ActiveMQ性能不咋滴,所以linkedin決定研發(fā)自己的消息傳遞系統(tǒng),也就是Kafka。
Kafka跟其余的消息中間件比較,那是出名的第一快,以并發(fā)量大,社區(qū)活躍備受廣大組織的喜愛。
Kafka提供了超高的吞吐量,ms級別的延遲,極高的可用性以及可靠性,而且分布式可以任意擴展,還支持大數(shù)據(jù)框架Hadoop數(shù)據(jù)并行加載。
單機隊列不能太高,超過64會導致性能下降。
消息重復消費。對數(shù)據(jù)準確性會產(chǎn)生影響。
缺乏一套完整的管理和監(jiān)控工具。
消費失敗不支持重試。
由阿里開源,基于Java實現(xiàn)的一套分布式消息中間件,已經(jīng)捐獻給Apache基金會。
起初阿里也使用ActiveMQ做消息系統(tǒng),可能也是由于性能、可用性問題,然后才自研RocketMQ。
RocketMQ思路起源于Kafka,單機吞吐量高,消息的高可靠性,如果做好了參數(shù)配置,基本不會存在消息丟失的可能,擴展性強,支持事務等。再怎么說,RocketMQ好歹經(jīng)歷過淘寶雙11的壓力,在阿里內(nèi)部項目中廣泛應用。
支持的語言極少,就java和c++。
社區(qū)活躍明顯比不上kafka和RabbitMQ。
功能不夠完整,沒去實現(xiàn)JMS接口,系統(tǒng)遷移需要修改大量的代碼,增加了維護成本。
以上就是動力節(jié)點小編介紹的"為什么選擇MQ消息隊列框架",希望對大家有幫助,想了解更多可查看Java教程。動力節(jié)點在線學習教程,針對沒有任何Java基礎的讀者學習,讓你從入門到精通,主要介紹了一些Java基礎的核心知識,讓同學們更好更方便的學習和了解Java編程,感興趣的同學可以關注一下。