栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 软件开发 > 后端开发 > Java

RocketMQ源码:Broker启动过程介绍

Java 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

RocketMQ源码:Broker启动过程介绍

1. 简介

Broker 启动入口是 BrokerStartup.java => main() ,跟上一篇讲的 NameSrv 类似,首先会从启动命令判断 -c 参数,读取自定义配置文件。然后创建 BrokerController 对象,负责初始化和启动操作。

Broker 主要配置类有3个:

  • BrokerConfig:Broker相关的配置参数
  • NettyServerConfig:Netty服务端配置,默认端口号10911。NameSrv 也有这个配置,默认端口9876
  • NettyClientConfig:Netty客户端配置
2. BrokerController 初始化

代码位置: BrokerController.java => initialize()

2.1 加载TopicConfig

文件路径:{MessageStoreConfig.storePathRootDir}/config/topics.json
记录每个Topic的信息,例如:topic名称、topic读写权限、queue的可读数量、queue的可写数量等等
加载完毕后,记录在 topicConfigManager.topicConfigTable,类型是 ConcurrentMap

2.2 加载ConsumerOffset

文件路径&

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/424107.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号