首页
/
每日頭條
/
圖文
/
rocket mq延遲消息隊列實現原理
rocket mq延遲消息隊列實現原理
更新时间:2025-11-19 15:04:39

有關RocketMQ實現分布式事務的理論知識,下篇也會示例 通過SpringCloud來實例RocketMQ實現分布式事務的項目。

一、舉個分布式事務場景

列子:假設 AB100塊錢,同時它們不是同一個服務商。

目标:就是 A 減100塊錢,B 加100塊錢。

實際情況可能有四種:

1)就是A賬戶減100 (成功),B賬戶加100 (成功)

2)就是A賬戶減100(失敗),B賬戶加100 (失敗)

3)就是A賬戶減100(成功),B賬戶加100 (失敗)

4)就是A賬戶減100 (失敗),B賬戶加100 (成功)

這裡 第1和第2 種情況是能夠保證事務的一緻性的,但是 第3和第4 是無法保證事務的一緻性的。

那我們來看下RocketMQ是如何來保證事務的一緻性的。

二、RocketMQ實現分布式事務原理

RocketMQ雖然之前也支持分布式事務,但并沒有開源,等到RocketMQ 4.3才正式開源。

1、基礎概念

最終一緻性

RocketMQ是一種最終一緻性的分布式事務,就是說它保證的是消息最終一緻性,而不是像2PC、3PC、TCC那樣強一緻分布式事務,至于為什麼說它是最終一緻性事務下面會詳細說明。

Half message(半消息)

是指暫不能被Consumer消費的消息。Producer 已經把消息成功發送到了 Broker 端,但此消息被标記為暫不能投遞狀态,處于該種狀态下的消息稱為半消息。需要 Producer

對消息的二次确認後,Consumer才能去消費它。

消息回查

由于網絡閃段,生産者應用重啟等原因。導緻 Producer 端一直沒有對 Half Message(半消息) 進行 二次确認。這是Brock服務器會定時掃描長期處于半消息的消息,會

主動詢問 Producer端 該消息的最終狀态(Commit或者Rollback),該消息即為 消息回查

2、分布式事務交互流程

理解這張阿裡官方的圖,就能理解RocketMQ分布式事務的原理了。

rocket mq延遲消息隊列實現原理(RocketMQ實現分布式事務原理)1

我們來說明下上面這張圖

1、A服務先發送給Half Message給Brock端,消息中攜帶 B服務 即将要 100元的信息。

2、當A服務知道Half Message發送成功後,那麼開始第3步執行本地事務。

3、執行本地事務(會有三種情況1、執行成功。2、執行失敗。3、網絡等原因導緻沒有響應)

4.1)、如果本地事務成功,那麼Product向Brock服務器發送Commit,這樣B服務就可以消費該message。

4.2)、如果本地事務失敗,那麼Product向Brock服務器發送Rollback,那麼就會直接删除上面這條半消息。

4.3)、如果因為網絡等原因遲遲沒有返回失敗還是成功,那麼會執行RocketMQ的回調接口,來進行事務的回查。

從上面流程可以得知隻有A服務本地事務執行成功 ,B服務才能消費該message。

然後我們再來思考幾個問題?

rocket mq延遲消息隊列實現原理(RocketMQ實現分布式事務原理)2

為什麼要先發送Half Message(半消息)

我覺得主要有兩點

1)可以先确認 Brock服務器是否正常 ,如果半消息都發送失敗了 那說明Brock挂了。

2)可以通過半消息來回查事務,如果半消息發送成功後一直沒有被二次确認,那麼就會回查事務狀态。

什麼情況會回查

也會有兩種情況

1)執行本地事務的時候,由于突然網絡等原因一直沒有返回執行事務的結果(commit或者rollback)導緻最終返回UNKNOW,那麼就會回查。

2) 本地事務執行成功後,返回Commit進行消息二次确認的時候的服務挂了,在重啟服務那麼這個時候在brock端

它還是個Half Message(半消息),這也會回查。

特别注意: 如果回查,那麼一定要先查看當前事務的執行情況,再看是否需要重新執行本地事務。

想象下如果出現第二種情況而引起的回查,如果不先查看當前事務的執行情況,而是直接執行事務,那麼就相當于成功執行了兩個本地事務。

為什麼說MQ是最終一緻性事務

通過上面這幅圖,我們可以看出,在上面舉例事務不一緻的兩種情況中,永遠不會發生

A賬戶減100 (失敗),B賬戶加100 (成功)

因為:如果A服務本地事務都失敗了,那B服務永遠不會執行任何操作,因為消息壓根就不會傳到B服務。

那麼 A賬戶減100 (成功),B賬戶加100 (失敗) 會不會可能存在的。

答案是會的

