Java RocketMQ 路由註冊與刪除的實現
阿新 • • 發佈：2020-01-07
簡介
RocketMQ路由註冊與刪除是通過Broker與NameServer的心跳功能實現的。Broker啟動時向叢集中所有的NameServer傳送心跳語句，每隔30s向叢集中所有NameServer傳送心跳包，NameServer收到Broker心跳包時會更新brokerLiveTable中的lastUpdateTimestamp，然後NameServer每隔10s掃描brokerLiveTable,如果連續120s沒有收到心跳包，NameServer將移除該Broker的路由資訊。
路由資訊
路由實現類是org.apache.rocketmq.namesrv.routeinfo.RouteInfoManager
- topicQueueTable：Topic訊息佇列路由資訊，訊息傳送時根據路由表進行負載均衡。
- brokerAddrTable：Broker基礎資訊，包含brokerName、所屬叢集名稱、主備Broker地址。
- clusterAddrTable：Broker叢集資訊，儲存叢集中所有Broker名稱。
- brokerLiveTable：Broker狀態資訊。NameServer每次收到心跳包會更新該資訊。
- filterServerTable：Broker上的FilterServer列表，用於類模式訊息過濾。
路由註冊
路由註冊過程描述如下：
Broker啟動時會向所有NameServer註冊路由，然後啟動一個定時任務，每隔30s傳送心跳包；
BrokerOuterAPI中的registerBrokerAll實際上是通過Netty客戶端將註冊路由的請求發往NameServer的Netty服務端；
NameServer的Netty服務端接受到請求後，交給DefaultRequestProcessor的processRequest處理，最後委託給了RouteInfoManager的registerBroker方法，填充或者更新路由資訊。
路由刪除
在NamesrvController的initialize啟動了個定時任務每隔10s掃描brokerLiveTable，如果連續120s沒有收到心跳包，NameServer將移除該Broker的路由資訊
以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支援我們。