【RocketMQ|源码分析】namesrv启动停止过程都做了什么
简介
namesrv在是RocketMQ中一个十分重要的组件,它相当于是Kafka中的zookeeper,Spring Cloud Alibaba中的nacos。它的主要作用是为消息生产者和消息消费者提供关于topic的路由信息。namesrv具有存储路由信息,并且能够管理broker节点(路由注册,路由删除等功能)。
namesrv源码分析
namesrv环境准备
namesrv的启动入口函数在org.apache.rocketmq.namesrv.NamesrvStartup#main
直接通过idea启动会提示需要在环境变量中配置ROCKETMQ_HOME
。
在idea的环境变量配置后,再次启动NamesrvStartup
启动成功后,idea控制台会输出成功提示
namesrv启动过程
namesrv启动过程可以分为如下三个阶段
- 解析命令行并创建配置
- 创建NamesrvController并启动
- 创建ControllerManager并启动
NamesrvStartup#main
入口方法中调用了main0和controllerManagerMain
public static void main(String[] args) {main0(args);controllerManagerMain();
}
在main0方法的解析了命令行中的参数,并创建了NamesrvController类
public static NamesrvController main0(String[] args) {try {// 1. 使用Apache Commons CLI解析启动命令行中的配置parseCommandlineAndConfigFile(args);// 2. 创建一个NamesrvController类NamesrvController controller = createAndStartNamesrvController();return controller;} catch (Throwable e) {e.printStackTrace();System.exit(-1);}return null;
}
parseCommandlineAndConfigFile
解析命令行中的参数,生成CommandLine对象,如果命令行中包含-c
选项,则会读取参数中的配置文件路径,并设置NamesrvConfig、NettyServerConfig、NettyClientConfig三个参数。
如果命令行中包含-p
选项,则会打印所有可配置项,并直接退出,启动效果如下图所示。
public static void parseCommandlineAndConfigFile(String[] args) throws Exception {System.setProperty(RemotingCommand.REMOTING_VERSION_KEY, Integer.toString(MQVersion.CURRENT_VERSION));Options options = ServerUtil.buildCommandlineOptions(new Options());CommandLine commandLine = ServerUtil.parseCmdLine("mqnamesrv", args, buildCommandlineOptions(options), new DefaultParser());if (null == commandLine) {System.exit(-1);return;}// 创建配置namesrvConfig = new NamesrvConfig();nettyServerConfig = new NettyServerConfig();nettyClientConfig = new NettyClientConfig();// 默认端口9876nettyServerConfig.setListenPort(9876);// 解析配置文件if (commandLine.hasOption('c')) {// 省略部分代码}MixAll.properties2Object(ServerUtil.commandLine2Properties(commandLine), namesrvConfig);if (commandLine.hasOption('p')) {// 打印所有配置项}// 必须要有ROCKETMQ_HOME环境变量if (null == namesrvConfig.getRocketmqHome()) {System.out.printf("Please set the %s variable in your environment to match the location of the RocketMQ installation%n", MixAll.ROCKETMQ_HOME_ENV);System.exit(-2);}MixAll.printObjectProperties(log, namesrvConfig);MixAll.printObjectProperties(log, nettyServerConfig);}
参数解析并配置完成之后就是创建并启动NamesrvController,可以从下面源码中日志看到,NamesrvController启动之后,namesrv就算启动了,由此可见NamesrvController在namesrv扮演者举足轻重的地位。
public static NamesrvController createAndStartNamesrvController() throws Exception {// 创建NamesrvControllerNamesrvController controller = createNamesrvController();// 启动NamesrvControllerstart(controller);// netty服务器端配置NettyServerConfig serverConfig = controller.getNettyServerConfig();String tip = String.format("The Name Server boot success. serializeType=%s, address %s:%d", RemotingCommand.getSerializeTypeConfigInThisServer(), serverConfig.getBindAddress(), serverConfig.getListenPort());log.info(tip);System.out.printf("%s%n", tip);return controller;
}
创建NamesrvController的方法也十分简单,将刚才配置解析创建好的三个配置namesrvConfig, nettyServerConfig, nettyClientConfig作为构造参数创建NamesrvController
public static NamesrvController createNamesrvController() {final NamesrvController controller = new NamesrvController(namesrvConfig, nettyServerConfig, nettyClientConfig);// remember all configs to prevent discardcontroller.getConfiguration().registerConfig(properties);return controller;
}
NamesrvController创建完成之后,就开始启动NamesrvController,NamesrvController启动方法位于NamesrvStartup#start
,整个启动的过程分为两步,先初始化NamesrvController(controller.initialize
),然后再启动NamesrvController(controller.start
)。
下面源码中在NamesrvController初始化和启动之间还添加了一个JVM关闭的钩子函数,在JVM退出之前会先调用NamesrvController.shutdown方法关闭NamesrvController,及时释放资源。
public static NamesrvController start(final NamesrvController controller) throws Exception {// 省略部分代码// 初始化失败,则关闭shutdown namesrvboolean initResult = controller.initialize();// 初始化失败,则退出if (!initResult) {controller.shutdown();System.exit(-3);}// 添加jvm关闭钩子方法Runtime.getRuntime().addShutdownHook(new ShutdownHookThread(log, (Callable<Void>) () -> {controller.shutdown();return null;}));// 启动controllercontroller.start();return controller;
}
NamesrvController初始化源码如下,它创建了通信用的组件,初始化发送请求和接受请求的线程池及队列等,具体细节在这里就不展开了
public boolean initialize() {// 加载kv configloadConfig();// 初始化NettyRemotingServer,NettyRemotingClientinitiateNetworkComponents();// 初始化服务端请求处理线程池和客户端请求线程池initiateThreadExecutors();// 注册请求处理器registerProcessor();// 启动定时任务线程池startScheduleService();// 初始化sslinitiateSslContext();// 初始化初始化一个ZoneRouteRPCHook,处理根据topicname获取路由信息请求initiateRpcHooks();return true;
}
NamesrvController启动的过程启动了如下三个非常关键的组件
- RemotingServer
- RemotingClient
- RouteInfoManager
public void start() throws Exception {// remotingServer启动this.remotingServer.start();// 省略部分代码this.remotingClient.updateNameServerAddressList(Collections.singletonList(NetworkUtil.getLocalAddress()+ ":" + nettyServerConfig.getListenPort()));// remotingClient启动this.remotingClient.start();// 文件监视服务if (this.fileWatchService != null) {this.fileWatchService.start();}// 路由信息管理启动this.routeInfoManager.start();
}
至此,namesrv就算启动完成了。如果配置了enableControllerInNamesrv
还会创建并启动ControllerManager。
ControllerManager是支持RocketMQ集群自动主从切换的组件,这里就不详细阐述了
public static ControllerManager controllerManagerMain() {try {if (namesrvConfig.isEnableControllerInNamesrv()) {return createAndStartControllerManager();}} catch (Throwable e) {e.printStackTrace();System.exit(-1);}return null;
}
将上述启动过程整理成思维导图如下
[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-Hp97gT7L-1680013942145)(https://lin-note-img.oss-cn-shenzhen.aliyuncs.com/img/namesrv%E5%90%AF%E5%8A%A8%E8%BF%87%E7%A8%8B-%E6%80%9D%E7%BB%B4%E5%AF%BC%E5%9B%BE.png)]
namesrv关闭
namesrv的关闭其实就是NamesrvController的关闭,关闭方法在org.apache.rocketmq.namesrv.NamesrvController#shutdown
,方法中处理的是网络客户端的关闭、线程池关闭以及路由信息Manager关闭。
public void shutdown() {// 网络通信客户端关闭this.remotingClient.shutdown();// 网络通信服务端关闭this.remotingServer.shutdown();// 默认线程池关闭this.defaultExecutor.shutdown();// 客户端请求线程池关闭this.clientRequestExecutor.shutdown();// 定时调度线程池关闭this.scheduledExecutorService.shutdown();// 不健康broker扫描线程池this.scanExecutorService.shutdown();// 路由信息Manager关闭this.routeInfoManager.shutdown();// fileWatchService关闭if (this.fileWatchService != null) {this.fileWatchService.shutdown();}
}
总结
namesrv的启动和停止其实就是NamesrvController的启动和停止,NamesrvController启动时需要读取配置信息,创建配置类,再根据配置类创建和初始化NamesrvController。NamesrvController处理的是资源的回收。
【RocketMQ|源码分析】namesrv启动停止过程都做了什么相关推荐
- RocketMQ源码:NameSrv启动全过程详解
文章目录 1. 概述 2. NamesrvController 简介 3. NamesrvController 创建过程 4. NamesrvController 初始化 5. NamesrvCont ...
- 《RocketMQ源码分析》NameServer如何处理Broker的连接
<RocketMQ源码分析>NameServer如何处理Broker的连接 NameServer 介绍 NameServer 功能 动态路由发现和注册 服务剔除 创建NameServerC ...
- RocketMQ源码分析之延迟消息
文章目录 前言 一.延迟消息 1.特点 2.使用场景 3.demo 二.发送延迟消息 三.broker端存储延迟消息 四.总结 1.延迟消息工作原理 2.延迟消息在消费者消费重试中的应用 前言 本篇文 ...
- Linux内核源码分析--内核启动之(4)Image内核启动(setup_arch函数)(Linux-3.0 ARMv7)【转】...
原文地址:Linux内核源码分析--内核启动之(4)Image内核启动(setup_arch函数)(Linux-3.0 ARMv7) 作者:tekkamanninja 转自:http://blog.c ...
- 【四】Spring源码分析之启动主流程---AbstractApplicationContext的refresh方法
入口: 在SpringBoot启动的时候,SpringApplication的run方法中 refreshContext(context); 里面最终调用的是AbstractApplicationCo ...
- RocketMQ源码(4)—Broker启动加载消息文件以及恢复数据源码【一万字】
详细介绍了Broker启动加载消息文件以及恢复数据源码. 此前我们学习了Broker的启动源码:RocketMQ源码(3)-Broker启动流程源码解析[一万字],Broker的启动过程中,在Defa ...
- Linux内核源码分析--内核启动之(3)Image内核启动(C语言部分)(Linux-3.0 ARMv7) 【转】...
原文地址:Linux内核源码分析--内核启动之(3)Image内核启动(C语言部分)(Linux-3.0 ARMv7) 作者:tekkamanninja 转自:http://blog.chinauni ...
- Wifi模块—源码分析Wifi启动(Android P)
一.前言 Android P在wifi这块改动挺大的,Wifi到AndoidO之后不再使用jni,所以AndroidP也一样不再使用jni来实现Java代码与本地的C/C++代码交互,而是使用HIDL ...
- Wifi模块—源码分析Wifi启动2(Android P)
一 前言 在上一篇分析了wifi启动的流程,从Android应用层一直分析到了Java框架层,这次我们接着往下走流程.如果没有看上一篇的建议先回头看看 Wifi模块-源码分析Wifi启动1(And ...
最新文章
- NET基础(3):is 和 as 操作符
- php 魔术方法 多继承,day23:单继承多继承菱形继承__init__魔术方法
- python txt文件读写(追加、覆盖)
- 右边菜单_Excel – 如何始终显示下拉菜单右边的小箭头?
- python django mysql写入中文乱码_解决django 向mysql中写入中文字符出错的问题
- md5 java_java中MD5函数
- 天津科技大学计算机科学与信息工程学院,天津科技大学人工智能学院欢迎您!...
- C#学习日志 day 5 plus------ interface 数组及stringBuilder相关
- python黑客攻防入门下载-Python键盘钩取的自我理解(来源于《Python黑客攻防入门》)...
- 演示教学法在计算机基础课程中的应用,演示教学法在《计算机基础》课程中的应用...
- Golang list双向链表源码走读
- Redis学习-性能与优化(五)
- CCLayer中Touch事件(Standard Touch Delegate Targeted Touch Delegate)
- [高中作文赏析]渴望从前
- Azure 网站上的 Java
- 大土狗书屋好书推荐--《史蒂夫·乔布斯传》
- 关于wow游戏插件制作之前的几件事
- Linux tty字符终端下VIM显示混乱的解决方法
- 《请停止无效的社交》第一章七问七答读后感作文2300字
- 创建wincc项目提示无法连接到服务器,wincc 项目管理器 服务器不可用 无法连接到服务器...
热门文章
- Can not deserialize value of type java.util.Date from String异常解决办法
- CMake 入门教程(完整版-更新中)
- ios11对比android8.0,iOS11发正式版:对比安卓8.0你喜欢谁?
- Power App基础
- 日常问题解决:英频杰读卡器(门禁)安装部署
- yii2必须掌握php,Yii2框架中一些折磨人的坑
- 时间序列预测:用电量预测 07 灰色预测算法
- 程序员需要高情商吗??? 不需要被定义的情商。
- 【论文精度】Youtube团队打造深度神经网络与推荐算法结合开山之作Deep Neural Network for YouTube Recommendation
- 一文搞懂CPU如何控制I/O设备