分布式事務(wù)-Seata極簡(jiǎn)入門(mén)

下面是這次Seata極簡(jiǎn)入門(mén)的大致講解目錄:

  • 分布式事務(wù)介紹
  • 兩階段提交(2pc)
  • Seate簡(jiǎn)介
  • Seate事務(wù)模式
  • Seata實(shí)現(xiàn)2PC與傳統(tǒng)2PC的區(qū)別

一.分布式事務(wù)介紹

先給大家舉個(gè)例子說(shuō)明下什么是分布式事務(wù)。給大家看看沒(méi)有分布式事務(wù)和具有分布式事務(wù)在微服務(wù)架構(gòu)中的情況池凄。

  • 沒(méi)有分布式事務(wù)
    假設(shè)在下面的微服務(wù)架構(gòu)中,沒(méi)有分布式事務(wù)涎嚼,會(huì)出現(xiàn)什么情況北苟?
    沒(méi)有分布式事務(wù).jpg

    大家可以看到,如果沒(méi)有分布式事務(wù)出現(xiàn)異常情況,會(huì)造成兩個(gè)服務(wù)之間數(shù)據(jù)不一致移必。庫(kù)存被扣減成功了,但是訂單創(chuàng)建失敗了毡鉴,或者訂單創(chuàng)建成功了崔泵,但是庫(kù)存沒(méi)有扣減。
    單數(shù)據(jù)源的一致性單機(jī)事務(wù)就可以完成猪瞬,但是上面這種多數(shù)據(jù)源的數(shù)據(jù)一致性就需要分布式事務(wù)憎瘸。
  • 具有分布式事務(wù)
    如果有分布式事務(wù),上面的情況會(huì)變成什么樣了撑螺?如下:


    有分布式事務(wù)

    如果出現(xiàn)異常情況含思,會(huì)進(jìn)行回滾操作,保證了多數(shù)據(jù)源的數(shù)據(jù)一致性甘晤。


解決方案

分布式事務(wù)用于在分布式系統(tǒng)中保證多節(jié)點(diǎn)的數(shù)據(jù)一致性含潘。
具有多種解決方案:

  • XA分布式事務(wù)協(xié)議,由Tuxedo提出
    1. 2PC-Two Phase Commit线婚。兩階段提交
    2. 3PC-Three Phase Commit遏弱。三階段提交、
兩階段:**準(zhǔn)備階段和執(zhí)行階段**
  • TCC編程事務(wù)(Try-Confirm-Cancel)
    TCC跟XA類(lèi)似塞弊,但是需要人工手動(dòng)編寫(xiě)代碼來(lái)實(shí)現(xiàn)漱逸,具有代碼入侵性。
  • MQ消息事務(wù)
    目前消息隊(duì)列中游沿,RockMQ是支持消息事務(wù)的饰抒。到達(dá)最終一致性。

二.XA協(xié)議-兩階段提交-2PC

XA協(xié)議中包含了兩個(gè)角色:事務(wù)協(xié)調(diào)者事務(wù)參與者
接下來(lái)看看兩階段提交的流程诀黍。

1.正常流程

  • 第一階段(正常)
    第一階段也就是準(zhǔn)備階段袋坑;
第一階段正常.png
1. 事務(wù)協(xié)調(diào)者會(huì)向所有事務(wù)參與者發(fā)送準(zhǔn)備(Prepare)請(qǐng)求;
2. 每個(gè)事務(wù)參與者收到請(qǐng)求眯勾,會(huì)處理本地事務(wù)相關(guān)的數(shù)據(jù)更新操作枣宫,并寫(xiě)入到undo_log表中,并告訴事務(wù)協(xié)調(diào)者“我完成了”吃环;
  • 第二階段(正常)
    事務(wù)協(xié)調(diào)者收到所有參與者的請(qǐng)求后也颤,整個(gè)分布式事務(wù)就會(huì)進(jìn)入到第二階段,也就是執(zhí)行階段
    第二階段正常.png
1. 事務(wù)協(xié)調(diào)者收到所有參與者都是正向返回郁轻,則會(huì)向所有參與者發(fā)出commit請(qǐng)求翅娶;
2. 參與者收到commit請(qǐng)求后,就會(huì)提交本地事務(wù),并釋放鎖資源故觅;完成之后告訴事務(wù)協(xié)調(diào)者“我完成了”厂庇;
3. 事務(wù)協(xié)調(diào)者收到所有參與者的“我完成了”,然后就會(huì)結(jié)束分布式事務(wù)输吏;

