RocketMQ源碼解讀 - 專題

投稿

收錄了17篇文章 · 21人關(guān)注

事務(wù)消息
總覽 RocketMQ事務(wù)消息（Transactional Message）是指應(yīng)用本地事務(wù)和發(fā)送消息操作可以被定義到全局事務(wù)中蔬充，要么同時成功蝶俱，...

0.1 93張先生 1 2
順序消息
順序消息順序消息是指消息消費的順序和生產(chǎn)者發(fā)送消息的順序一樣的。例如：一個訂單產(chǎn)生了三條消息分別是訂單創(chuàng)建饥漫、訂單付款榨呆、訂單完成。消費時要按照...

93張先生 0 0

消息進度管理
總覽消息消費者在消費一批消息后庸队，需要記錄該批消息已經(jīng)消費完畢积蜻，然后也會從ProcessQueue處理隊列中移除該批消息，返回ProcessQu...

93張先生 0 0
定時消息機制
概覽定時消息是指消息發(fā)送到Broker后彻消，并不立即被消費者消費而是要等到特定的時間后才能被消費竿拆。 broker有配置項messageDelay...

93張先生 0 0
消息拉取與消息隊列的負載均衡
總覽消息消費的模式有兩種推模式、拉模式宾尚；拉模式已經(jīng)不再推薦使用丙笋，因此本章將詳細介紹推模式。推模式消息到達消息服務(wù)器后央勒，服務(wù)器推送消息給消費...

93張先生 0 1
RocketMQ消費啟動流程
概覽消息消費包含兩種推模式和拉模式不见，拉模式官方已經(jīng)不推薦使用，那我們今天就介紹推模式崔步。DefaultMQPushConsumer是推模式消費的...

93張先生 0 0
RocketMQ消息消費概覽
概覽 RocketMQ消息消費以消費組為消費維度的稳吮，消費組之間消息消費有集群模式與廣播模式兩種消費模式。廣播模式主題下的同一條消息將被集群內(nèi)...

93張先生 0 0

RocketMQHA機制
概覽 RocketMQ作為一款優(yōu)秀的分布式消息中間件井濒，分布式系統(tǒng)的一個很重要的特點就是要保證系統(tǒng)的高可用(HA)灶似，RocketMQ則是通過主從同...

0.1 93張先生 0 1
RocketMQ刷盤機制
概覽 RocketMQ的存儲讀寫是基于JDK NIO的內(nèi)存映射機制的列林，消息存儲時首先將消息追加到內(nèi)存中。在根據(jù)不同的刷盤策略在不同的時間進行刷盤...

0.9 93張先生 0 7
Broker啟動歷史數(shù)據(jù)加載
概覽 Broker啟動需要知道commitlog上次的commitWhere酪惭、flushWhere上次的位置希痴，啟動流程加載commitlog、c...

93張先生 0 1