NameServer介绍
nameServer是RocketMQ自研的一款轻量级高可用注册中心,集群之间不需要维护心跳机制,每台Broker也是独立连接每台NameServer,减少nameServer之间相互交互数据带来的性能开销。同时nameServer也具有持久化机制,在服务故障是可基于持久化文件快速恢复。
核心配置类介绍
nameServer含有两个核心配置类,NamesrvConfig和NettySerConfig。NamesrvConfig主要存放的是namesrv自身的配置,NettySerConfig配置的是远程通讯相关参数。
NamesrvConfig
- rocketmqHome:获取RocketMQ的环境变量的值。
- kvConfigPath:NameServer存放 K-V 的路径。
- configStorePath:NameServer自己的配置存储路径。
- productEnvName:生产环境名称,默认center。
- clusterTest:是否启动了测试集群,默认false。
- orderMessageEnable:是否支持有序消息,默认false。
NettyServerConfig
- listenPort:Netty监听的端口号,外面已经设置成9876了。
- serverWorkerThreads:Netty的工作线程数量,默认8。
- serverCallbackExecutorThreads:Netty的public线程池的线程数量。
- serverSelectorThreads:Netty的IO线程池中线程数,负责解析网络请求,完事交给work线程处理。
- serverOnewaySemaphoreValue:Broker在使用Netty时,会使用。
- serverPooledByteBufAllocatorEnable:ByteBuffer是否开启缓存,默认开启。
- useEpollNativeSelector:是否开启epoll IO模型。
源码分析
从main函数进来主要掉了两个方法,createNamesrvController和start。createNamesrvController是创建nameServer初始化参数,在start中正式启动。
createNamesrvController中解析参数有两种方式,第一种通过Apache工具解析启动参数,通过参数-c 添加配置文件解析,最终将配置文件初始化到NamesrvConfig和NettyServerConfig中。 通过部分参数也可以直接通过JVM启动参数初始化,但是优先级没有通过文件加载优先级高,这里也推荐使用配置文件初始化参数。
接下来我们看start核心方法。 首先调用的是initialize 通过kvConfigManager.load()将批次文件中缓存的KV加载到内存中,然后是调用registerProcessor注册Netty事件处理器,最后是初始化两个线程,分别是剔除没有心跳的Broker和定时打印K-V数据。
registerProcessor时会根据我们配置的clusterTest参数是否开启集群测试模式觉得注册ClusterTestRequestProcessor还是DefaultRequestProcessor,ClusterTestRequestProcessor集成DefaultRequestProcessor并且重写了getRouteInfoByTopic方法。nameServer消息分发入口:
org.apache.rocketmq.namesrv.processor.DefaultRequestProcessor#processRequest
最终消息会被分发到KVConfigManager和RouteInfoManager上。KVConfigManager主要维护注册数据和持久化,RouteInfoManager主要维护Topic和队列等信息。
|