2. 異常處理流程

  • 第一階段(異常)


    第一階段異常.png
1. 事務(wù)協(xié)調(diào)者會(huì)向所有事務(wù)參與者發(fā)送準(zhǔn)備(Prepare)請(qǐng)求权旷;
2. 如果事務(wù)參與者B出現(xiàn)失敗情況,則會(huì)告訴協(xié)調(diào)者“我失敗了”贯溅;
  • 第二階段(異常)
    當(dāng)事務(wù)協(xié)調(diào)者收到所有參與者返回的消息拄氯,分布式事務(wù)進(jìn)入第二階段;


    第二階段異常.png
1. 事務(wù)協(xié)調(diào)者收到某個(gè)參與者是失敗的情況它浅,則會(huì)向所有參與者發(fā)送Rollback請(qǐng)求译柏;
2. 參與者收到Rollback請(qǐng)求時(shí),會(huì)根據(jù)undo_log表回滾本地事務(wù)姐霍,并釋放鎖資源鄙麦;

3.存在的缺點(diǎn)

咱們總結(jié)下傳統(tǒng)的2pc流程的相關(guān)缺點(diǎn):

  • 同步阻塞問(wèn)題
    執(zhí)行過(guò)程中,所有的參與節(jié)點(diǎn)都是事務(wù)阻塞型镊折。當(dāng)參與者訪問(wèn)公共資源時(shí)胯府,其他第三方節(jié)點(diǎn)訪問(wèn)公共資源不得不等待,處于阻塞狀態(tài)恨胚;
  • 單點(diǎn)故障
    由于協(xié)調(diào)者的重要性骂因,一旦協(xié)調(diào)者發(fā)生故障,則參與者就會(huì)一直處于阻塞狀態(tài)赃泡。特別是在第二階段寒波,如果協(xié)調(diào)者出現(xiàn)故障,則所有的參與者都還處于鎖定事務(wù)資源的狀態(tài)升熊,而無(wú)法繼續(xù)完成事務(wù)操作俄烁;
  • 數(shù)據(jù)不一致
    如果在第二階段,協(xié)調(diào)者發(fā)送Commit請(qǐng)求后發(fā)生故障级野,可能會(huì)導(dǎo)致一部分參與者執(zhí)行了commit請(qǐng)求页屠,一部分沒(méi)有執(zhí)行,會(huì)造成數(shù)據(jù)不一致的情況勺阐;

針對(duì)上面這些缺點(diǎn),提出了三階段(3PC)提交矛双;
三階段提交有兩個(gè)改動(dòng)點(diǎn)渊抽,下面簡(jiǎn)單列舉下:

  • 同時(shí)在事務(wù)協(xié)調(diào)者和參與者中都引人了超時(shí)機(jī)制;
  • 在第一階段和第二階段中間新增了一個(gè)準(zhǔn)備階段(CanCommit),保證了在最后提交之前所有參與者狀態(tài)一致议忽;

三.Seata 簡(jiǎn)介

1. Seata的由來(lái)

  • 2019年1月懒闷,阿里巴巴中間件團(tuán)隊(duì)發(fā)起了開(kāi)源項(xiàng)目Fascar;
  • Fascar開(kāi)源之后,螞蟻金服加入了Fascar社區(qū)進(jìn)行共建愤估;
  • 為了打造更中立帮辟,更開(kāi)放,生態(tài)更加豐富的分布式事務(wù)開(kāi)源社區(qū)玩焰,大家決定對(duì)Fascar進(jìn)行品牌升級(jí)由驹,更名為Seata(Simple Extensible Autonomous Transcation Architecture);是一套一站式分布式事務(wù)解決方案昔园;

2. Seata是什么榄棵?

來(lái)自官網(wǎng)的介紹:
Seata是一款開(kāi)源的分布式事務(wù)解決方案帆阳,致力于提供高性能和簡(jiǎn)單易用的分布式事務(wù)。Seata將為用戶提供AT,TCC袱饭,SAGA和XA事務(wù)協(xié)議。為用戶打造一站式分布式解決方案伟桅。

3. Seata術(shù)語(yǔ)

  • 事務(wù)協(xié)調(diào)者-TC(Transaction Coordinator)
    維護(hù)全局和分支事務(wù)狀態(tài)退敦,驅(qū)動(dòng)全局事務(wù)提交或者回滾;
  • 事務(wù)管理器-TM(Transaction Manager)
    定義全局事務(wù)的范圍邪锌,開(kāi)始全局事務(wù)勉躺,提交或者回滾全局事務(wù);
  • 資源管理器-RM(Resource Manager)
    管理分支事務(wù)處理的資源秃流,并驅(qū)動(dòng)分支事務(wù)提交或者回滾赂蕴;
    關(guān)系圖.jpg

    從圖中可以看出TC是單獨(dú)部署的服務(wù)端,TM和RM是嵌入到應(yīng)用中的Client客戶端舶胀;

