我們知道消息隊(duì)列的特性導(dǎo)致其消息不是順序進(jìn)行消費(fèi)的，RocketMQ沒有提供所謂的順序消息來供我們使用，但是有時(shí)候一些場景需要需要順序的去接收消...
投稿
收錄了17篇文章 · 7人關(guān)注
-
RocketMQ順序消息 -
RocketMQ消息過濾消息過濾包括基于表達(dá)式過濾與基于類模式兩種過濾模式。其中表達(dá)式過濾又分為TAG和SQL92模式，分別介紹各自的過濾機(jī)制，及代碼示例內(nèi)容，深入探消...
-
RocketMQ事務(wù)消息在微服務(wù)架構(gòu)中，隨著服務(wù)的逐步拆分，數(shù)據(jù)庫私有已經(jīng)成為共識，這也導(dǎo)致所面臨的分布式事務(wù)問題成為微服務(wù)落地過程中一個(gè)非常難以逾越的障礙，但是目前尚...
-
RocketMQ消息重試
RocketMQ為了保證消息被消費(fèi)采用ACK確認(rèn)機(jī)制，消費(fèi)者消費(fèi)消息時(shí)需要給Broker反饋消息消費(fèi)的情況，成功或失敗，對于失敗的消息會根據(jù)內(nèi)部...
-
RocketMQ刷盤策略
我們都知道RocketMQ的消息是持久化到文件的，具體的消息的刷盤策略是什么，是發(fā)送一條消息就直接持久化到文件中嗎？作為一款高性能的消息中間件這...
-
RocketMQ運(yùn)維監(jiān)控一個(gè)完善的消息中間件，監(jiān)控是必不可少的功能。通過監(jiān)控我們可以查看系統(tǒng)的運(yùn)行情況，是否出現(xiàn)異常，是系統(tǒng)穩(wěn)定性和運(yùn)維的基礎(chǔ)。 1、監(jiān)控平臺搭建 下載...
-
RocketMQ內(nèi)存映射前面幾節(jié)我們講解的都是RocketMQ應(yīng)用層面也有一些關(guān)于源碼的分析講解，消息的存儲只是簡單的分析沒有深入的探討其中的內(nèi)部機(jī)制，我們都知道Roc...
-
RocketMQ權(quán)限控制
RocketMQ作為一款優(yōu)秀的中間件，應(yīng)用領(lǐng)域非常廣泛，金融、電商、電信、醫(yī)療、社科、安保等不同的領(lǐng)域都有其大規(guī)模的應(yīng)用，無疑安全性很受質(zhì)疑，因...
-
RocketMQ主從同步RocketMQ作為一款優(yōu)秀的分布式消息中間件，分布式系統(tǒng)的一個(gè)很重要的特點(diǎn)就是要保證系統(tǒng)的高可用(HA)，RocketMQ則是通過主從同步機(jī)制...
-
RocketMQ存儲文件
RocketMQ存儲路徑默認(rèn)是${ROCKRTMQ_HOME}/store,主要存儲消息、主題對應(yīng)的消息隊(duì)列的索引等。 1、概述 查看其目錄文件...
{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/1872501/2020-04-11_162611.png', '推薦專題《RocketMQ原理分析》（ 分享自 @簡書 ）','http://www.itdecent.cn/c/1ddd6df29784?utm_campaign=maleskine&utm_content=collection&utm_medium=reader_share&utm_source=weibo','頁面編碼gb2312|utf-8默認(rèn)gb2312'));){kind=link}