總覽 RocketMQ事務(wù)消息（Transactional Message）是指應(yīng)用本地事務(wù)和發(fā)送消息操作可以被定義到全局事務(wù)中，要么同時(shí)成功，...
投稿
收錄了17篇文章 · 21人關(guān)注
-
事務(wù)消息 -
順序消息
順序消息 順序消息是指消息消費(fèi)的順序和生產(chǎn)者發(fā)送消息的順序一樣的。 例如：一個(gè)訂單產(chǎn)生了三條消息分別是訂單創(chuàng)建、訂單付款、訂單完成。消費(fèi)時(shí)要按照...
-
消息進(jìn)度管理
總覽 消息消費(fèi)者在消費(fèi)一批消息后，需要記錄該批消息已經(jīng)消費(fèi)完畢，然后也會(huì)從ProcessQueue處理隊(duì)列中移除該批消息，返回ProcessQu...
-
定時(shí)消息機(jī)制
概覽 定時(shí)消息是指消息發(fā)送到Broker后，并不立即被消費(fèi)者消費(fèi)而是要等到特定的時(shí)間后才能被消費(fèi)。 broker有配置項(xiàng)messageDelay...
-
消息拉取與消息隊(duì)列的負(fù)載均衡總覽 消息消費(fèi)的模式有兩種推模式、拉模式；拉模式已經(jīng)不再推薦使用，因此本章將詳細(xì)介紹推模式。 推模式 消息到達(dá)消息服務(wù)器后，服務(wù)器推送消息給消費(fèi)...
-
RocketMQ消費(fèi)啟動(dòng)流程
概覽 消息消費(fèi)包含兩種推模式和拉模式，拉模式官方已經(jīng)不推薦使用，那我們今天就介紹推模式。DefaultMQPushConsumer是推模式消費(fèi)的...
-
RocketMQ消息消費(fèi)概覽
概覽 RocketMQ消息消費(fèi)以消費(fèi)組為消費(fèi)維度的，消費(fèi)組之間消息消費(fèi)有集群模式與廣播模式兩種消費(fèi)模式。 廣播模式 主題下的同一條消息將被集群內(nèi)...
-
RocketMQHA機(jī)制概覽 RocketMQ作為一款優(yōu)秀的分布式消息中間件，分布式系統(tǒng)的一個(gè)很重要的特點(diǎn)就是要保證系統(tǒng)的高可用(HA)，RocketMQ則是通過主從同...
-
RocketMQ刷盤機(jī)制概覽 RocketMQ的存儲(chǔ)讀寫是基于JDK NIO的內(nèi)存映射機(jī)制的，消息存儲(chǔ)時(shí)首先將消息追加到內(nèi)存中。在根據(jù)不同的刷盤策略在不同的時(shí)間進(jìn)行刷盤...
-
Broker啟動(dòng)歷史數(shù)據(jù)加載
概覽 Broker啟動(dòng)需要知道commitlog上次的commitWhere、flushWhere上次的位置，啟動(dòng)流程加載commitlog、c...
{var%20f='http://v.t.sina.com.cn/share/share.php?appkey=1881139527',u=z||d.location,p=['&url=',e(u),'&title=',e(t||d.title),'&source=',e(r),'&sourceUrl=',e(l),'&content=',c||'gb2312','&pic=',e(p||'')].join('');function%20a(){if(!window.open([f,p].join(''),'mb',['toolbar=0,status=0,resizable=1,width=440,height=430,left=',(s.width-440)/2,',top=',(s.height-430)/2].join('')))u.href=[f,p].join('');};if(/Firefox/.test(navigator.userAgent))setTimeout(a,0);else%20a();})(screen,document,encodeURIComponent,'','','https://upload.jianshu.io/collections/images/1929292/1200px-Apache_RocketMQ_Logo.svg.png', '推薦專題《RocketMQ源碼解讀》（ 分享自 @簡(jiǎn)書 ）','http://m.itdecent.cn/c/4053e056ae5b?utm_campaign=maleskine&utm_content=collection&utm_medium=reader_share&utm_source=weibo','頁面編碼gb2312|utf-8默認(rèn)gb2312'));){kind=link}