四.Seata 事務(wù)模式

1.Seata 全局事務(wù)架構(gòu)

定義:全局事務(wù)可以理解為若干分支事務(wù)的協(xié)調(diào)概说;
Seata的全局事務(wù)可以理解為兩個(gè)階段:

  • 執(zhí)行階段
    執(zhí)行分支事務(wù),并保證執(zhí)行結(jié)果是可回滾的可持久化的嚣伐;
  • 完成階段
    根據(jù)執(zhí)行階段結(jié)果形成的決議糖赔,應(yīng)用通過(guò)TM發(fā)出的全局提交或回滾請(qǐng)求給TC,TC命令TM驅(qū)動(dòng)分支事務(wù)進(jìn)行Commit或者Rollback轩端;
    Seata官網(wǎng)獲取的一個(gè)整體架構(gòu)圖:
    全局事務(wù)架構(gòu).jpg
1. TM負(fù)責(zé)向TC發(fā)起(Begin),提交(Commit),回滾(Rollback)全局事務(wù)放典;
2. TM把代表全局事務(wù)的XID綁定到分支事務(wù)上;
3. RM注冊(cè)到TC基茵,還會(huì)把分支事務(wù)執(zhí)行結(jié)果反饋給TC奋构;
4. TC發(fā)送分支提交Commit或者分支回滾Rollback給RM;

2.Seata 事務(wù)模式

定義: Seata事務(wù)模式也叫做分支事務(wù)模式拱层,是指運(yùn)行在Seata全局事務(wù)框架下的分支事務(wù)的行為模式弥臼;
目前Seata提供了四種事務(wù)模式:

  • AT模式
  • TCC模式
  • SAGA模式
  • XA模式
不同的模式區(qū)別在于【分支事務(wù)】使用【不同的方式】完成全局事務(wù)的兩個(gè)階段

Seata事務(wù)模式.jpg

從圖中可以看到AT和XA是業(yè)務(wù)無(wú)侵入的,TCC和SAGA是有業(yè)務(wù)侵入的根灯;

下面咱們看看AT模式和TCC模式,目前應(yīng)用的比較多的兩種径缅;

3. AT模式

  • 前提
    基于支持本地ACID事務(wù)的關(guān)系型數(shù)據(jù)庫(kù)掺栅;
    Java應(yīng)用,通過(guò)JDBC訪問(wèn)數(shù)據(jù)庫(kù)纳猪;
  • 整體機(jī)制
    兩階段提交協(xié)議的演變氧卧;
    一階段:業(yè)務(wù)數(shù)據(jù)和undo_log日志記錄在同一個(gè)本地事務(wù)中提交,釋放本地鎖和連接資源氏堤;
    二階段:提交異步化沙绝;回滾通過(guò)一階段undo_log回滾日志進(jìn)行反向補(bǔ)償;
  • 流程圖


    AT模式.png
1. 第一階段
  注冊(cè)分支事務(wù)到TC丽猬;
  通過(guò)代理數(shù)據(jù)源DataSourceProxy對(duì)業(yè)務(wù)sql進(jìn)行解析宿饱,并轉(zhuǎn)換成undolog;并與業(yè)務(wù)sql在一個(gè)事務(wù)內(nèi)入庫(kù)脚祟;
  提交本地事務(wù)谬以,上報(bào)狀態(tài)給TC;
2. 第二階段
  分布式事務(wù)操作成功由桌,則TC通知RM異步刪除undolog为黎;
  分布式事務(wù)操作失敗,
    TM向TC發(fā)布回滾請(qǐng)求行您;
    RM收到協(xié)調(diào)器TC發(fā)來(lái)回滾指令铭乾,通過(guò)XID和BranchID找到對(duì)應(yīng)回滾日志;
    通過(guò)回滾日志生成反向的補(bǔ)償SQl并執(zhí)行娃循,完成分支事務(wù)的回滾炕檩;

  • UNDO_LOG 表
    生成的undolog表數(shù)據(jù)如下:


    undo_log.png
數(shù)據(jù)中存儲(chǔ)了操作前鏡像,操作后鏡像捌斧,有全局事務(wù)XID笛质,和分支事務(wù)BranchID等信息;

4. TCC模式

