什麼是TCC,TCC是Try、Confirm、Cancel三個詞語的縮寫,最早是由 Pat Helland 於 2007 年發表的一篇名為《Life beyond Distributed Transactions:an Apostate’s Opinion》的論文提出。
TCC分為3個階段
TCC分散式事務裡,有3個角色,與經典的XA分散式事務一樣:
如果我們要進行一個類似於銀行跨行轉賬的業務,轉出(TransOut)和轉入(TransIn)分別在不同的微服務裡,一個成功完成的TCC事務典型的時序圖如下:
下面我們進行一個TCC事務的具體開發
目前可用於TCC的開源框架,主要為Java語言,其中以seata為代表。我們的例子採用nodejs,使用的分散式事務框架為dtm,它對分散式事務的支援非常優雅。下面來詳細講解TCC的組成
下面我們來編寫具體的Try/Confirm/Cancel的處理常式
$vega->handleFunc('/api/TransOutTry', function (Mix\Vega\Context $ctx) { var_dump('TransOutTry', $ctx->request->getQueryParams(), $ctx->request->getParsedBody()); $ctx->JSON(200, ['result' => 'SUCCESS']);})->methods('POST');$vega->handleFunc('/api/TransOutConfirm', function (Mix\Vega\Context $ctx) { var_dump('TransOutConfirm', $ctx->request->getQueryParams(), $ctx->request->getParsedBody()); $ctx->JSON(200, ['result' => 'SUCCESS']);})->methods('POST');$vega->handleFunc('/api/TransOutCancel', function (Mix\Vega\Context $ctx) { var_dump('TransOutCancel', $ctx->request->getQueryParams(), $ctx->request->getParsedBody()); $ctx->JSON(200, ['result' => 'SUCCESS']);})->methods('POST');$vega->handleFunc('/api/TransInTry', function (Mix\Vega\Context $ctx) { var_dump('TransInTry', $ctx->request->getQueryParams(), $ctx->request->getParsedBody()); $ctx->JSON(200, ['result' => 'SUCCESS']);})->methods('POST');$vega->handleFunc('/api/TransInConfirm', function (Mix\Vega\Context $ctx) { var_dump('TransInConfirm', $ctx->request->getQueryParams(), $ctx->request->getParsedBody()); $ctx->JSON(200, ['result' => 'SUCCESS']);})->methods('POST');$vega->handleFunc('/api/TransInCancel', function (Mix\Vega\Context $ctx) { var_dump('TransInCancel', $ctx->request->getQueryParams(), $ctx->request->getParsedBody()); $ctx->JSON(200, ['result' => 'SUCCESS']);})->methods('POST');
到此各個子事務的處理常式已經OK了,然後是開啟TCC事務,進行分支呼叫
Dtmcli\tccGlobalTransaction($dtm, function ($tcc) use ($svc) { /** @var Dtmcli\Tcc $tcc */ $req = ['amount' => 30]; $tcc->callBranch($req, $svc . '/TransOutTry', $svc . '/TransOutConfirm', $svc . '/TransOutCancel'); $tcc->callBranch($req, $svc . '/TransInTry', $svc . '/TransInConfirm', $svc . '/TransInCancel'); });
至此,一個完整的TCC分散式事務編寫完成。
如果您想要完整執行一個成功的範例,那麼參考這個例子yedf/dtmcli-php-sample,將它執行起來非常簡單
# 部署啟動dtm# 需要docker版本18以上git clone https://github.com/yedf/dtmcd dtm docker-compose up# 另起一個命令列https://github.com/yedf/dtmcli-php-sample.gitcd dtmcli-php-sample composer installphp demo.php start
假如銀行將金額準備轉入使用者2時,發現使用者2的賬戶異常,返回失敗,會怎麼樣?我們可以讓TransIn返回失敗來模擬這種情況
$vega->handleFunc('/api/TransInTry', function (Mix\Vega\Context $ctx) { var_dump('TransInTry', $ctx->request->getQueryParams(), $ctx->request->getParsedBody()); $ctx->JSON(200, ['result' => 'FAILURE']);})->methods('POST');
我們給出事務失敗互動的時序圖
這個跟成功的TCC差別就在於,當某個子事務返回失敗後,後續就回滾全域性事務,呼叫各個子事務的Cancel操作,保證全域性事務全部回滾。
在TCC事務模式上,有不少的讀者會問,如果Confirm/Cancel失敗會怎麼樣?這是一個好問題,代表您正在深入思考TCC事務模式。第一種情況是臨時失敗,例如網路故障、應用或資料庫宕機,這類錯誤進行重試,最後會返回成功;另一種情況為業務失敗,按照TCC的協定,第一階段鎖定資源,保證足夠的資源能夠讓Confirm/Cancel執行,也就是說,程式邏輯上,Confirm/Cancel是不允許返回業務失敗的,如果出現業務失敗,那麼是bug,需要開發人員手動修復bug。
在這篇文章裡,我們介紹了TCC的理論知識,也通過一個例子,完整給出了編寫一個TCC事務的過程,涵蓋了正常成功完成,以及成功回滾的情況。相信讀者通過這邊文章,對TCC已經有了深入的理解。
關於分散式事務更多更全面的知識,請參考《》
文中使用的例子節選自yedf/dtm(https://github.com/yedf/dtm),它支援多種事務模式:TCC、SAGA、XA、事務訊息 跨語言支援,已支援 golang、python、Java、PHP、nodejs等語言的使用者端,參考各語言SDK(https://dtm.pub/summary/code.html#go)。提供子事務屏障功能,優雅解決冪等、懸掛、空補償等問題。
閱讀完此篇乾貨,歡迎大家存取github.com/yedf/dtm專案,給顆星星支援!
以上就是手把手教你用PHP完成一個分散式事務TCC的詳細內容,更多請關注TW511.COM其它相關文章!