今天我們來一起深入分析 RocketMQ的注冊中心 NameServer。iIZ28資訊網(wǎng)——每日最新資訊28at.com

本文基于 RocketMQ release-5.2.0。iIZ28資訊網(wǎng)——每日最新資訊28at.com

首先，我們回顧下 RocketMQ的內(nèi)核原理鳥瞰圖：iIZ28資訊網(wǎng)——每日最新資訊28at.com

iIZ28資訊網(wǎng)——每日最新資訊28at.com

iIZ28資訊網(wǎng)——每日最新資訊28at.com

三、心跳機制

心跳機制是 NameServer維護 Broker的路由信息最重要的一個抓手，主要分為接收心跳、處理心跳、心跳超時 3部分：iIZ28資訊網(wǎng)——每日最新資訊28at.com

1.接收心跳

Broker每 30s會向所有的 NameServer發(fā)送心跳包，告訴它們自己還存活著，從而更新自己在 NameServer的狀態(tài)，整體交互如下圖：iIZ28資訊網(wǎng)——每日最新資訊28at.com

iIZ28資訊網(wǎng)——每日最新資訊28at.com

2.處理心跳

NameServer收到心跳包時會更新 brokerLiveTable緩存中 BrokerLiveInfo的 lastUpdateTimeStamp信息，整體交互如下圖：iIZ28資訊網(wǎng)——每日最新資訊28at.com

iIZ28資訊網(wǎng)——每日最新資訊28at.com

處理邏輯可以參考源碼：org.apache.rocketmq.namesrv.processor.DefaultRequestProcessor#processRequest#brokerHeartbeat:iIZ28資訊網(wǎng)——每日最新資訊28at.com

public RemotingCommand brokerHeartbeat(ChannelHandlerContext ctx,    RemotingCommand request) throws RemotingCommandException {    final RemotingCommand response = RemotingCommand.createResponseCommand(null);    final BrokerHeartbeatRequestHeader requestHeader =        (BrokerHeartbeatRequestHeader) request.decodeCommandCustomHeader(BrokerHeartbeatRequestHeader.class);    this.namesrvController.getRouteInfoManager().updateBrokerInfoUpdateTimestamp(requestHeader.getClusterName(), requestHeader.getBrokerAddr());    response.setCode(ResponseCode.SUCCESS);    response.setRemark(null);    return response;}

3.心跳超時

NameServer每隔 10s(每隔5s + 5s延遲)掃描 brokerLiveTable檢查 Broker的狀態(tài)，如果在 120s內(nèi)未收到 Broker心跳，則認為 Broker異常，會從路由表將該 Broker摘除并關(guān)閉 Socket連接，同時還會更新路由表的其他信息，整體交互如下圖：iIZ28資訊網(wǎng)——每日最新資訊28at.com

iIZ28資訊網(wǎng)——每日最新資訊28at.com

private void startScheduleService() {this.scanExecutorService.scheduleAtFixedRate(NamesrvController.this.routeInfoManager::scanNotActiveBroker,        5, this.namesrvConfig.getScanNotActiveBrokerInterval(), TimeUnit.MILLISECONDS);}

源碼參考：org.apache.rocketmq.namesrv.routeinfo.RouteInfoManager#unRegisterBroker()，核心流程：iIZ28資訊網(wǎng)——每日最新資訊28at.com

• 遍歷brokerAddrTable
• 遍歷broker地址
• 根據(jù) broker地址移除 brokerAddr
• 如果當前 Topic只包含待移除的 Broker,則移除該 Topic

四、其他核心源碼解讀

NameServer啟動

NameServer的啟動類為：org.apache.rocketmq.namesrv.NamesrvStartup，整個流程如下圖：iIZ28資訊網(wǎng)——每日最新資訊28at.com

iIZ28資訊網(wǎng)——每日最新資訊28at.com

NameServer啟動最核心的 3個事情是：iIZ28資訊網(wǎng)——每日最新資訊28at.com

• 加載配置：NameServerConfig、NettyServerConfig主要是映射配置文件，并創(chuàng)建 NamesrvController。
• 啟動 Netty通信服務(wù)：NettyRemotingServer是 NameServer和Broker，Producer，Consumer通信的底層通道 Netty服務(wù)器。
• 啟動定時器和鉤子程序：NameServerController實例一方面處理 Netty接收到消息后，一方面內(nèi)部有多個定時器和鉤子程序，它是 NameServer的核心控制器。

五、總結(jié)

NameServer并沒有采用復(fù)雜的分布式協(xié)議來保持數(shù)據(jù)的一致性，而是采用 CAP理論中的 AP，各個節(jié)點之間是Peer to Peer的對等關(guān)系，數(shù)據(jù)的一致性通過心跳機制，定時器，延時感知來完成。iIZ28資訊網(wǎng)——每日最新資訊28at.com

本文鏈接：http://www.tebozhan.com/showinfo-26-93682-0.html代碼很少，卻很優(yōu)秀！RocketMQ的NameServer是如何做到的？

聲明：本網(wǎng)頁內(nèi)容旨在傳播知識，若有侵權(quán)等問題請及時與本網(wǎng)聯(lián)系，我們將在第一時間刪除處理。郵件：2376512515@qq.com

上一篇： React 實現(xiàn)給密碼輸入框加上【密碼強度】展示？

下一篇： 建議直接收藏的三個 Go 庫