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)類(lèi)是org.apache.rocketmq.namesrv.routeinfo.RouteInfoManager
- topicQueueTable：Topic消息隊(duì)列路由信息，消息發(fā)送時(shí)根據(jù)路由表進(jìn)行負(fù)載均衡。
- brokerAddrTable：Broker基礎(chǔ)信息，包含brokerName、所屬集群名稱(chēng)、主備Broker地址。
- clusterAddrTable：Broker集群信息，存儲(chǔ)集群中所有Broker名稱(chēng)。
- brokerLiveTable：Broker狀態(tài)信息。NameServer每次收到心跳包會(huì)更新該信息。
- filterServerTable：Broker上的FilterServer列表，用于類(lèi)模式消息過(guò)濾。
路由注冊(cè)
路由注冊(cè)過(guò)程描述如下：
Broker啟動(dòng)時(shí)會(huì)向所有NameServer注冊(cè)路由，然后啟動(dòng)一個(gè)定時(shí)任務(wù)，每隔30s發(fā)送心跳包；
BrokerOuterAPI中的registerBrokerAll實(shí)際上是通過(guò)Netty客戶(hù)端將注冊(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)文章
Java中什么時(shí)候類(lèi)加載,第一次需要使用類(lèi)信息時(shí)加載。類(lèi)加載的原則：延遲加載，能不加載就不加載。下面這篇文章主要介紹了Java中類(lèi)的加載順序,需要的朋友可以參考借鑒，下面來(lái)一起看看吧。2017-01-01
這篇文章主要介紹了Java中BeanMap的使用方法,BeanMap來(lái)源于spring 框架,可以將一般的類(lèi)轉(zhuǎn)為 Map 結(jié)構(gòu)存儲(chǔ),基于Map的JavaBean視圖,默認(rèn)的鍵集是所有屬性名稱(chēng)的聯(lián)合,需要的朋友可以參考下2024-01-01
使用AbstractRoutingDataSource實(shí)現(xiàn)數(shù)據(jù)源動(dòng)態(tài)切換的實(shí)例
AbstractRoutingDataSource 是 Spring 框架提供的一個(gè)抽象類(lèi),用于實(shí)現(xiàn)動(dòng)態(tài)數(shù)據(jù)源路由,這個(gè)類(lèi)主要用于多數(shù)據(jù)源場(chǎng)景,其中可以根據(jù)不同的條件動(dòng)態(tài)地切換到不同的數(shù)據(jù)源,本文給大家介紹了如何使用AbstractRoutingDataSource實(shí)現(xiàn)數(shù)據(jù)源動(dòng)態(tài)切換,需要的朋友可以參考下2024-03-03
Sleuth+logback 設(shè)置traceid 及自定義信息方式
這篇文章主要介紹了Sleuth+logback 設(shè)置traceid 及自定義信息方式，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教2021-07-07
Springbootadmin與security沖突問(wèn)題及解決
這篇文章主要介紹了Springbootadmin與security沖突問(wèn)題及解決方案,具有很好的參考價(jià)值,希望對(duì)大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2024-08-08
Java實(shí)現(xiàn)讀取TXT和CSV文件內(nèi)容
這篇文章主要為大家詳細(xì)介紹了如何利用Java語(yǔ)言實(shí)現(xiàn)讀取TXT和CSV文件內(nèi)容的功能，文中的示例代碼講解詳細(xì)，感興趣的小伙伴可以了解一下2023-02-02
這篇文章主要介紹了Java多線程編程中的線程同步方法,使用synchronized關(guān)鍵字創(chuàng)建線程同步方法是實(shí)現(xiàn)線程同步的關(guān)鍵,需要的朋友可以參考下2016-05-05
這篇文章主要為大家詳細(xì)介紹了Java中CountDownLatch類(lèi)的用法，本文通過(guò)一些簡(jiǎn)單的示例進(jìn)行了簡(jiǎn)單介紹，感興趣的小伙伴可以跟隨小編一起了解一下2023-05-05
Spring實(shí)現(xiàn)擁有者權(quán)限驗(yàn)證的方法示例
這篇文章主要介紹了Spring實(shí)現(xiàn)擁有者權(quán)限驗(yàn)證的方法示例，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2019-03-03
Springboot+Vue+axios實(shí)現(xiàn)文章收藏功能
這篇文章主要為大家詳細(xì)介紹了Springboot+Vue+axios實(shí)現(xiàn)文章收藏功能，文中示例代碼介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2022-08-08