輕量級註冊中心:RocketMQ NameServer

NameServer實現比較簡單,主要包括配置管理、路由管理兩塊。其主要功能是為整個MQ集群提供服務協調與治理,具體就是記錄維護Topic、Broker的信息,及監控Broker的運行狀態,為client提供路由能力。NameServer是一個幾乎無狀態節點,可集群部署,節點之間無任何信息同步。

NameServer為生產者和消費者提供Meta數據,以確定消息該發往哪個Broker或者該從哪個Broker拉取消息。有了Meta數據後,生產者和消費者就可以直接和 Broker交互了。這種點對點的交互方式最大限度降低了消息傳遞的中間環節,縮短了鏈路耗時。

1. 啟動

NameServer的啟動過程如下:


輕量級註冊中心:RocketMQ NameServer


  1. 加載本地的備份文件,載入k-v對,有KVConfigManager持有,格式如下 HashMap> configTable = new HashMap>(); 在有值發生變化的時候就會執行一次持久化
  2. 初始化NettyRemotingServer,傳入BrokerHousekeepingService,會在客戶端連接發生變化的時候進行路由管理的變更
  3. 初始化線程池,用於NettyRemotingServer分發請求,詳見上一節關於Netty的介紹
  4. 註冊請求處理器,NameServer的實現為DefaultRequestProcessor,提供了包括PUT_KV_CONFIG、GET_KV_CONFIG等管理功能的CRUD遠程調用入口
  5. 啟動定時器,每5秒掃描超時的broker連接並移除
  6. 啟動定時器,每10分鐘打印一次kv對信息

2. 服務管理

NameServer的對外服務入口由DefaultRequestProcessor提供,主要包括配置管理和路由管理,分別由KVConfigManager和RouteInfoManager實現。

2.1. KVConfigManager

比較簡單,中規中矩的一個類,內部有一個configTable按照命名空間管理配置鍵值對,除了put和get操作外,還有持久化為json以及加載持久化文件的操作。

2.2. RouteInfoManager

RouteInfoManager主要用來管理Broker及Topic對應的路由信息,類關係如下:


輕量級註冊中心:RocketMQ NameServer


包括:

  1. Topic對應的Queue列表
  2. Queue所在的Broker,以及Queue對應的屬性
  3. Broker對應的集群信息、集群中的實例地址信息
  4. 每個Broker實例對應的存活信息,包括最後更新時間、版本號、Netty io連接、HA地址
  5. 集群對應的Broker列表

主要用於管理Broker和Topic的路由信息。

2.2.1. 註冊Broker(registerBroker)

方法定義如下:

<code>public RegisterBrokerResult registerBroker(
        

final

String

clusterName,

final

String

brokerAddr,

final

String

brokerName,

final

long brokerId,

final

String

haServerAddr,

final

TopicConfigSerializeWrapper topicConfigWrapper,

final

List<

String

> filterServerList,

final

Channel channel) /<code>

過程如下:


輕量級註冊中心:RocketMQ NameServer


2.2.2. 根據topic選擇路由信息(pickupTopicRouteData)

方法定義如下:

<code>

public

TopicRouteData

pickupTopicRouteData

(

final

String topic)

/<code>

返回結果為:

<code>

public

class

TopicRouteData

extends

RemotingSerializable

{

private

String orderTopicConf;

private

List

queueDatas;

private

List

brokerDatas;

private

HashMap/<code>

即根據topic名找到該topic下所有Queue在Broker上的分佈信息,過程如下:


輕量級註冊中心:RocketMQ NameServer


2.2.3 去註冊Broker(unregisterBroker)

去掉屬性中持有的關於該Broker對應的所有數據,可以類比上面的過程看源碼。

RouteInfoManager的其他服務也類似,都是從持有的各個屬性中查找到數據有並返回。

相對於ZooKeeper這種支持強一致性的註冊中心來說,NameServer實現上比較輕量,RocketMQ的架構設計決定了它不需要進行Master選舉,用不到其他複雜的功能,只需要一個輕量級的元數據服務器就足夠了。中間件對穩定性要求很高,RocketMQ的NameServer只有很少的代碼,容易維護,所以不需要再依賴另一箇中間件,從而減少整體維護成本。


分享到:


相關文章: