欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

kafka?消息隊(duì)列中點(diǎn)對點(diǎn)與發(fā)布訂閱的區(qū)別說明

 更新時(shí)間:2022年05月05日 11:33:14   作者:幽靈之使  
這篇文章主要介紹了kafka?消息隊(duì)列中點(diǎn)對點(diǎn)與發(fā)布訂閱的區(qū)別說明,具有很好的參考價(jià)值,希望對大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教

背景知識

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)文章

  • Java8中List轉(zhuǎn)Map的多種方式代碼

    Java8中List轉(zhuǎn)Map的多種方式代碼

    這篇文章主要給大家介紹了關(guān)于Java8中List轉(zhuǎn)Map的多種方式,在實(shí)際項(xiàng)目中我們經(jīng)常會用到List轉(zhuǎn)Map操作,本文介紹了多種方法的實(shí)現(xiàn)代碼,需要的朋友可以參考下
    2023-08-08
  • Java兩種方式實(shí)現(xiàn)動態(tài)代理

    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-10
  • Mybatis中mapper.xml實(shí)現(xiàn)熱加載介紹

    Mybatis中mapper.xml實(shí)現(xiàn)熱加載介紹

    大家好,本篇文章主要講的是Mybatis中mapper.xml實(shí)現(xiàn)熱加載介紹,感興趣的同學(xué)趕快來看一看吧,對你有幫助的話記得收藏一下
    2022-01-01
  • Java實(shí)現(xiàn)上傳文件圖片到指定服務(wù)器目錄

    Java實(shí)現(xiàn)上傳文件圖片到指定服務(wù)器目錄

    本文通過實(shí)例代碼給大家介紹了java上傳文件圖片到指定服務(wù)器目錄的相關(guān)知識,代碼簡單易懂,非常不錯(cuò),具有一定的參考借鑒價(jià)值,需要的朋友可以參考下
    2018-06-06
  • JAVA中的延遲隊(duì)列DelayQueue應(yīng)用解析

    JAVA中的延遲隊(duì)列DelayQueue應(yīng)用解析

    這篇文章主要介紹了JAVA中的延遲隊(duì)列DelayQueue應(yīng)用解析,DelayQueue是一個(gè)根據(jù)元素的到期時(shí)間來排序的隊(duì)列,而并非是一般的隊(duì)列那樣先進(jìn)先出,最快過期的元素排在隊(duì)首,越晚到期的元素排得越后,需要的朋友可以參考下
    2023-12-12
  • Java excel數(shù)據(jù)導(dǎo)入mysql的實(shí)現(xiàn)示例詳解

    Java excel數(shù)據(jù)導(dǎo)入mysql的實(shí)現(xiàn)示例詳解

    今天教大家如何使用Java將excel數(shù)據(jù)導(dǎo)入MySQL,文中有非常詳細(xì)的代碼示例,對正在學(xué)習(xí)java的小伙伴呢很有幫助,需要的朋友可以參考下
    2022-08-08
  • Java中l(wèi)ist.foreach不能使用字符串拼接的問題

    Java中l(wèi)ist.foreach不能使用字符串拼接的問題

    這篇文章主要介紹了Java中l(wèi)ist.foreach不能使用字符串拼接的問題,具有很好的參考價(jià)值,希望對大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教
    2021-09-09
  • MyBatis-Plus實(shí)現(xiàn)分頁的方法使用詳解

    MyBatis-Plus實(shí)現(xiàn)分頁的方法使用詳解

    這篇文章主要為大家介紹了MyBatis-Plus的分頁的方法使用,包括:不傳參數(shù)時(shí)的默認(rèn)結(jié)果、查詢不存在的數(shù)據(jù)、手動包裝page和自定義SQL,需要的可以參考一下
    2022-03-03
  • java 請求跨域問題解決方法實(shí)例詳解

    java 請求跨域問題解決方法實(shí)例詳解

    這篇文章主要介紹了java 請求跨域問題解決方法實(shí)例詳解的相關(guān)資料,需要的朋友可以參考下
    2017-04-04
  • SpringBoot常見錯(cuò)誤圖文總結(jié)

    SpringBoot常見錯(cuò)誤圖文總結(jié)

    最近在使用idea+Springboot開發(fā)項(xiàng)目中遇到一些問題,這篇文章主要給大家介紹了關(guān)于SpringBoot常見錯(cuò)誤總結(jié)的相關(guān)資料,文中通過實(shí)例代碼介紹的非常詳細(xì),需要的朋友可以參考下
    2023-06-06

最新評論