1. BrokerConfig\NettyServerConfig\NettyClientConfig\MessageStoreConfig\日志配置等,创建BrokerController
2. 初始化BrokerController
1. topicConfigManager.load()
2. consumerOffsetManager.load()
3. subscriptionGroupManager.load()
4. consumerFilterManager.load()
5. 创建DefaultMessageStore,BrokerStats,MessageStorePluginContext对象,messageStore.load()
6. 创建remotingServer,fastRemotingServer对象
7. 创建线程:sendMessageExecutor、pullMessageExecutor、queryMessageExecutor、adminBrokerExecutor、clientManageExecutor、consumerManageExecutor
8. 注册处理器BrokerController.registerProcessor()
1. 创建SendMessageProcessor并向remotingServer、fastRemotingServer注册处理器
2. 向remotingServer注册读取消息处理器pullMessageProcessor
3. 创建NettyRequestProcessor对象并向remotingServer、fastRemotingServer注册处理器(与上述步骤类似)
4. 创建ClientManageProcessor对象并向remotingServer、fastRemotingServer注册处理器(与上述步骤类似)
5. 创建ConsumerManageProcessor对象并向remotingServer、fastRemotingServer注册处理器(与上述步骤类似)
6. 创建EndTransactionProcessor对象并向remotingServer、fastRemotingServer注册处理器(与上述步骤类似)
7. 创建AdminBrokerProcessor对象并向remotingServer、fastRemotingServer注册处理器(与上述步骤有点区别)
9. 创建定时任务:
10. BrokerController.start()
