分布式事務之訊息佇列一致性和冪等問題

2022-02-19 16:22:07 字數 1994 閱讀 4705

這篇說說分布式事務的問題。企業現在的架構都由傳統的架構轉向了微服務架構,如下圖所示:

那麼,都不可避免的會遇到跨資料庫呼叫的,分布式事務問題!

目前,業內解決分布式事務問題,都基本不用jta這種強一致性的解決方案,基本是採用如下兩套方案

ok,你們先記住兩點

(1)圖中的服務a和服務b,如果是同步呼叫,要求一起成功,或者一起失敗,那麼此時應選用tcc的事務框架,這點我改天另寫一篇,先挖坑!

(2)圖中的服務a和服務b,如果是非同步呼叫,比如服務c先呼叫服務a後,服務c不用管服務b的執行結果,直接返回,那麼這種情況下,應選用訊息佇列!這篇文章重點講!

目前為止,大部分文章都講的太複雜了。導致很多新人看完後於是看這篇文章前,你們先忘記你們在其他文章看到的概念,跟著博主的思路走!

先給大家套乙個業務場景,也是很常見的乙個非同步呼叫場景:

即將服務a假設為支付寶,服務b假設為餘額寶。

於是呢,我們的支付寶往餘額寶轉100塊錢是怎麼做的呢?

特別容易,借助訊息佇列即可,如下圖所示

ok,上面這一版有乙個致命的問題!如下所示

事務開始

(1)給支付寶賬戶zhangsan,扣100元

(2)將(給餘額寶賬戶zhangsan,加100元)封裝為訊息,傳送給訊息佇列

事務結束

敢問你,如何保證第一步和第二步是在同乙個事務裡完成的。換句話說,第一步操作的是資料庫,第二步操作的是乙個訊息佇列,你如何保證這兩步之間的一致性?

記住了,任何涉及到資料庫和中介軟體之間的業務邏輯操作,都需要考慮二者之間的一致性。比如,你先操作了資料庫,再操作快取,資料庫和快取之間一致性如何解決?好吧,如果是博主的鐵粉,應該知道怎麼解決了,回到我們的場景。

改變思路,加一張事務表,如下圖所示

注意了,此時事務的內容為

事務開始

(1)給支付寶賬戶zhangsan,扣100元

(2)給事件表插入一條記錄

事務結束

此時是對同一資料庫的兩張表操作,因此可以用資料庫的事務進行保證。

另外,起乙個定時程式,定時掃瞄事務表,發現乙個狀態為'unfinished'的事件,就進行封裝為訊息,傳送到訊息中介軟體,然後將狀態改為'finished'.

注意了,這一版還存在乙個冪等性問題!

仔細看,定時程式做了如下三個操作

(1)定時掃瞄事務表,發現乙個狀態為'unfinished'的事件

(2)將事件資訊,封裝為訊息,傳送到訊息中介軟體

(3)將事件狀態改為'finished'

ok,假設在步驟(2)的時候,傳送完訊息體,還未執行步驟(3),定時程式陣亡了!然後重啟定時程式,發現剛那個事務的狀態依然為'unfinished',因此重新傳送。這樣,就會出現重複消費問題。因此,冪等性也是需要保證的!

如果是博主的忠實讀者,應該知道,博主曾經寫過一篇《分布式之訊息佇列複習精講》,裡頭就提到了如何解決冪等性問題。什麼?你沒看過這篇?拉出去槍斃!

借用這篇文章裡的方案。在消費者端,也維護乙個帶主鍵的表,可以選txid為主鍵,如下圖所示

如果一旦出現重複消費,則在事務裡直接報出主鍵衝突錯誤,從而保證了冪等性!

面試官:"你們用了微服務架構麼?"

求職者:"用了,用了"

面試官:"怎麼解決分布式事務的啊?"

求職者:"我們的服務剛好是非同步的場景,所以用訊息佇列!"

面試官:"怎麼保證一致性和冪等性啊?"

求職者:"嗯,聽我細細說來....."

分布式一致性 冪等

關於分布式系統的資料一致性問題 一 最近寫了乙個關於 鐵道部購票系統的若干文章 鐵道部新客票系統的設計 一 鐵道部新客票系統的設計 二 鐵道部新客票系統的設計 三 正好遇到乙個博友,諮詢了乙個問題,這個問題正好可以作為分布式系統的資料一致性的簡單例子,當然,這個只是比較簡單的情況 現在先丟擲問題,假...

分布式一致性

分布式一致性是指在分布式環境中對某個副本資料進行更新操作時,必須確保其他副本也會更新,避免不同副本資料不一致。分布式系統乙個重要的問題時解決資料複製,一是為了增加系統的可用性防止單點故障,二是提高系統可用性,通過負載聚恆,使分布在不同位置的資料副本能夠提供服務。理想狀態下,當然希望分布式系統能夠實現...

分布式一致性

分布式系統的乙個重要問題是資料的複製。對資料的複製一般有兩個原因 資料複製的主要難題是保持各個副本的一致性。即在更新乙個副本時,必須確保同時更新其他的副本,否則資料的各個副本將不再相同。一致性模型實質上是程序和資料儲存之間的乙個約定。正常情況下,乙個資料項上執行讀操作時,它期待該操作返回的是該資料在...