對(duì)AT模式有些了解后捞蚂,咱們?cè)倏纯碩CC模式妇押;

  • TCC模式介紹
    TCC--Try,Confirm姓迅,Cancel敲霍;業(yè)務(wù)方需要實(shí)現(xiàn)這三個(gè)方法來(lái)完成分布式事務(wù);
    TCC模式是指把自定義分支事務(wù)納入到全局事務(wù)進(jìn)行管理丁存;

  • TCC模式優(yōu)缺點(diǎn)

    1. 業(yè)務(wù)代碼侵入嚴(yán)重
      每個(gè)階段的數(shù)據(jù)處理都需要自己編寫(xiě)代碼來(lái)實(shí)現(xiàn)肩杈,事務(wù)框架無(wú)法自動(dòng)處理;
    2. 效率高
      不必對(duì)數(shù)據(jù)加全局鎖解寝;
  • TCC模式流程


    TCC模式.png
1. 第一階段
  TM開(kāi)啟全局事務(wù)扩然;
  執(zhí)行TCC參與者的Try方法時(shí),被TCC攔截器攔截编丘,在Try方法執(zhí)行前注冊(cè)分支事務(wù)到TC与学;在Try方法執(zhí)行后向TC報(bào)告分支事務(wù)的狀態(tài);
2. 第二階段
  TM通知TC執(zhí)行提交事務(wù)嘉抓,如果出現(xiàn)異常索守,則會(huì)通知TC執(zhí)行回滾事務(wù);
  TC收到TM提交或回滾的通知抑片,則會(huì)遍歷各個(gè)分支事務(wù)卵佛,逐個(gè)進(jìn)行提交或回滾;

5.AT/TCC模式適用場(chǎng)景

對(duì)于上述兩種模式進(jìn)行了簡(jiǎn)單的介紹敞斋,咱們來(lái)列舉下適用的場(chǎng)景

對(duì)比項(xiàng) AT模式 TCC模式
集成難度
數(shù)據(jù)庫(kù)改造 UNDO_LOG表 業(yè)務(wù)表增加狀態(tài)和鎖定的字段
實(shí)現(xiàn)機(jī)制 DataSource代理 自定義TCC方法實(shí)現(xiàn)
適用場(chǎng)景 遺留老的項(xiàng)目
自研所有場(chǎng)景項(xiàng)目
需要快速構(gòu)建分布式事務(wù)
新項(xiàng)目
高性能要求項(xiàng)目
復(fù)雜場(chǎng)景項(xiàng)目
金融支付場(chǎng)景

五. Seata實(shí)現(xiàn)2PC與傳統(tǒng)2PC區(qū)別

  • 層次架構(gòu)方面
    傳統(tǒng)2PC方案的RM實(shí)際上是在數(shù)據(jù)庫(kù)層截汪,RM本質(zhì)就是數(shù)據(jù)庫(kù)本身,通過(guò)XA協(xié)議實(shí)現(xiàn)植捎;
    而Seata的RM是以Jar包的形式作為中間件部署在應(yīng)用程序中的衙解;
  • 兩階段提交方面
    傳統(tǒng)2PC無(wú)論第二階段決議是提交還是回滾,事務(wù)資源的鎖都需要保持到第二階段才能釋放焰枢;
    而Seata在第一階段將本地事務(wù)提交蚓峦,從而省去了第二階段持鎖時(shí)間,整體提高了效率济锄;

相關(guān)參考文章:
Seata官網(wǎng)
Seata服務(wù)端搭建
Seata客服端集成(springcloud+nacos+seata)

歡迎大家留言暑椰,提出建議,感謝荐绝!

