簡(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í)有所幫助，也希望大家多多支持腳本之家。

最新評(píng)論