RocketMQ 源碼閱讀 Broker

和broker自己本身相關(guān)的組件

  • BrokerController
  • BrokerStatsManager
  • BrokerFastFailure

和remoting相關(guān)的組件

  • NettyServer
  • NettyClient

和消息存儲(chǔ)相關(guān)的組件

  • MessageStore

和consumer 相關(guān)的組件

  • ConsumerOffsetManager
  • ConsumerManager
  • ConsumerFilterManager
  • SubscriptionGroupManager
  • PullMessageProcessor
  • PullRequestHoldService
  • ConsumerIdsChangeListener

和producer 相關(guān)的組件

  • ProducerManager

和 cluster 相關(guān)的組件

  • RebalanceLockManager
  • SlaveSynchronize
  • slaveSyncFuture

和 transaction 有關(guān)的組件

  • TransactionalMessageCheckService
  • TransactionalMessageService
  • AbstractTransactionalMessageCheckListener

broker持有的成員變量

  • storeHost
  • brokerStats
  • brokerFastFailure
  • configuration

和produce/consume 相對(duì)應(yīng)的hook

  • consumeMessageHookList
  • sendMessageHookList

其他不是很明顯的，尚待分類(lèi)的

  • Broker2Client
  • MessageArrivingListener
  • ClientHousekeepingService
  • BrokerOuterAPI
  • FilterServerManager
  • FileWatchService

一些重要方法

  • brokerRegisterAll
  • registerIncrementalBrokerData

一些和broker角色有關(guān)的方法

  • handleSlaveSynchronize
  • changeToSlave
  • changeToMaster
  • startProcessorByHa
  • shutdownProcessorByHa

我們首先得看RocketMQ broker 支持哪幾種命令，給每一類(lèi)命令相應(yīng)的Processor都配了專(zhuān)門(mén)的ExecutorService

  • TransactionalMessageCheckService
  • TransactionalMessageService

Send Message

Pull Message

Reply Message

Query Message

Client Manage Processor

Consumer Manage Processor

End Transaction Processor

Others (Default)

?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成，瀏覽時(shí)請(qǐng)結(jié)合常識(shí)與多方信息審慎甄別。
平臺(tái)聲明：文章內(nèi)容（如有圖片或視頻亦包括在內(nèi)）由作者上傳并發(fā)布，文章內(nèi)容僅代表作者本人觀點(diǎn)，簡(jiǎn)書(shū)系信息發(fā)布平臺(tái)，僅提供信息存儲(chǔ)服務(wù)。

友情鏈接更多精彩內(nèi)容