最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
  • 序言:七十年代末一汽,一起剝皮案震驚了整個(gè)濱河市,隨后出現(xiàn)的幾起案子低滩,更是在濱河造成了極大的恐慌召夹,老刑警劉巖,帶你破解...
    沈念sama閱讀 218,941評(píng)論 6 508
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件委造,死亡現(xiàn)場(chǎng)離奇詭異戳鹅,居然都是意外死亡,警方通過(guò)查閱死者的電腦和手機(jī)昏兆,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 93,397評(píng)論 3 395
  • 文/潘曉璐 我一進(jìn)店門(mén)枫虏,熙熙樓的掌柜王于貴愁眉苦臉地迎上來(lái),“玉大人爬虱,你說(shuō)我怎么就攤上這事隶债。” “怎么了跑筝?”我有些...
    開(kāi)封第一講書(shū)人閱讀 165,345評(píng)論 0 356
  • 文/不壞的土叔 我叫張陵死讹,是天一觀的道長(zhǎng)。 經(jīng)常有香客問(wèn)我曲梗,道長(zhǎng)赞警,這世上最難降的妖魔是什么妓忍? 我笑而不...
    開(kāi)封第一講書(shū)人閱讀 58,851評(píng)論 1 295
  • 正文 為了忘掉前任,我火速辦了婚禮愧旦,結(jié)果婚禮上世剖,老公的妹妹穿的比我還像新娘。我一直安慰自己笤虫,他們只是感情好旁瘫,可當(dāng)我...
    茶點(diǎn)故事閱讀 67,868評(píng)論 6 392
  • 文/花漫 我一把揭開(kāi)白布。 她就那樣靜靜地躺著琼蚯,像睡著了一般酬凳。 火紅的嫁衣襯著肌膚如雪。 梳的紋絲不亂的頭發(fā)上遭庶,一...
    開(kāi)封第一講書(shū)人閱讀 51,688評(píng)論 1 305
  • 那天宁仔,我揣著相機(jī)與錄音,去河邊找鬼峦睡。 笑死台诗,一個(gè)胖子當(dāng)著我的面吹牛,可吹牛的內(nèi)容都是我干的赐俗。 我是一名探鬼主播拉队,決...
    沈念sama閱讀 40,414評(píng)論 3 418
  • 文/蒼蘭香墨 我猛地睜開(kāi)眼,長(zhǎng)吁一口氣:“原來(lái)是場(chǎng)噩夢(mèng)啊……” “哼阻逮!你這毒婦竟也來(lái)了粱快?” 一聲冷哼從身側(cè)響起,我...
    開(kāi)封第一講書(shū)人閱讀 39,319評(píng)論 0 276
  • 序言:老撾萬(wàn)榮一對(duì)情侶失蹤叔扼,失蹤者是張志新(化名)和其女友劉穎事哭,沒(méi)想到半個(gè)月后,有當(dāng)?shù)厝嗽跇?shù)林里發(fā)現(xiàn)了一具尸體瓜富,經(jīng)...
    沈念sama閱讀 45,775評(píng)論 1 315
  • 正文 獨(dú)居荒郊野嶺守林人離奇死亡鳍咱,尸身上長(zhǎng)有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點(diǎn)故事閱讀 37,945評(píng)論 3 336
  • 正文 我和宋清朗相戀三年,在試婚紗的時(shí)候發(fā)現(xiàn)自己被綠了与柑。 大學(xué)時(shí)的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片谤辜。...
    茶點(diǎn)故事閱讀 40,096評(píng)論 1 350
  • 序言:一個(gè)原本活蹦亂跳的男人離奇死亡,死狀恐怖价捧,靈堂內(nèi)的尸體忽然破棺而出丑念,到底是詐尸還是另有隱情,我是刑警寧澤结蟋,帶...
    沈念sama閱讀 35,789評(píng)論 5 346
  • 正文 年R本政府宣布脯倚,位于F島的核電站,受9級(jí)特大地震影響嵌屎,放射性物質(zhì)發(fā)生泄漏推正。R本人自食惡果不足惜恍涂,卻給世界環(huán)境...
    茶點(diǎn)故事閱讀 41,437評(píng)論 3 331
  • 文/蒙蒙 一、第九天 我趴在偏房一處隱蔽的房頂上張望植榕。 院中可真熱鬧乳丰,春花似錦、人聲如沸内贮。這莊子的主人今日做“春日...
    開(kāi)封第一講書(shū)人閱讀 31,993評(píng)論 0 22
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽(yáng)夜郁。三九已至,卻和暖如春粘勒,著一層夾襖步出監(jiān)牢的瞬間竞端,已是汗流浹背。 一陣腳步聲響...
    開(kāi)封第一講書(shū)人閱讀 33,107評(píng)論 1 271
  • 我被黑心中介騙來(lái)泰國(guó)打工庙睡, 沒(méi)想到剛下飛機(jī)就差點(diǎn)兒被人妖公主榨干…… 1. 我叫王不留事富,地道東北人。 一個(gè)月前我還...
    沈念sama閱讀 48,308評(píng)論 3 372
  • 正文 我出身青樓乘陪,卻偏偏與公主長(zhǎng)得像统台,于是被迫代替她去往敵國(guó)和親。 傳聞我的和親對(duì)象是個(gè)殘疾皇子啡邑,可洞房花燭夜當(dāng)晚...
    茶點(diǎn)故事閱讀 45,037評(píng)論 2 355

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