1. 簡(jiǎn)介

Broker 啟動(dòng)入口是 BrokerStartup.java => main() ，跟上一篇講的 NameSrv 類似，首先會(huì)從啟動(dòng)命令判斷 -c 參數(shù)，讀取自定義配置文件。然后創(chuàng)建 BrokerController 對(duì)象，負(fù)責(zé)初始化和啟動(dòng)操作。

Broker 主要配置類有3個(gè)：

• BrokerConfig：Broker相關(guān)的配置參數(shù)
• NettyServerConfig：Netty服務(wù)端配置，默認(rèn)端口號(hào)10911。NameSrv 也有這個(gè)配置，默認(rèn)端口9876
• NettyClientConfig：Netty客戶端配置

2. BrokerController 初始化

代碼位置： BrokerController.java => initialize()

2.1 加載TopicConfig

文件路徑：{MessageStoreConfig.storePathRootDir}/config/topics.json
記錄每個(gè)Topic的信息，例如：topic名稱、topic讀寫權(quán)限、queue的可讀數(shù)量、queue的可寫數(shù)量等等
加載完畢后，記錄在 topicConfigManager.topicConfigTable，類型是 ConcurrentMap<String, TopicConfig>

2.2 加載ConsumerOffset

文件路徑&

與50位技術(shù)專家面對(duì)面20年技術(shù)見證，附贈(zèng)技術(shù)全景圖

總結(jié)

以上是生活随笔為你收集整理的RocketMQ源码：Broker启动过程介绍的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。