成人免费xxxxx在线视频软件_久久精品久久久_亚洲国产精品久久久_天天色天天色_亚洲人成一区_欧美一级欧美三级在线观看

用 Node 輕松完成一個分布式事務(wù) TCC,保姆級教程

開發(fā) 前端 分布式
什么是TCC,TCC是Try、Confirm、Cancel三個詞語的縮寫,最早是由 Pat Helland 于 2007 年發(fā)表的一篇名為《Life beyond Distributed Transactions:an Apostate’s Opinion》的論文提出。

[[428021]]

 什么是TCC,TCC是Try、Confirm、Cancel三個詞語的縮寫,最早是由 Pat Helland 于 2007 年發(fā)表的一篇名為《Life beyond Distributed Transactions:an Apostate’s Opinion》的論文提出。

TCC組成

TCC分為3個階段

  • Try 階段:嘗試執(zhí)行,完成所有業(yè)務(wù)檢查(一致性), 預(yù)留必須業(yè)務(wù)資源(準隔離性)

  • Confirm 階段:如果所有分支的Try都成功了,則走到Confirm階段。Confirm真正執(zhí)行業(yè)務(wù),不作任何業(yè)務(wù)檢查,只使用 Try 階段預(yù)留的業(yè)務(wù)資源

  • Cancel 階段:如果所有分支的Try有一個失敗了,則走到Cancel階段。Cancel釋放 Try 階段預(yù)留的業(yè)務(wù)資源。

TCC分布式事務(wù)里,有3個角色,與經(jīng)典的XA分布式事務(wù)一樣:

  • AP/應(yīng)用程序,發(fā)起全局事務(wù),定義全局事務(wù)包含哪些事務(wù)分支

  • RM/資源管理器,負責分支事務(wù)各項資源的管理

  • TM/事務(wù)管理器,負責協(xié)調(diào)全局事務(wù)的正確執(zhí)行,包括Confirm,Cancel的執(zhí)行,并處理網(wǎng)絡(luò)異常

如果我們要進行一個類似于銀行跨行轉(zhuǎn)賬的業(yè)務(wù),轉(zhuǎn)出(TransOut)和轉(zhuǎn)入(TransIn)分別在不同的微服務(wù)里,一個成功完成的TCC事務(wù)典型的時序圖如下:

TCC網(wǎng)絡(luò)異常

TCC在整個全局事務(wù)的過程中,可能發(fā)生各類網(wǎng)絡(luò)異常情況,典型的是空回滾、冪等、懸掛,由于TCC的異常情況,和SAGA、可靠消息等事務(wù)模式有相近的地方,因此我們把所有異常的解決方案統(tǒng)統(tǒng)放在這篇文章《分布式事務(wù)最經(jīng)典的七種解決方案》的子事務(wù)屏障環(huán)節(jié)進行講解

TCC實踐

下面我們進行一個TCC事務(wù)的具體開發(fā)

目前可用于TCC的開源框架,主要為Java語言,其中以seata為代表。我們的例子采用nodejs,使用的分布式事務(wù)框架為dtm,它對分布式事務(wù)的支持非常優(yōu)雅。下面來詳細講解TCC的組成

