RocketMQ中Broker的啟動源碼分析（一）
在RocketMQ中，使用BrokerStartup作為啟動類，相較於NameServer的啟動，Broker作為RocketMQ的核心可復雜得多 【RocketMQ中NameServer的啟動源碼分析】 主函數作為其啟動的入口 ...
原文：RocketMQ中Broker的刷盤源碼分析
上一篇博客的最后簡單提了下CommitLog的刷盤 RocketMQ中Broker的消息存儲源碼分析 這篇博客和上一篇有很大的聯系 Broker的CommitLog刷盤會啟動一個線程，不停地將緩沖區的內容寫入磁盤 CommitLog文件 中，主要分為異步刷盤和同步刷盤 異步刷盤又可以分為兩種方式： 緩存到mappedByteBuffer gt 寫入磁盤 包括同步刷盤 緩存到writeBuffer ...
2019-08-07 00:35 0 376 推薦指數：
相關推薦
RocketMQ中Broker的消息存儲源碼分析
Broker和前面分析過的NameServer類似，需要在Pipeline責任鏈上通過NettyServerHandler來處理消息 【RocketMQ中NameServer的啟動源碼分析】 實際上就通過前面提到的SendMessageProcessor ...
rocketmq源碼分析2-broker的消息接收
broker消息接收，假設接收的是一個普通消息(即沒有事務)，此處分析也只分析master上動作邏輯，不涉及ha。 1. 如何找到消息接收處理入口 可以通過broker的監聽端口10911順藤摸瓜式的找到 NettyClientConfig.setListenPort--> ...
rocketmq刷盤過程
本文基於rocketmq4.0版本，結合CommitlLog的刷盤過程，對消息隊列的刷盤過程源碼進行分析，進而對RocketMQ的刷盤原理和過程進行了解。 rocketmq 4.0版本中刷盤類型和以前的版本一樣有兩種： public enum ...
RocketMq刷盤機制
RocketMq刷盤機制 handleDiskFlush ①同步刷盤使用GroupCommitService ②異步刷盤 且開啟了transientStorePoolEnable且不是從服務器，使用CommitLogService 否則使用FlushCommitLogService刷盤 ...
RocketMQ源碼分析 broker啟動，commitlog、consumequeue、indexfile、MappedFileQueue、MappedFile之間的關系以及位置說明
目錄 1.MappedFile類屬性說明 1.1.MappedFile類屬性如下 1.2.MappedFile構造器說明 2.MappedF ...
RocketMQ中Producer消息的發送源碼分析
上篇博客介紹過Producer的啟動，這里涉及到相關內容就不再累贅了 【RocketMQ中Producer的啟動源碼分析】 Producer發送消息，首先需要生成Message實例： 其中properties中存放需要配置的屬性，由MessageConst規定其key ...
RocketMQ中Producer的啟動源碼分析
RocketMQ中通過DefaultMQProducer創建Producer DefaultMQProducer定義如下： 其中defaultMQProducerImpl成員是Producer的具體實現，其余的一些成員是對一些參數的設置：createTopicKey：是一個 ...