91超碰碰碰碰久久久久久综合_超碰av人澡人澡人澡人澡人掠_国产黄大片在线观看画质优化_txt小说免费全本

溫馨提示×

溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊×
其他方式登錄
點擊 登錄注冊 即表示同意《億速云用戶服務條款》

Java RocketMQ 路由注冊與刪除的實現

發布時間:2020-08-28 03:56:10 來源:腳本之家 閱讀:227 作者:bugDesigner 欄目:編程語言

簡介

RocketMQ路由注冊與刪除是通過Broker與NameServer的心跳功能實現的。Broker啟動時向集群中所有的NameServer發送心跳語句,每隔30s向集群中所有NameServer發送心跳包,NameServer收到Broker心跳包時會更新brokerLiveTable中的lastUpdateTimestamp,然后NameServer每隔10s掃描brokerLiveTable,如果連續120s沒有收到心跳包,NameServer將移除該Broker的路由信息。

路由信息

路由實現類是org.apache.rocketmq.namesrv.routeinfo.RouteInfoManager

Java RocketMQ 路由注冊與刪除的實現

  • topicQueueTable:Topic消息隊列路由信息,消息發送時根據路由表進行負載均衡
  • brokerAddrTable:Broker基礎信息,包含brokerName、所屬集群名稱、主備Broker地址。
  • clusterAddrTable:Broker集群信息,存儲集群中所有Broker名稱。
  • brokerLiveTable:Broker狀態信息。NameServer每次收到心跳包會更新該信息。
  • filterServerTable:Broker上的FilterServer列表,用于類模式消息過濾。

路由注冊

Java RocketMQ 路由注冊與刪除的實現

路由注冊過程描述如下:

Broker啟動時會向所有NameServer注冊路由,然后啟動一個定時任務,每隔30s發送心跳包;

Java RocketMQ 路由注冊與刪除的實現

BrokerOuterAPI中的registerBrokerAll實際上是通過Netty客戶端將注冊路由的請求發往NameServer的Netty服務端;

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

路由刪除

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

Java RocketMQ 路由注冊與刪除的實現

Java RocketMQ 路由注冊與刪除的實現

以上就是本文的全部內容,希望對大家的學習有所幫助,也希望大家多多支持億速云。

向AI問一下細節

免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。

AI

肥城市| 嘉祥县| 乡宁县| 阿拉善左旗| 宁陕县| 清新县| 绩溪县| 平遥县| 萨嘎县| 衡南县| 赤峰市| 平远县| 泽州县| 清丰县| 图木舒克市| 浏阳市| 黔南| 万荣县| 谷城县| 青海省| 凌源市| 高唐县| 汉寿县| 宜州市| 汶川县| 河北区| 乌兰察布市| 宁德市| 武平县| 开鲁县| 博乐市| 海南省| 九江县| 西盟| 普格县| 厦门市| 鸡泽县| 琼海市| 木兰县| 遂溪县| 榆中县|