欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

Java RocketMQ 路由注冊與刪除的實現(xiàn)

 更新時間：2019年11月01日 10:02:09   作者：bugDesigner  
這篇文章主要介紹了Java RocketMQ 路由注冊與刪除的實現(xiàn)，文中通過示例代碼介紹的非常詳細，對大家的學(xué)習或者工作具有一定的參考學(xué)習價值，需要的朋友們下面隨著小編來一起學(xué)習學(xué)習吧

簡介

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基礎(chǔ)信息，包含brokerName、所屬集群名稱、主備Broker地址。
  • clusterAddrTable：Broker集群信息，存儲集群中所有Broker名稱。
  • brokerLiveTable：Broker狀態(tài)信息。NameServer每次收到心跳包會更新該信息。
  • filterServerTable：Broker上的FilterServer列表，用于類模式消息過濾。

路由注冊

路由注冊過程描述如下：

Broker啟動時會向所有NameServer注冊路由，然后啟動一個定時任務(wù)，每隔30s發(fā)送心跳包；

BrokerOuterAPI中的registerBrokerAll實際上是通過Netty客戶端將注冊路由的請求發(fā)往NameServer的Netty服務(wù)端；

NameServer的Netty服務(wù)端接受到請求后，交給DefaultRequestProcessor的processRequest處理，最后委托給了RouteInfoManager的registerBroker方法，填充或者更新路由信息。

路由刪除

在NamesrvController的initialize啟動了個定時任務(wù)每隔10s掃描brokerLiveTable，如果連續(xù)120s沒有收到心跳包，NameServer將移除該Broker的路由信息

以上就是本文的全部內(nèi)容，希望對大家的學(xué)習有所幫助，也希望大家多多支持腳本之家。

相關(guān)文章

最新評論