当前位置:   article > 正文

rocketmq启动流程_rocketmq 启动

rocketmq 启动

BrokerStartup

使用mqbroker脚本启动broker时,如果启动参数每加–enable_proxy,启动主类是BrokerStartup,启动主要分为3步:

  1. 创建brokerController
  2. 初始化brokerController
  3. 启动brokerController

创建brokerController

根据配置文件和命令行参数,创建4个配置类:BrokerConfig、NettyServerConfig、NettyClientConfig、MessageStoreConfig,配置文件通过-c参数指定,如果没指定,使用默认配置。日志配置文件默认路径是${ROCKETMQ_HOME}/conf/logback_broker.xml。

broker监听端口号默认是10911

创建完4个配置类后,根据配置类创建brokerController,

初始化brokerController

首先TopicConfigManager.load()加载主题配置文件,包含了主题信息,路径是${user.home}/store/config/topics.json,TopicConfigManager的构造器中包含了一些系统默认主题:

  • TBW102:开启自动创建主题时,会有这个主题
  • brokerClusterName:会创建一个名称是brokerClusterName的主题
  • brokerName:
  • SCHEDULE_TOPIC_XXXX:延时消息相关
  • RMQ_SYS_TRACE_TOPIC:开启tra
声明:本文内容由网友自发贡献,不代表【wpsshop博客】立场,版权归原作者所有,本站不承担相应法律责任。如您发现有侵权的内容,请联系我们。转载请注明出处:https://www.wpsshop.cn/w/我家自动化/article/detail/632838
推荐阅读
相关标签
  

闽ICP备14008679号