簡(jiǎn)介

成都創(chuàng)新互聯(lián)公司專注于仙桃網(wǎng)站建設(shè)服務(wù)及定制，我們擁有豐富的企業(yè)做網(wǎng)站經(jīng)驗(yàn)。 熱誠(chéng)為您提供仙桃營(yíng)銷型網(wǎng)站建設(shè)，仙桃網(wǎng)站制作、仙桃網(wǎng)頁(yè)設(shè)計(jì)、仙桃網(wǎng)站官網(wǎng)定制、成都微信小程序服務(wù)，打造仙桃網(wǎng)絡(luò)公司原創(chuàng)品牌,更為您提供仙桃網(wǎng)站排名全網(wǎng)營(yíng)銷落地服務(wù)。

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)類是org.apache.rocketmq.namesrv.routeinfo.RouteInfoManager

• topicQueueTable：Topic消息隊(duì)列路由信息，消息發(fā)送時(shí)根據(jù)路由表進(jìn)行負(fù)載均衡。
• brokerAddrTable：Broker基礎(chǔ)信息，包含brokerName、所屬集群名稱、主備Broker地址。
• clusterAddrTable：Broker集群信息，存儲(chǔ)集群中所有Broker名稱。
• brokerLiveTable：Broker狀態(tài)信息。NameServer每次收到心跳包會(huì)更新該信息。
• filterServerTable：Broker上的FilterServer列表，用于類模式消息過(guò)濾。

路由注冊(cè)

路由注冊(cè)過(guò)程描述如下：

Broker啟動(dòng)時(shí)會(huì)向所有NameServer注冊(cè)路由，然后啟動(dòng)一個(gè)定時(shí)任務(wù)，每隔30s發(fā)送心跳包；

BrokerOuterAPI中的registerBrokerAll實(shí)際上是通過(guò)Netty客戶端將注冊(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í)有所幫助，也希望大家多多支持創(chuàng)新互聯(lián)建站。

另外有需要云服務(wù)器可以了解下創(chuàng)新互聯(lián)建站www.cdcxhl.com，海內(nèi)外云服務(wù)器15元起步，三天無(wú)理由+7*72小時(shí)售后在線，公司持有idc許可證，提供“云服務(wù)器、裸金屬服務(wù)器、建站服務(wù)器、香港服務(wù)器、美國(guó)服務(wù)器、虛擬主機(jī)、免備案服務(wù)器”等云主機(jī)租用服務(wù)以及企業(yè)上云的綜合解決方案，具有“安全穩(wěn)定、簡(jiǎn)單易用、服務(wù)可用性高、性價(jià)比高”等特點(diǎn)與優(yōu)勢(shì)，專為企業(yè)上云打造定制，能夠滿足用戶豐富、多元化的應(yīng)用場(chǎng)景需求。

名稱欄目：JavaRocketMQ路由注冊(cè)與刪除的實(shí)現(xiàn)-創(chuàng)新互聯(lián)
文章出自：http://weahome.cn/article/dsccod.html