RocketMQ 學(xué)習(xí)筆記

RocketMQ 簡介

1.RocketMQ 是一個隊列模型的消息中間件寡键,具有高性能,高可用雪隧,高實時等特性西轩,它并不支持JMS(java消息服務(wù))規(guī)范,但參考了JMS規(guī)范和kafak等的思想脑沿。

2.Producer 藕畔、Consumer,隊列都可以分布式庄拇。

3.Producer可以向隊列輪流發(fā)送消息注服,隊列的集合稱為Topic,Consumer可以做廣播消費,也可以做集群消費祠汇。

4.能夠保證嚴(yán)格的消息順序

5.提供消費者水平訂閱擴展能力

6.億級的消息堆積能力

7.較少的依賴

RocketMQ術(shù)語介紹

1.Producer ?消息生產(chǎn)者仍秤,即生產(chǎn)消息的系統(tǒng),一般指業(yè)務(wù)系統(tǒng)可很。

2.Consumer 消息消費者诗力,即消費消息的系統(tǒng),一般指后端的異步處理系統(tǒng)我抠。

3.ProducerGroup 生產(chǎn)者組苇本,指一類發(fā)送消息的系統(tǒng)。

4.ConsumerGroup 消費組菜拓,指消費同一類消息的系統(tǒng)

5.Broker 消息中間件瓣窄,主要完成消息的存儲,轉(zhuǎn)發(fā)纳鼎,是消息系統(tǒng)的核心組件俺夕。

5.Topic 消息主題,消息隊列的集合贱鄙。

6.MessageQueue ?消息隊列劝贸,RocketMQ 的所有消息都是持久化的,可以把MessageQueue 理解為一個長度無限的數(shù)組逗宁,通過下標(biāo)offset 訪問消息

7.廣播消費消息模型映九,指消費這消費某主題的所有隊列的消息,消費組在該消息模型下不起作用瞎颗,類似JMS的publish/subscribe.

8.集群消費消息模型件甥,是指同一個消費組的消費者各自消費某一主題的消費隊列的消息,比如有一個主題 topicA,該主題有4個隊列(創(chuàng)建主題的時候可以指定該主題的隊列的數(shù)量),有一個消費組testConsumerGroup,該消費組有四個消費者(四個機器或者四個進程),則四個消費者各自消費一個消息隊列哼拔。

RocketMQ 提供功能

1.消息的順序引有,即消費消息的順序同發(fā)送消息消息的順序一致。

2.消息重試管挟,即消息消費失敗后轿曙,RocketMQ 提供了一種機制,可以讓消息在消費一次僻孝。

3.定時消息,即指消息到達broker后守谓,并不是立即投遞給消費者穿铆,而是在某個時間點或者一定的延時后在投遞,RocketMQ支持一定的延時投遞消息斋荞。

4.消息回溯荞雏,是指消息成功被消費者消費后,可能需要一個機制重新消費以前的消息,rocketmq支持回溯消費某個時間點的消息(支持到毫秒級別),可以向前也可以向后凤优。

5.消息重復(fù)悦陋,RocketMQ 保證 At least once ,即消息至少被投遞一次筑辨,并不支持 Exactly only once(支持這個需要生產(chǎn)者指發(fā)送一次俺驶,broker只投遞一次,實現(xiàn)這個會損失性能)棍辕,所以由于網(wǎng)絡(luò)或者消費組啟動或者停止暮现,可能造成消息重復(fù)投遞,需要消費者做到去重楚昭,即消費消息要做到冪等栖袋,但在大部分情況下,消息是不會重復(fù)投遞的抚太。

