RocketMQ4.7.1之NameServer源码解析

 

核心流程图解如下:

1.从NameServer的启动说起.

可以看到main0才是真正的main方法.

并且createNamesrvController之后直接用start方法了.可见createNamesrvController方法里面才是nameServer真正的核心加载逻辑.

 

 

2.nameServer核心创建逻辑createNamesrvController方法

进入createNamesrvController方法后.最主要的就是下面三行代码,这三行代码主要是用来加载nameServer启动时命令中带的配置文件路径,以及命令行中附带的配置项,

然后将配置文件赋值给NamesrvConfig对象和NettyServerConfig对象.

final NamesrvConfig namesrvConfig = new NamesrvConfig();

final NettyServerConfig nettyServerConfig = new NettyServerConfig();

nettyServerConfig.setListenPort(9876);//设置端口号,

 

 

3.nameServer启动逻辑.接下来进入start方法,

可以看到里面最重要的就是controller.initialize()方法.内部主要是对netty进行配置项配置.

 

4.我们进入controller.initialize()方法,且看netty是如何即那个netty配置并加载netty核心组件的.

 

这里最重要的就是下面第一张图片的逻辑.初始化netty服务器.

 

 

 

5.我们进入初始化netty服务器的new NettyRemotingServer逻辑.这个应该是rocketmq自己写的netty网络组件创建构建方法.

可以看到new ServerBootstrap();ServerBootstrap是netty的核心组件.到这里就知道了该构造方法初始化了netty服务器启动所需要的组件

6.到这里我们就可以回到刚开始的位置了, controller.initialize()方法已经看完.接下来就是controller的启动.

 

下面的启动其实就是利用第4步创建的remtingServer进行启动的.remtingServer是netty服务器封装好的启动对象.

 

然后broker就可以去注册broker信息跟netty进行通信了.然后

总结:至此nameServer的启动就分析完了.