當前位置：首頁 > 科技 > 軟件

借助Nacos高效配置與實踐Seata事務的TCC模式

來源：責編：時間：2024-02-01 12:45:10 214觀看

導讀實現TCC 模式TCC模式與AT模式非常相似，每階段都是獨立事務，不同的是TCC通過人工編碼來實現數據恢復。需要實現三個方法：Try：資源的檢測和預留；Confirm：完成資源操作業務；要求 Try 成功 Confirm 一定要能成功。Cancel：預留資源

實現

TCC 模式

TCC模式與AT模式非常相似，每階段都是獨立事務，不同的是TCC通過人工編碼來實現數據恢復。需要實現三個方法：

Try：資源的檢測和預留；
Confirm：完成資源操作業務；要求 Try 成功 Confirm 一定要能成功。
Cancel：預留資源釋放，可以理解為try的反向操作。

流程分析

圖片

階段一（Try）：檢查余額是否充足，如果充足則凍結金額增加30元，可用余額扣除30

圖片

此時，總金額 = 凍結金額 + 可用金額，數量依然是100不變，事務直接提交無需等待其它事務。

階段二（Confirm) ：假如要提交，則凍結金額扣減30

圖片

確認可以提交，不過之前可用金額已經扣減過了，這里只要清除凍結金額就好了，此時，總金額 = 凍結金額 + 可用金額 = 0 + 70 = 70

階段二（Cancel）：如果要回滾，則凍結金額扣減30，可用余額增加30

圖片

需要回滾，那么就要釋放凍結金額，恢復可用金額

Seata的TCC模型

圖片

代碼樣例

配置和依賴參考之前《利用Nacos實現Seata事務模式（XA與AT）的快速配置與靈活切換》即可

bank3:

聲明TCC接口@LocalTCCpublic interface AccountInTcc {    @TwoPhaseBusinessAction(name = "prepareDeductMoney", commitMethod = "commitDeductMoney", rollbackMethod = "rollbackDeductMoney")    boolean prepareDeductMoney(BusinessActionContext businessActionContext,                               @BusinessActionContextParameter(paramName = "accountNo")String accountNo,                               @BusinessActionContextParameter(paramName = "amount")Double amount);    /**     * 提交扣款     * 二階段confirm確認方法、可以另命名，但要保證與commitMethod一致     */    boolean commitDeductMoney(BusinessActionContext businessActionContext);    /**     * 回滾扣款     * 二階段回滾方法，要保證與rollbackMethod一致     */    boolean rollbackDeductMoney(BusinessActionContext businessActionContext);}

具體實現：

