您好,登錄后才能下訂單哦!
簡介
RocketMQ路由注冊與刪除是通過Broker與NameServer的心跳功能實現的。Broker啟動時向集群中所有的NameServer發送心跳語句,每隔30s向集群中所有NameServer發送心跳包,NameServer收到Broker心跳包時會更新brokerLiveTable中的lastUpdateTimestamp,然后NameServer每隔10s掃描brokerLiveTable,如果連續120s沒有收到心跳包,NameServer將移除該Broker的路由信息。
路由信息
路由實現類是org.apache.rocketmq.namesrv.routeinfo.RouteInfoManager
路由注冊
路由注冊過程描述如下:
Broker啟動時會向所有NameServer注冊路由,然后啟動一個定時任務,每隔30s發送心跳包;
BrokerOuterAPI中的registerBrokerAll實際上是通過Netty客戶端將注冊路由的請求發往NameServer的Netty服務端;
NameServer的Netty服務端接受到請求后,交給DefaultRequestProcessor的processRequest處理,最后委托給了RouteInfoManager的registerBroker方法,填充或者更新路由信息。
路由刪除
在NamesrvController的initialize啟動了個定時任務每隔10s掃描brokerLiveTable,如果連續120s沒有收到心跳包,NameServer將移除該Broker的路由信息
以上就是本文的全部內容,希望對大家的學習有所幫助,也希望大家多多支持億速云。
免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。