Java RocketMQ 路由注冊(cè)與刪除的實(shí)現(xiàn)
簡(jiǎn)介
RocketMQ路由注冊(cè)與刪除是通過(guò)Broker與NameServer的心跳功能實(shí)現(xiàn)的。Broker啟動(dòng)時(shí)向集群中所有的NameServer發(fā)送心跳語(yǔ)句,每隔30s向集群中所有NameServer發(fā)送心跳包,NameServer收到Broker心跳包時(shí)會(huì)更新brokerLiveTable中的lastUpdateTimestamp,然后NameServer每隔10s掃描brokerLiveTable,如果連續(xù)120s沒(méi)有收到心跳包,NameServer將移除該Broker的路由信息。
路由信息
路由實(shí)現(xiàn)類是org.apache.rocketmq.namesrv.routeinfo.RouteInfoManager
- topicQueueTable:Topic消息隊(duì)列路由信息,消息發(fā)送時(shí)根據(jù)路由表進(jìn)行負(fù)載均衡。
- brokerAddrTable:Broker基礎(chǔ)信息,包含brokerName、所屬集群名稱、主備Broker地址。
- clusterAddrTable:Broker集群信息,存儲(chǔ)集群中所有Broker名稱。
- brokerLiveTable:Broker狀態(tài)信息。NameServer每次收到心跳包會(huì)更新該信息。
- filterServerTable:Broker上的FilterServer列表,用于類模式消息過(guò)濾。
路由注冊(cè)
路由注冊(cè)過(guò)程描述如下:
Broker啟動(dòng)時(shí)會(huì)向所有NameServer注冊(cè)路由,然后啟動(dòng)一個(gè)定時(shí)任務(wù),每隔30s發(fā)送心跳包;
BrokerOuterAPI中的registerBrokerAll實(shí)際上是通過(guò)Netty客戶端將注冊(cè)路由的請(qǐng)求發(fā)往NameServer的Netty服務(wù)端;
NameServer的Netty服務(wù)端接受到請(qǐng)求后,交給DefaultRequestProcessor的processRequest處理,最后委托給了RouteInfoManager的registerBroker方法,填充或者更新路由信息。
路由刪除
在NamesrvController的initialize啟動(dòng)了個(gè)定時(shí)任務(wù)每隔10s掃描brokerLiveTable,如果連續(xù)120s沒(méi)有收到心跳包,NameServer將移除該Broker的路由信息
以上就是本文的全部?jī)?nèi)容,希望對(duì)大家的學(xué)習(xí)有所幫助,也希望大家多多支持腳本之家。
相關(guān)文章
SpringBoot項(xiàng)目后端開(kāi)發(fā)邏輯全面梳理
這篇文章主要介紹了SpringBoot項(xiàng)目后端開(kāi)發(fā)邏輯全面梳理,具有很好的參考價(jià)值,希望對(duì)大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2023-11-11SpringBoot前后端分離解決跨域問(wèn)題的3種解決方案總結(jié)
前后端分離大勢(shì)所趨,跨域問(wèn)題更是老生常談,下面這篇文章主要給大家介紹了SpringBoot前后端分離解決跨域問(wèn)題的3種解決方案,文中通過(guò)實(shí)例代碼介紹的非常詳細(xì),需要的朋友可以參考下2022-05-05詳解Spring Boot整合Mybatis實(shí)現(xiàn) Druid多數(shù)據(jù)源配置
本篇文章主要介紹了詳解Spring Boot整合Mybatis實(shí)現(xiàn) Druid多數(shù)據(jù)源配置,具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下。2017-03-03Sa-Token中的SaSession對(duì)象使用學(xué)習(xí)示例詳解
這篇文章主要為大家介紹了Sa-Token中的SaSession對(duì)象使用學(xué)習(xí)示例詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪2023-07-07java 將數(shù)據(jù)加載到內(nèi)存中的操作
這篇文章主要介紹了java 將數(shù)據(jù)加載到內(nèi)存中的操作,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。一起跟隨小編過(guò)來(lái)看看吧2020-09-09Spring中的動(dòng)態(tài)數(shù)據(jù)源解讀
這篇文章主要介紹了關(guān)于Spring中的動(dòng)態(tài)數(shù)據(jù)源解讀,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2023-06-06