下面我們來編寫具體的Try/Confirm/Cancel的處理函數(shù)

  1. router.post('/api/TransOutTry', (ctx, next) => { 
  2.   console.log("TransOutTry"
  3.   ctx.body = { result: "SUCCESS" } 
  4. }).post('/api/TransOutConfirm', (ctx, next) => { 
  5.   console.log("TransOutConfirm"
  6.   ctx.body = { result: "SUCCESS" } 
  7. }).post('/api/TransOutCancel', (ctx, next) => { 
  8.   console.log("TransOutCancel"
  9.   ctx.body = { result: "SUCCESS" } 
  10. }).post('/api/TransInTry', (ctx, next) => { 
  11.   console.log("TransInTry"
  12.   ctx.body = { result: "SUCCESS" } 
  13. }).post('/api/TransInConfirm', (ctx, next) => { 
  14.   console.log("TransInConfirm"
  15.   ctx.body = { result: "SUCCESS" } 
  16. }).post('/api/TransInCancel', (ctx, next) => { 
  17.   console.log("TransInCancel"
  18.   ctx.body = { result: "SUCCESS" } 
  19. }) 

到此各個子事務(wù)的處理函數(shù)已經(jīng)OK了,然后是開啟TCC事務(wù),進行分支調(diào)用

  1. async function FireTcc() { 
  2.   let dtm = "http://localhost:8080/api/dtmsvr" // dtm服務(wù)地址 
  3.   let svc = "http://localhost:4005/api" // 本地服務(wù)前綴 
  4.   // 開啟一個tcc事務(wù),第二個參數(shù)里面,寫全局事務(wù)的邏輯 
  5.   await dtmcli.tccGlobalTransaction(dtm, async (t) => { 
  6.     let req = { amount: 30 } // 子事務(wù)需要的負荷 
  7.     console.log("calling trans out"
  8.     // 注冊事務(wù)分支,并調(diào)用分支中的Try 
  9.     await t.callBranch(req, svc + "/TransOutTry", svc + "/TransOutConfirm", svc + "/TransOutCancel"
  10.     console.log("calling trans in"
  11.     // 注冊事務(wù)分支,并調(diào)用分支中的Try 
  12.     await t.callBranch(req, svc + "/TransInTry", svc + "/TransInConfirm", svc + "/TransInCancel"
  13.   }) 

至此,一個完整的TCC分布式事務(wù)編寫完成。

如果您想要完整運行一個成功的示例,那么參考這個例子yedf/dtmcli-node-sample,將它運行起來非常簡單

  1. # 部署啟動dtm 
  2. # 需要docker版本18以上 
  3. git clone https://github.com/yedf/dtm 
  4. cd dtm 
  5. docker-compose up 
  6.  
  7. # 另起一個命令行 
  8. git clone https://github.com/yedf/dtmcli-node-sample 
  9. cd dtmcli-node-sample 
  10. npm install 
  11. node . 

TCC的回滾

假如銀行將金額準備轉(zhuǎn)入用戶2時,發(fā)現(xiàn)用戶2的賬戶異常,返回失敗,會怎么樣?我們給出事務(wù)失敗交互的時序圖

這個跟成功的TCC差別就在于,當某個子事務(wù)返回失敗后,后續(xù)就回滾全局事務(wù),調(diào)用各個子事務(wù)的Cancel操作,保證全局事務(wù)全部回滾。

小結(jié)

在這篇文章里,我們介紹了TCC的理論知識,也通過一個例子,完整給出了編寫一個TCC事務(wù)的過程,涵蓋了正常成功完成,以及成功回滾的情況。相信讀者通過這邊文章,對TCC已經(jīng)有了深入的理解。

關(guān)于分布式事務(wù)更多更全面的知識,請參考《分布式事務(wù)最經(jīng)典的七種解決方案》

文中使用的例子節(jié)選自yedf/dtm,支持多種事務(wù)模式:TCC、SAGA、XA、事務(wù)消息 跨語言支持,已支持 golang、python、Java、PHP、nodejs等語言的客戶端,參考各語言SDK。提供子事務(wù)屏障功能,優(yōu)雅解決冪等、懸掛、空補償?shù)葐栴}。

閱讀完此篇干貨,歡迎大家訪問https://github.com/yedf/dtm項目,給顆星星支持!

責任編輯:張燕妮 來源: 別枝驚鵲
相關(guān)推薦

2021-10-25 10:33:29

Python 開發(fā)編程語言

2021-09-14 13:55:15

Go開發(fā)分布式

2021-09-07 09:26:13

Python 開發(fā)編程語言

2024-06-04 10:58:30

2022-06-27 08:36:27

分布式事務(wù)XA規(guī)范

2024-06-12 09:06:48

2025-04-30 10:44:02

2024-10-09 14:14:07

2021-06-08 12:46:27

分布式阿里TCC

2022-07-20 06:55:10

TCC分布式事務(wù)微服務(wù)

2025-05-07 00:10:00

分布式事務(wù)TCC模式

2019-12-27 16:00:56

分布式事務(wù)框架Java

2024-06-28 09:07:19

2024-12-09 09:35:00

2022-06-27 08:21:05

Seata分布式事務(wù)微服務(wù)

2018-11-23 09:25:00

TCC分布式事務(wù)

2022-01-12 10:02:02

TCC模式 Seata

2022-09-29 08:28:57

SpringRedis分布式

2022-09-22 13:28:34

Redis分布式鎖

2017-07-26 15:08:05

大數(shù)據(jù)分布式事務(wù)
點贊
收藏

51CTO技術(shù)棧公眾號

主站蜘蛛池模板: 亚洲日韩欧美一区二区在线 | 91精品导航 | 亚洲欧美在线观看 | 99精品久久久 | 嫩草视频网站 | 国产目拍亚洲精品99久久精品 | 成人免费在线观看视频 | 91麻豆精品国产91久久久更新资源速度超快 | 欧美精品一区在线观看 | 日操夜操 | 天堂中文资源在线 | 久久夜视频| www.国产一区| 国产自产c区 | 久久男人 | 色欧美综合 | 久久久免费精品 | 色一阁| 伊人一区 | 91精品久久久久久久久中文字幕 | 女同av亚洲女人天堂 | 日本一区不卡 | 欧美在线色 | 国产一级片| 亚洲成av| 99精品国自产在线 | 婷婷色国产偷v国产偷v小说 | 亚洲国产一区二区视频 | 一区视频| 日韩在线视频观看 | 欧美一区二区三区 | 美女131mm久久爽爽免费 | 欧美日韩综合精品 | 天天人人精品 | 国产激情视频在线观看 | 亚洲一区亚洲二区 | 久久综合欧美 | 美日韩精品| 乱码av午夜噜噜噜噜动漫 | 久久看精品 | 精品国产99 |