跳到主要内容

一、RocketMQ源码分析之NameServer

1、RocketMQ组件概述​

 

  • NameServer
    NameServer相当于配置中心，维护Broker集群、Broker信息、Broker存活信息、主题与队列信息等。NameServer彼此之间不通信，每个Broker与集群内所有的Nameserver保持长连接。

2、源码分析NameServer​

本文不对 NameServer 与 Broker、Producer 集群、Consumer 集群的网络通信做详细解读（该系列后续专门进行讲解）

本文重点关注 NameServer 作为 MQ 集群的配置中心存储什么信息。

2.1 源码分析NamesrvController​

NameserController 是 NameServer 模块的核心控制类。

2.1.1 NamesrvConfig​

NamesrvConfig,主要指定 nameserver 的相关配置属性：

  • kvConfigPath(kvConfig.json)。
  • mqhome/namesrv/namesrv.properties。
  • orderMessageEnable，是否开启顺序消息功能，默认为false。

2.1.2 ScheduledExecutorService​

private final ScheduledExecutorService scheduledExecutorService = Executors.

NameServer 定时任务执行线程池，默认定时执行两个任务：

  • 任务1、每隔 10s 扫描 broker ,维护当前存活的Broker信息。
  • 任务2、每隔 10s 打印KVConfig 信息。

2.1.3 KVConfigManager​

读取或变更NameServer的配置属性，加载 NamesrvConfig 中配置的配置文件到内存，此类一个亮点就是使用轻量级的非线程安全容器，再结合读写锁对资源读写进行保护。尽最大程度提高线程的并发度。