kafka?消息隊(duì)列中點(diǎn)對點(diǎn)與發(fā)布訂閱的區(qū)別說明
背景知識
JMS一個(gè)在 Java標(biāo)準(zhǔn)化組織(JCP)內(nèi)開發(fā)的標(biāo)準(zhǔn)(代號JSR 914)。2001年6月25日,Java消息服務(wù)發(fā)布JMS 1.0.2b,2002年3月18日J(rèn)ava消息服務(wù)發(fā)布 1.1.
Java消息服務(wù)(Java Message Service,JMS)應(yīng)用程序接口是一個(gè)Java平臺中關(guān)于面向消息中間件(MOM)的API,用于在兩個(gè)應(yīng)用程序之間,或分布式系統(tǒng)中發(fā)送消息,進(jìn)行異步通信。
點(diǎn)對點(diǎn)與發(fā)布訂閱最初是由JMS定義的。這兩種模式主要區(qū)別或解決的問題就是發(fā)送到隊(duì)列的消息能否重復(fù)消費(fèi)(多訂閱)
1.JMS中定義
JMS規(guī)范目前支持兩種消息模型:點(diǎn)對點(diǎn)(point to point, queue)和發(fā)布/訂閱(publish/subscribe,topic)。
點(diǎn)對點(diǎn)
- 消息生產(chǎn)者生產(chǎn)消息發(fā)送到queue中,然后消息消費(fèi)者從queue中取出并且消費(fèi)消息。這里要注意:
- 消息被消費(fèi)以后,queue中不再有存儲,所以消息消費(fèi)者不可能消費(fèi)到已經(jīng)被消費(fèi)的消息。
- Queue支持存在多個(gè)消費(fèi)者,但是對一個(gè)消息而言,只會有一個(gè)消費(fèi)者可以消費(fèi)。
發(fā)布/訂閱
- 消息生產(chǎn)者(發(fā)布)將消息發(fā)布到topic中,同時(shí)有多個(gè)消息消費(fèi)者(訂閱)消費(fèi)該消息。
- 和點(diǎn)對點(diǎn)方式不同,發(fā)布到topic的消息會被所有訂閱者消費(fèi)。
2.二者分析與區(qū)別
2.1 點(diǎn)對點(diǎn)模式
生產(chǎn)者發(fā)送一條消息到queue,只有一個(gè)消費(fèi)者能收到。
2.2 發(fā)布訂閱模式
發(fā)布者發(fā)送到topic的消息,只有訂閱了topic的訂閱者才會收到消息。
小結(jié)
- queue實(shí)現(xiàn)了負(fù)載均衡,一個(gè)消息只能被一個(gè)消費(fèi)者接受,當(dāng)沒有消費(fèi)者可用時(shí),這個(gè)消息會被保存直到有 一個(gè)可用的消費(fèi)者,一個(gè)queue可以有很多消費(fèi)者,他們之間實(shí)現(xiàn)了負(fù)載均衡,所以Queue實(shí)現(xiàn)了一個(gè)可靠的負(fù)載均衡。
- topic實(shí)現(xiàn)了發(fā)布和訂閱,當(dāng)你發(fā)布一個(gè)消息,所有訂閱這個(gè)topic的服務(wù)都能得到這個(gè)消息,所以從1到N個(gè)訂閱者都能得到一個(gè)消息的拷貝,只有在消息代理收到消息時(shí)有一個(gè)有效訂閱時(shí)的訂閱者才能得到這個(gè)消息的拷貝。
疑問
- 發(fā)布訂閱模式下,能否實(shí)現(xiàn)訂閱者負(fù)載均衡消費(fèi)呢?當(dāng)發(fā)布者消息量很大時(shí),顯然單個(gè)訂閱者的處理能力是不足的。實(shí)際上現(xiàn)實(shí)場景中是多個(gè)訂閱者節(jié)點(diǎn)組成一個(gè)訂閱組負(fù)載均衡消費(fèi)topic消息,即分組訂閱(如下圖所示),這樣訂閱者很容易實(shí)現(xiàn)消費(fèi)能力線性擴(kuò)展。
3.流行的消息隊(duì)列模型比較
傳統(tǒng)企業(yè)型消息隊(duì)列ActiveMQ遵循了JMS規(guī)范,實(shí)現(xiàn)了點(diǎn)對點(diǎn)和發(fā)布訂閱模型,但其他流行的消息隊(duì)列RabbitMQ、Kafka并沒有遵循老態(tài)龍鐘的JMS規(guī)范,是通過什么方式實(shí)現(xiàn)消費(fèi)負(fù)載均衡、多訂閱呢?
3.1 RabbitMQ
RabbitMQ實(shí)現(xiàn)了AQMP協(xié)議,AQMP協(xié)議定義了消息路由規(guī)則和方式。生產(chǎn)端通過路由規(guī)則發(fā)送消息到不同queue,消費(fèi)端根據(jù)queue名稱消費(fèi)消息。此外RabbitMQ是向消費(fèi)端推送消息,訂閱關(guān)系和消費(fèi)狀態(tài)保存在服務(wù)端。
生產(chǎn)端發(fā)送一條消息通過路由投遞到Queue,只有一個(gè)消費(fèi)者能消費(fèi)到。
當(dāng)RabbitMQ需要支持多訂閱時(shí),發(fā)布者發(fā)送的消息通過路由同時(shí)寫到多個(gè)Queue,不同訂閱組消費(fèi)此消息。
RabbitMQ既支持內(nèi)存隊(duì)列也支持持久化隊(duì)列,消費(fèi)端為推(push)模型,消費(fèi)狀態(tài)和訂閱關(guān)系由服務(wù)端負(fù)責(zé)維護(hù),消息消費(fèi)完后立即刪除,不保留歷史消息。所以支持多訂閱時(shí),消息會多個(gè)拷貝。
3.2 Kafka
Kafka只支持消息持久化,消費(fèi)端為拉(pull)模型,消費(fèi)狀態(tài)和訂閱關(guān)系由客戶端端負(fù)責(zé)維護(hù),消息消費(fèi)完后不會立即刪除,會保留歷史消息。因此支持多訂閱時(shí),消息只會存儲一份就可以了。
以上為個(gè)人經(jīng)驗(yàn),希望能給大家一個(gè)參考,也希望大家多多支持腳本之家。
相關(guān)文章
Java兩種方式實(shí)現(xiàn)動態(tài)代理
Java 在 java.lang.reflect 包中有自己的代理支持,該類(Proxy.java)用于動態(tài)生成代理類,只需傳入目標(biāo)接口、目標(biāo)接口的類加載器以及 InvocationHandler 便可為目標(biāo)接口生成代理類及代理對象。我們稱這個(gè)Java技術(shù)為:動態(tài)代理2020-10-10Mybatis中mapper.xml實(shí)現(xiàn)熱加載介紹
大家好,本篇文章主要講的是Mybatis中mapper.xml實(shí)現(xiàn)熱加載介紹,感興趣的同學(xué)趕快來看一看吧,對你有幫助的話記得收藏一下2022-01-01Java實(shí)現(xiàn)上傳文件圖片到指定服務(wù)器目錄
本文通過實(shí)例代碼給大家介紹了java上傳文件圖片到指定服務(wù)器目錄的相關(guān)知識,代碼簡單易懂,非常不錯(cuò),具有一定的參考借鑒價(jià)值,需要的朋友可以參考下2018-06-06JAVA中的延遲隊(duì)列DelayQueue應(yīng)用解析
這篇文章主要介紹了JAVA中的延遲隊(duì)列DelayQueue應(yīng)用解析,DelayQueue是一個(gè)根據(jù)元素的到期時(shí)間來排序的隊(duì)列,而并非是一般的隊(duì)列那樣先進(jìn)先出,最快過期的元素排在隊(duì)首,越晚到期的元素排得越后,需要的朋友可以參考下2023-12-12Java excel數(shù)據(jù)導(dǎo)入mysql的實(shí)現(xiàn)示例詳解
今天教大家如何使用Java將excel數(shù)據(jù)導(dǎo)入MySQL,文中有非常詳細(xì)的代碼示例,對正在學(xué)習(xí)java的小伙伴呢很有幫助,需要的朋友可以參考下2022-08-08Java中l(wèi)ist.foreach不能使用字符串拼接的問題
這篇文章主要介紹了Java中l(wèi)ist.foreach不能使用字符串拼接的問題,具有很好的參考價(jià)值,希望對大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2021-09-09MyBatis-Plus實(shí)現(xiàn)分頁的方法使用詳解
這篇文章主要為大家介紹了MyBatis-Plus的分頁的方法使用,包括:不傳參數(shù)時(shí)的默認(rèn)結(jié)果、查詢不存在的數(shù)據(jù)、手動包裝page和自定義SQL,需要的可以參考一下2022-03-03