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

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

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

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

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

三、心跳機(jī)制

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

1.接收心跳

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

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

2.處理心跳

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

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

處理邏輯可以參考源碼：org.apache.rocketmq.namesrv.processor.DefaultRequestProcessor#processRequest#brokerHeartbeat:8wL28資訊網(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.心跳超時(shí)

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

8wL28資訊網(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()，核心流程：8wL28資訊網(wǎng)——每日最新資訊28at.com

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

四、其他核心源碼解讀

NameServer啟動(dòng)

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

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

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

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

五、總結(jié)

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

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

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

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

下一篇： 建議直接收藏的三個(gè) Go 庫(kù)