因為A服務隻負責當我消息執行成功了,保證消息能夠送達到B,至于B服務接到消息後最終執行結果A并不管。

那B服務失敗怎麼辦?

如果B最終執行失敗,幾乎可以斷定就是代碼有問題所以才引起的異常,因為消費端RocketMQ有重試機制,如果不是代碼問題一般重試幾次就能成功。

如果是代碼的原因引起多次重試失敗後,也沒有關系,将該異常記錄下來,由人工處理,人工兜底處理後,就可以讓事務達到最終的一緻性。

最後

不管多忙,每天給自己預留至少半小時的學習時間,拒絕做代碼垃圾的搬運工!

有不對的地方可以在評論區留言,覺得不錯的朋友希望能得到您的轉發支持,同時可以持續關注我,每周定期會分享3到4篇精選幹貨!

,
Comments
Welcome to tft每日頭條 comments! Please keep conversations courteous and on-topic. To fosterproductive and respectful conversations, you may see comments from our Community Managers.
Sign up to post
Sort by
Show More Comments
推荐阅读
康熙小s唱歌(又可以看小S手撕嘉賓了)
康熙小s唱歌(又可以看小S手撕嘉賓了)
  01   2015年10月,那個說永不缺席的蔡康永發出一條辭别《康熙來了》的微博。      而随後小S也在微博回應說“沒有你便不完整,所以親愛的,我們就共進退吧!”      就這樣2876集、12年陪伴的《康熙來了》開始了它毫無預警的告别。   12年死忠粉任泉說“沒了,才知道什麼是真沒了。”   姚晨說“多麼希望你明天說,這隻是你和大家開的一個玩笑...
2025-11-19
最新韓國古裝高分b級電影推薦(豆瓣8.3分的R級片)
最新韓國古裝高分b級電影推薦(豆瓣8.3分的R級片)
  美輪美奂的西部風景,動聽悅耳的音樂,六則寓意深刻的故事娓娓道來,看科恩兄弟的新作,再一次被故事的強烈宿命感震撼到,看完回味無窮。   時隔兩年,伊桑·科恩和喬爾·科恩終于又帶來一部新作《巴斯特·斯克魯格斯的歌謠》,看片名差點以為是紀錄片,又或者歌舞片。      《巴斯特·斯克魯格斯的歌謠》在豆瓣評分高達8.3分,好于92%的西部片,好于92%的喜劇片,...
2025-11-19
和田玉羊脂玉怎麼識别真假的方法(和田玉的謠言一)
和田玉羊脂玉怎麼識别真假的方法(和田玉的謠言一)
  一說到和田玉,大家想到最多的詞語便是“羊脂玉”,好多商家也說自己的玉是羊脂玉,那到底什麼是羊脂玉,真的很稀缺珍貴嗎?   關于“羊脂玉”,大家有許多不了解,市場上也有很多羊脂玉的謠言,下面我用5句話給大家說清楚“羊脂玉”的前世今生。   1、在三國時代,曹丕曾在《與鐘繇謝玉玦書》中曰:“竊見玉書,稱美玉白如截肪,黑譬純漆,赤拟雞冠,黃侔蒸栗” 這是史料中...
2025-11-19
棗莊市東湖公園在哪裡(東湖公園彼岸花競相開放)
棗莊市東湖公園在哪裡(東湖公園彼岸花競相開放)
  棗莊市市中區:東湖公園彼岸花競相開放眼下,在棗莊市市中區東湖公園道路兩旁,如果你用心就會看到,一片片、一簇簇生在枝頭鮮紅的花朵正在陸續開放。它排列如傘,絲光閃閃、花瓣朝後反卷,形成燈籠狀,從花瓣中心迸射出幾支長長的蕊絲,仿佛煙花一般,十分豔麗。               這種美麗的花叫中國石蒜,為東亞特有植物,人們通常稱為彼岸花。石蒜屬植物葉片于花前或...
2025-11-19
鹿鼎記和天龍八部相同演員(天龍八部鹿鼎記之後她光芒不再)
鹿鼎記和天龍八部相同演員(天龍八部鹿鼎記之後她光芒不再)
     《知否知否應是綠肥紅瘦》收官之後,當下熱播的各部古裝劇平分秋色,最近話題度比較高的,除了《東宮》和《獨孤皇後》以外,大概就是劇名相當惹眼的《招搖》了。      大概是因為與才播出不久、由楊幂主演的古裝玄幻劇《扶搖》劇名高度重合,網友們對這部劇的吐槽和議論不斷。不過從這部劇中,卻有另外一個值得注意卻被大多數網友忽略的點,那就是其中獨孤修的扮演者竟然...
2025-11-19
Copyright 2023-2025 - www.tftnews.com All Rights Reserved