Seata集成Mybatis-Plus解決多數(shù)據(jù)源事務問題

更新時間：2023年11月01日 14:39:41 作者：吳名氏.

當進行業(yè)務操作時,訂單發(fā)生異常 ,進行了回滾操作,因為在不同的數(shù)據(jù)庫實例中,余額卻扣除成功,此時發(fā)現(xiàn)數(shù)據(jù)不一致問題,本文給大家介紹Seata集成Mybatis-Plus解決多數(shù)據(jù)源事務問題,感興趣的朋友一起看看吧

1 前言

在使用單個服務，多數(shù)據(jù)源時，也存在分布式事務問題。

當單體系統(tǒng)需要訪問多個數(shù)據(jù)庫（實例）時就會產(chǎn)生分布式事務。比如：用戶信息和訂單信息分別在兩個MySQL實例存儲，用戶管理系統(tǒng)刪除用戶信息，需要分別刪除用戶信息及用戶的訂單信息，由于數(shù)據(jù)分布在不同的數(shù)據(jù)實例，需要通過不同的數(shù)據(jù)庫鏈接去操作數(shù)據(jù)，此時產(chǎn)生分布式事務。簡言之：跨數(shù)據(jù)庫實例產(chǎn)生分布式事務。

在這里插入圖片描述

2 問題場景

參考此文檔搭建一個多數(shù)據(jù)源項目Mybatis-Plus入門系列(19) -多數(shù)據(jù)源使用詳解。

在插入訂單數(shù)據(jù)時，模擬一個異常：

    @Override
    @DS("db_order")
    @Transactional
    public void insertOrder() {
        // 插入訂單
        OrderTbl orderTbl = new OrderTbl();
        orderTbl.setUserId("12");
        orderTbl.setCommodityCode("IPHONE 13");
        orderTbl.setCount(1);
        orderTblMapper.insert(orderTbl);
        int i = 5 / 0;
    }

當進行業(yè)務操作時，訂單發(fā)生異常，進行了回滾操作，因為在不同的數(shù)據(jù)庫實例中，余額卻扣除成功，此時發(fā)現(xiàn)數(shù)據(jù)不一致問題。

3 使用Seata 解決多數(shù)據(jù)源事務問題

3.1 集成Nacos Seata

參考該系列，給當前服務添加Nacos Seata 相關依賴，并啟動Nacos Seata 。

3.2 多數(shù)據(jù)源集成Seata

多數(shù)據(jù)源集成Seata 時，主要是需要修改一下幾個配置即可。

多數(shù)據(jù)源中，開啟分布式事務，設置事務模式：

  datasource:
    # 多數(shù)據(jù)源
    dynamic:
      # 省略其他 
      # 開啟分布式事務
      seata: true
      # 事務模式 為AT
      seata-mode: AT

seata 中，關閉數(shù)據(jù)源自動代理

seata:
  # 是否開啟spring-boot自動裝配，默認true，包括數(shù)據(jù)源的自動代理以及GlobalTransactionScanner初始化
  enabled: true
  # 是否開啟數(shù)據(jù)源自動代理，默認開啟
  enable-auto-data-source-proxy: false

3.3 測試

添加@GlobalTransactional注解。

    @GlobalTransactional
    @GetMapping("/test")
    public Object test() throws InterruptedException {
        accountTblService.reduceMoney();
        orderTblService.insertOrder();
        return "執(zhí)行完畢！";
    }

測試發(fā)現(xiàn)，異常時，余額和訂單服務都進行了回滾，集成成功。