消息中间件之RocketMQ源码分析(十)

Namesrv启动流程

在这里插入图片描述

第一步:脚本和启动参数配置。

启动命令 nohup ./bin/mqnamesrv -c ./conf/namesrv.conf > dev/null 2>&1 &
通过脚本配置启动基本参数，比如配置文件路径、JVM参数，调用NamesrvStartup.main()方法，解析命令行的参数，将处理好的参数转化为Java实例，传递给NamesrvController实例

第二步:new 一个NamesrvController

在这里插入图片描述

加载命令行传递的配置参数，调用controller.initialize()方法初始化NamesrvController。
Namesrv启动的主要初始化过程也在这个方法中，代码如图
1.加载KV配置。主要是从本地文件中加载KV配置到内存中
2.初始化Netty通信层实例。RocketMQ基于Netty实现了一个RPC服务端，即NettyRemotingServer.通过参数nettyServerConfig,
会启动9876端口监听
3.Namesrv主动检测Broker是否可用，如果不可用就剔除。生产者、消费者也能通过心跳发现被踢出的路由，从而感知Broker下线
4.Namesrv定时打印配置信息到日志中。

第三步:NamesrvController在初始化后添加JVM Hook.Hook中会调用NamesrvController.shutdown()方法来关闭整个Namesrv服务

在这里插入图片描述

第四步:调用NamesrvController.start()方法，启动整个Namesrv。其实start()方法只启动了Namesrv接口处理线程池

Namesrv关闭流程

为什么需要了解停止流程呢?RocketMQ在设计之初已经考虑了很多异常情况，比如Namesrv异常退出、突然断电、内存被打满等等，只有了解了正常的停止流程才能对异常退出导致的问题进行精确的分析和排障。

通常Namesrv的停止是通过关闭命令./mqshutdown namesrv来实现的。这个命令通过调用kill命令将关闭进程通知发给JVM,JVM调用观级Hook执行停止逻辑。具体实现如下
在这里插入图片描述

1.关闭Netty服务端，主要是关闭Netty事件处理器、时间监听器等全部已经初始化的组件
2.关闭Namesrv接口处理线程池
3.关闭全部已经启动的定时任务