@Componentpublic class AccountInTccImpl implements AccountInTcc {    @Autowired    private AccountInfoMapper accountInfoMapper;    @Transactional    @Override    public boolean prepareDeductMoney(BusinessActionContext businessActionContext, String accountNo, Double amount) {        String xid = businessActionContext.getXid();        // 冪等性判斷        if (TccActionResultWrap.hasPrepareResult(xid)) {            return true;        }        // 避免空懸掛，已經執行過回滾了就不能再預留資源        if (TccActionResultWrap.hasRollbackResult(xid) || TccActionResultWrap.hasCommitResult(xid)) {            return false;        }        // 預留資源        boolean result = accountInfoMapper.prepareDeductMoney(accountNo,amount) > 0;        // 記錄執行結果，以便回滾時判斷是否是空回滾        TccActionResultWrap.prepareSuccess(xid);        System.out.println("============prepare==============");        return result;    }    // 保證提交邏輯的原子性    @Transactional    @Override    public boolean commitDeductMoney(BusinessActionContext businessActionContext) {        String xid = businessActionContext.getXid();        // 冪等性判斷        if (TccActionResultWrap.hasCommitResult(xid)) {            return true;        }        Map<String, Object> actionContext = businessActionContext.getActionContext();        String accountNo = (String) actionContext.get("accountNo");        BigDecimal amount = (BigDecimal) actionContext.get("amount");        // 執行提交操作，扣除預留款        boolean result = accountInfoMapper.commitDeductMoney(accountNo,amount.doubleValue()) > 0;        // 清除預留結果        TccActionResultWrap.removePrepareResult(xid);        // 設置提交結果        TccActionResultWrap.commitSuccess(xid);        System.out.println("============commit==============");        return result;    }    @Transactional    @Override    public boolean rollbackDeductMoney(BusinessActionContext businessActionContext) {        String xid = businessActionContext.getXid();        // 冪等性判斷        if (TccActionResultWrap.hasRollbackResult(xid)) {            return true;        }        // 沒有預留資源結果，回滾不做任何處理；        if (!TccActionResultWrap.hasPrepareResult(xid)) {            // 設置回滾結果，防止空回滾            TccActionResultWrap.rollbackSuccess(xid);            return true;        }        // 執行回滾        Map<String, Object> actionContext = businessActionContext.getActionContext();        String accountNo = (String) actionContext.get("accountNo");        BigDecimal amount = (BigDecimal) actionContext.get("amount");        boolean result = accountInfoMapper.rollbackDeductMoney(accountNo,amount.doubleValue()) > 0;        // 清除預留結果        TccActionResultWrap.removePrepareResult(xid);        // 設置回滾結果        TccActionResultWrap.rollbackSuccess(xid);        System.out.println("============rollback==============");        return result;    }}

業務層：

@Autowired  private AccountInTcc accountInTcc;  @Override  public Boolean deductMoney(String accountNo, Double amount) {      return accountInTcc.prepareDeductMoney(null,accountNo,amount);  }

參數中的BusinessActionContext不需要開發人員自己傳遞，直接給null即可，Seata會自動處理。

mapper:

@Update("update account_info set account_balance = account_balance - #{amount}, frozen_money = frozen_money + #{amount} where account_no = #{accountNo} and account_balance >= #{amount}")    int prepareDeductMoney(@Param("accountNo") String accountNo, @Param("amount") Double amount);    @Update("update account_info set frozen_money = frozen_money - #{amount} where account_no = #{accountNo}")    int commitDeductMoney(@Param("accountNo") String accountNo, @Param("amount") Double amount);    @Update("update account_info set account_balance = account_balance + #{amount}, frozen_money = frozen_money - #{amount} where account_no = #{accountNo}")    int rollbackDeductMoney(@Param("accountNo") String accountNo, @Param("amount") Double amount);

bank4服務調用：

@GlobalTransactional    @Override    public Boolean addMoney(String accountNo, Double amount) {        String result = bank3Client.deduct(amount);        if("true".equalsIgnoreCase(result)){            Boolean flag = baseMapper.addMoney(accountNo,amount) > 0;            if(amount != 30 ) throw new RuntimeException("bank4 make exception amount != 30");            return flag;        }        return false;    }

TCC的優點：

一階段完成直接提交事務，釋放數據庫資源，性能好
相比AT模型，無需生成快照，無需使用全局鎖，性能最強
不依賴數據庫事務，而是依賴補償操作，可以用于非事務型數據庫

TCC的缺點：

有代碼侵入，需要人為編寫try、Confirm和Cancel接口，太麻煩
軟狀態，事務是最終一致
需要考慮Confirm和Cancel的失敗情況，做好冪等處理

空回滾：當某分支事務的try階段阻塞時，可能導致全局事務超時而觸發二階段的cancel操作。在未執行try操作時先執行了cancel操作，這時cancel不能做回滾，就是空回滾
業務懸掛：對于已經空回滾的業務，之前被阻塞的try操作恢復，繼續執行try，就永遠不可能confirm或cancel ，事務一直處于中間狀態，這就是業務懸掛。

圖片

執行cancel操作時，應當判斷try是否已經執行，如果尚未執行，則應該空回滾。
執行try操作時，應當判斷cancel是否已經執行過了，如果已經執行，應當阻止空回滾后的try操作，避免懸掛。

本文鏈接：http://www.www897cc.com/showinfo-26-70394-0.html借助Nacos高效配置與實踐Seata事務的TCC模式

聲明：本網頁內容旨在傳播知識，若有侵權等問題請及時與本網聯系，我們將在第一時間刪除處理。郵件：2376512515@qq.com

上一篇： PHP 高性能的事件循環庫 Revolt

下一篇： Vue3問題：如何實現頁面引導提示？

標簽：

熱門焦點

7月安卓手機性能榜：紅魔8S Pro再奪榜首

7月份的手機市場風平浪靜，除了紅魔和努比亞帶來了兩款搭載驍龍8Gen2領先版處理器的新機之外，別的也想不到有什么新品了，這也正常，通常6月7月都是手機廠商修整的時間，進入8月份之
跑分安卓第一！Redmi K60至尊版8月發布！盧偉冰：目標年度性能之王

8月5日消息，Redmi K60至尊版將于8月發布，在此前舉行的戰略發布會上，官方該機將搭載搭載天璣9200+處理器，安兔兔V10跑分超177萬分，是目前安卓陣營最高的分數
從 Pulsar Client 的原理到它的監控面板

背景前段時間業務團隊偶爾會碰到一些 Pulsar 使用的問題，比如消息阻塞不消費了、生產者消息發送緩慢等各種問題。雖然我們有個監控頁面可以根據 topic 維度查看他的發送狀態，
不容錯過的MSBuild技巧，必備用法詳解和實踐指南

一、MSBuild簡介MSBuild是一種基于XML的構建引擎，用于在.NET Framework和.NET Core應用程序中自動化構建過程。它是Visual Studio的構建引擎，可在命令行或其他構建工具中使用
猿輔導與新東方的兩種“歸途”

作者｜卓心月出品｜零態LT（ID：LingTai_LT）如何成為一家偉大企業？答案一定是對“勢”的把握，這其中最關鍵的當屬對企業戰略的制定，且能夠站在未來看現在，即使這其中的
疑似小米14外觀設計圖曝光：后置相機模組變化不大

下半年的大幕已經開啟，而誰將成為下半年手機圈的主角就成為了大家關注的焦點，其中被傳有望拿下新一代驍龍8 Gen3旗艦芯片的小米14系列更是備受大家矚
超級標準版旗艦！iQOO 11S全球首發iQOO超算獨顯芯片

上半年已接近尾聲，截至目前各大品牌旗下的頂級旗艦都已悉數亮相，而下半年即將推出的頂級旗艦已經成為了數碼圈爆料的主流，其中就包括全新的iQOO 11S系
iQOO Neo8 Pro搶先上架：首發天璣9200+ 安卓性能之王

經過了一段時間的密集爆料，昨日iQOO官方如期對外宣布：將于5月23日推出全新的iQOO Neo8系列新品，官方稱這是一款擁有旗艦級性能調校的作品。隨著發布時
DRAM存儲器10月價格下跌，NAND閃存本月價格與上月持平

10月30日，據韓國媒體消息，自今年年初以來一直在上漲的 DRAM 存儲器的交易價格僅在本月就下跌了近 10％，此次是全年首次降價，而NAND 閃存本月價格與上月持平。市

日韩成人免费在线_国产成人一二_精品国产免费人成电影在线观..._日本一区二区三区久久久久久久久不

借助Nacos高效配置與實踐Seata事務的TCC模式

實現

TCC 模式

流程分析

Seata的TCC模型

代碼樣例

7月安卓手機性能榜：紅魔8S Pro再奪榜首

跑分安卓第一！Redmi K60至尊版8月發布！盧偉冰：目標年度性能之王

從 Pulsar Client 的原理到它的監控面板

不容錯過的MSBuild技巧，必備用法詳解和實踐指南

猿輔導與新東方的兩種“歸途”

疑似小米14外觀設計圖曝光：后置相機模組變化不大

超級標準版旗艦！iQOO 11S全球首發iQOO超算獨顯芯片

iQOO Neo8 Pro搶先上架：首發天璣9200+ 安卓性能之王

DRAM存儲器10月價格下跌，NAND閃存本月價格與上月持平

最新推薦

猜你喜歡

熱門推薦

相關資訊