Broker启动流程
2022-01-17 09:29:43 1 举报rocket mq Broker 启动流程
作者其他创作
大纲/内容
4.读取输入参数args为命令行参数
17.创建线程池执行定时任务，想所有namesrv注册Broker
3.设置netty的发送和接收buffer大小为128k
1.main()
5.新建BrokerConfig
14.备份配置信息，防止丢失
9.解析命令行参数，获取到配置文件并解析，将结果填充到各config中
15.initialize
16.返回BrokerController
NettySystemConfig
BrokerStartup
Container
BrokerController
NettyServerConfig
8.新建MessageStoreConfig对象，如果当前角色为slave，则设置可访问消息存储在内存的最大百分比为30
ServerUtil
2.createBrokerController
createBrokerController
6.新建NettyServerConfig，作为服务端用于接收生产者发送的消息（监听端口10911）
12.判断enableDLegerCommitLog 是否为true，true时，brokerId设为 -1 （是否启用Dleger，即是否启用主从切换，默认值为false）
7.新建NettyClientConfig，用于发送心跳至namesrv
controller.start()
18.调用brokerOuterAPI() 方法
MessageStoreConfig
NettyClientConfig
13.根据brokerConfig，nettyServerConfig，nettyClientConfig，messageStoreConfig 构建BrokerController
BrokerConfig
BrokerOuterAPI
10.获得配置的namesrv地址串，以；分割获取所有服务的地址
0 条评论
下一页
