11篇文章 · 9150字 · 4人關(guān)注
-
RocketMQ 同步刷盤實(shí)現(xiàn)原理
未寫完，待續(xù)。。。。 刷盤服務(wù)類有三種 同步刷盤時(shí)使用 GroupCommitService 異步刷盤時(shí)使用 FlushRealTimeServ...
-
RocketMQ MappedFile 預(yù)熱原理解析
創(chuàng)建 MappedFile 文件 創(chuàng)建 MappedFile 文件實(shí)現(xiàn)如下： 從代碼中可以看出钠至，只有 MappedFile 的大小等于或大于 C...
-
RocketMQ 延遲消息
概述 RocketMQ 支持發(fā)送延遲消息，但不支持任意時(shí)間的延遲消息的設(shè)置胎源，僅支持內(nèi)置預(yù)設(shè)值的延遲時(shí)間間隔的延遲消息棉钧。 預(yù)設(shè)值的延遲時(shí)間間隔為：...
-
RocketMQ CommitLog 文件規(guī)則1、CommitLog 文件生成規(guī)則 偏移量：每個(gè) CommitLog 文件的大小為 1G涕蚤，一般情況下第一個(gè) CommitLog 的起始偏移量為...
-
RocketMQ 存儲(chǔ)機(jī)制源碼解析
producer 發(fā)送消息后掰盘，broker端開始存儲(chǔ)消息，會(huì)調(diào)用 store 模塊的 DefaultMessageStore.putMessag...
-
RocketMQ 生產(chǎn)者 Producer 發(fā)送消息三種方式分析
概述 Producer 發(fā)送消息赞季，RocketMQ 提供了三種模式愧捕。 同步發(fā)送 異步發(fā)送 OneWay 發(fā)送 示例代碼如下： 1、同步發(fā)送Pro...
-
RocketMQ 生產(chǎn)者 Producer 啟動(dòng)過程MQProducer 從類關(guān)系中可以看出申钩，MQProducer 有兩種實(shí)現(xiàn)方式次绘。一個(gè)是 DefaultMQProducer，另一個(gè)是 Trans...
-
RocketMQ 生產(chǎn)者 rebalence 原理
概述 生產(chǎn)者 producer 在發(fā)送消息的時(shí)候撒遣，每個(gè)消息發(fā)送到 broker 只存儲(chǔ)在某一個(gè) quene 上邮偎。那么 producer 是怎么選...
-
RocketMQ 命令行工具源碼結(jié)構(gòu)解析概述 RocketMQ 提供有控制臺(tái)及一系列控制臺(tái)命令，用于管理員對(duì)主題义黎，集群禾进，broker 等信息的管理； 進(jìn)入 RocketMQ 的bin ...
