日韩无码专区无码一级三级片|91人人爱网站中日韩无码电影|厨房大战丰满熟妇|AV高清无码在线免费观看|另类AV日韩少妇熟女|中文日本大黄一级黄色片|色情在线视频免费|亚洲成人特黄a片|黄片wwwav色图欧美|欧亚乱色一区二区三区

RELATEED CONSULTING
相關(guān)咨詢(xún)
選擇下列產(chǎn)品馬上在線溝通
服務(wù)時(shí)間：8:30-17:00
你可能遇到了下面的問(wèn)題
關(guān)閉右側(cè)工具欄

新聞中心

這里有您想知道的互聯(lián)網(wǎng)營(yíng)銷(xiāo)解決方案
用Node輕松完成一個(gè)分布式事務(wù)TCC，保姆級(jí)教程

用 Node 輕松完成一個(gè)分布式事務(wù) TCC，保姆級(jí)教程

作者：葉東富 2021-10-11 09:24:14

開(kāi)發(fā)

前端

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

成都創(chuàng)新互聯(lián)專(zhuān)注為客戶(hù)提供全方位的互聯(lián)網(wǎng)綜合服務(wù)，包含不限于成都做網(wǎng)站、網(wǎng)站制作、榆樹(shù)網(wǎng)絡(luò)推廣、小程序設(shè)計(jì)、榆樹(shù)網(wǎng)絡(luò)營(yíng)銷(xiāo)、榆樹(shù)企業(yè)策劃、榆樹(shù)品牌公關(guān)、搜索引擎seo、人物專(zhuān)訪、企業(yè)宣傳片、企業(yè)代運(yùn)營(yíng)等，從售前售中售后，我們都將竭誠(chéng)為您服務(wù)，您的肯定，是我們最大的嘉獎(jiǎng)；成都創(chuàng)新互聯(lián)為所有大學(xué)生創(chuàng)業(yè)者提供榆樹(shù)建站搭建服務(wù)，24小時(shí)服務(wù)熱線：18980820575，官方網(wǎng)址：www.cdcxhl.com

[[428021]]

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

TCC組成

TCC分為3個(gè)階段

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

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

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

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

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

  • RM/資源管理器，負(fù)責(zé)分支事務(wù)各項(xiàng)資源的管理

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

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

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

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

TCC實(shí)踐

下面我們進(jìn)行一個(gè)TCC事務(wù)的具體開(kāi)發(fā)

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

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

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

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

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

至此，一個(gè)完整的TCC分布式事務(wù)編寫(xiě)完成。

如果您想要完整運(yùn)行一個(gè)成功的示例，那么參考這個(gè)例子yedf/dtmcli-node-sample，將它運(yùn)行起來(lái)非常簡(jiǎn)單

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

TCC的回滾

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

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

小結(jié)

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

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

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

閱讀完此篇干貨，歡迎大家訪問(wèn)https://github.com/yedf/dtm項(xiàng)目，給顆星星支持！


本文名稱(chēng)：用Node輕松完成一個(gè)分布式事務(wù)TCC，保姆級(jí)教程
文章地址：http://www.5511xx.com/article/dpjdcoe.html