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