最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
  • 序言:七十年代末塘幅,一起剝皮案震驚了整個濱河市,隨后出現(xiàn)的幾起案子尿贫,更是在濱河造成了極大的恐慌晌块,老刑警劉巖,帶你破解...
    沈念sama閱讀 222,104評論 6 515
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件帅霜,死亡現(xiàn)場離奇詭異匆背,居然都是意外死亡,警方通過查閱死者的電腦和手機身冀,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 94,816評論 3 399
  • 文/潘曉璐 我一進店門钝尸,熙熙樓的掌柜王于貴愁眉苦臉地迎上來,“玉大人搂根,你說我怎么就攤上這事珍促。” “怎么了剩愧?”我有些...
    開封第一講書人閱讀 168,697評論 0 360
  • 文/不壞的土叔 我叫張陵猪叙,是天一觀的道長。 經(jīng)常有香客問我仁卷,道長穴翩,這世上最難降的妖魔是什么? 我笑而不...
    開封第一講書人閱讀 59,836評論 1 298
  • 正文 為了忘掉前任锦积,我火速辦了婚禮芒帕,結(jié)果婚禮上,老公的妹妹穿的比我還像新娘丰介。我一直安慰自己背蟆,他們只是感情好鉴分,可當(dāng)我...
    茶點故事閱讀 68,851評論 6 397
  • 文/花漫 我一把揭開白布。 她就那樣靜靜地躺著带膀,像睡著了一般志珍。 火紅的嫁衣襯著肌膚如雪。 梳的紋絲不亂的頭發(fā)上垛叨,一...
    開封第一講書人閱讀 52,441評論 1 310
  • 那天伦糯,我揣著相機與錄音,去河邊找鬼点额。 笑死舔株,一個胖子當(dāng)著我的面吹牛,可吹牛的內(nèi)容都是我干的还棱。 我是一名探鬼主播载慈,決...
    沈念sama閱讀 40,992評論 3 421
  • 文/蒼蘭香墨 我猛地睜開眼,長吁一口氣:“原來是場噩夢啊……” “哼珍手!你這毒婦竟也來了办铡?” 一聲冷哼從身側(cè)響起,我...
    開封第一講書人閱讀 39,899評論 0 276
  • 序言:老撾萬榮一對情侶失蹤琳要,失蹤者是張志新(化名)和其女友劉穎寡具,沒想到半個月后,有當(dāng)?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體稚补,經(jīng)...
    沈念sama閱讀 46,457評論 1 318
  • 正文 獨居荒郊野嶺守林人離奇死亡童叠,尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點故事閱讀 38,529評論 3 341
  • 正文 我和宋清朗相戀三年,在試婚紗的時候發(fā)現(xiàn)自己被綠了课幕。 大學(xué)時的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片厦坛。...
    茶點故事閱讀 40,664評論 1 352
  • 序言:一個原本活蹦亂跳的男人離奇死亡,死狀恐怖乍惊,靈堂內(nèi)的尸體忽然破棺而出杜秸,到底是詐尸還是另有隱情,我是刑警寧澤润绎,帶...
    沈念sama閱讀 36,346評論 5 350
  • 正文 年R本政府宣布撬碟,位于F島的核電站,受9級特大地震影響莉撇,放射性物質(zhì)發(fā)生泄漏呢蛤。R本人自食惡果不足惜,卻給世界環(huán)境...
    茶點故事閱讀 42,025評論 3 334
  • 文/蒙蒙 一稼钩、第九天 我趴在偏房一處隱蔽的房頂上張望顾稀。 院中可真熱鬧,春花似錦坝撑、人聲如沸静秆。這莊子的主人今日做“春日...
    開封第一講書人閱讀 32,511評論 0 24
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽抚笔。三九已至,卻和暖如春侨拦,著一層夾襖步出監(jiān)牢的瞬間殊橙,已是汗流浹背。 一陣腳步聲響...
    開封第一講書人閱讀 33,611評論 1 272
  • 我被黑心中介騙來泰國打工狱从, 沒想到剛下飛機就差點兒被人妖公主榨干…… 1. 我叫王不留膨蛮,地道東北人。 一個月前我還...
    沈念sama閱讀 49,081評論 3 377
  • 正文 我出身青樓季研,卻偏偏與公主長得像敞葛,于是被迫代替她去往敵國和親。 傳聞我的和親對象是個殘疾皇子与涡,可洞房花燭夜當(dāng)晚...
    茶點故事閱讀 45,675評論 2 359

推薦閱讀更多精彩內(nèi)容

  • “ 消息隊列已經(jīng)逐漸成為企業(yè)IT系統(tǒng)內(nèi)部通信的核心手段惹谐。它具有低耦合、可靠投遞驼卖、廣播氨肌、流量控制、最終一致性等一系列...
    落羽成霜丶閱讀 3,993評論 1 41
  • 消息隊列已經(jīng)逐漸成為企業(yè)IT系統(tǒng)內(nèi)部通信的核心手段酌畜。它具有低耦合怎囚、可靠投遞、廣播桥胞、流量控制恳守、最終一致性等一系列功能...
    Sophie12138閱讀 723評論 0 7
  • Spring Cloud為開發(fā)人員提供了快速構(gòu)建分布式系統(tǒng)中一些常見模式的工具(例如配置管理,服務(wù)發(fā)現(xiàn)埠戳,斷路器井誉,智...
    卡卡羅2017閱讀 134,704評論 18 139
  • “他們說你經(jīng)常自己出去,也不帶我們整胃】攀ィ” 我很想聽聽她的想法,問“那你怎么看待這個問題的呢屁使?” “也不是這樣的啊在岂,你...
    EvelynFish閱讀 495評論 0 1