SpringCloud Alibaba(六) - Seata 分布式事務鎖-有解無憂

1、Seata 簡介

1.1 Seata是什么

Seata 是一款開源的分布式事務解決方案，致力于提供高性能和簡單易用的分布式事務服務，Seata 將為用戶提供了 AT、TCC、SAGA 和 XA 事務模式，為用戶打造一站式的分布式解決方案，AT模式是阿里首推的模式，阿里云上有商用版本的GTS（Global Transaction Service 全域事務服務），

1.2 Seata的三大角色

在Seata的架構中，一共有三大角色：

TC（Transaction Coordinator）- 事務協調者

維護全域和分支事務的狀態，驅動全域事務提交或回滾，

TM（Transaction Manager）- 事務管理器

定義全域事務的范圍：開始全域事務、提交或回滾全域事務

RM（Resource Manager）- 資源管理器

管理分支事務處理的資源，與TC交談以注冊分支事務和報告分支事務的狀態，并驅動分支事務提交或回滾，

其中，TC為單獨部署的Server服務端，TM和RM為嵌入到應用中的Client客戶端，

1.3 一個分布式事務的生命周期

博客參考：https://blog.csdn.net/qq_41910252/article/details/122517092

2、安裝seata

2.1 下載安裝包和原始碼

下載地址：https://github.com/seata/seata/releases

2.2 修改registry,conf 上傳組態檔到nacos

2.2.1 復制 registry 檔案

2.2.2 修改配置

2.3 上傳到nacos的配置串列

 使用git視窗# sh nacos-config.sh -h localhost -p 8848

資料庫8的修改一下driverClassName

加時區：

2.3 修改config.txt 啟動seate 注冊到nacos

2.3.1 復制config.txt

2.3.2 修改config.txt

2.3.3 創建seata資料庫

2.3.4 啟動seata

seata-server.bat -h 127.0.0.1 -p 8091

3、專案演示

3.1 模塊說明

3.2 依賴

<!-- nacso注冊，feign 依賴不再贅述 -->
<!--   seata     -->
<dependency>
    <groupId>com.alibaba.cloud</groupId>
    <artifactId>spring-cloud-starter-alibaba-seata</artifactId>
</dependency>

3.4 配置

3.4.1 undo_log表

3.2.1.1 資料庫腳本

3.2.1.2 配置

# 服務名
spring:
  # 資料源配置
  datasource:
    driver-class-name: com.mysql.cj.jdbc.Driver
    url: jdbc:mysql://localhost:3306/seate_order?useUnicode=true&characterEncoding=utf-8&useSSL=false&serverTimezone=GMT
    username: root
    password: root
    initialization-mode: always # 支持微服務應用啟動時自動執行schema，sql腳本

3.2.1.3 后面專案啟動后腳本刷入order庫，和prod庫

3.4.2 seata配置

# seata client配置(頂格寫)
seata:
  enabled: true # 開啟Seata
  tx-service-group: my_test_tx_group # 事務服務分組（可以每個應用單獨取名, 也可以使用相同的名字）即要和上文中的seata-server的context.txt中service.vgroupMapping.seata_test_tx_group=default一致
  enable-auto-data-source-proxy: true # 自動開啟資料源代理
  registry:
    type: nacos # 使用nacos注冊中心，默認file，訪問seata server(TC)
    nacos:
      server-addr: 127.0.0.1:8848 # seata server 所在的nacos服務地址
      application: seata-server # seata server 的服務名seata-server ，如果沒有修改可以不配
      group: SEATA_GROUP # seata server 所在的組，默認就是SEATA_GROUP，沒有改也可以不配
  config:
    type: nacos
    nacos:
      server-addr: 127.0.0.1:8848 # seata server 所在的nacos服務地址
      group: SEATA_GROUP # seata server 所在的組，默認就是SEATA_GROUP，沒有改也可以不配
  service:
    vgroup-mapping:
      my_test_tx_group: default # 事務群組(必須與seata-server保持一致)
    disable-global-transaction: false # 是否禁用全域事務開關
  client:
    rm:
      report-success-enable: false #是否上報一階段成功

3.5 主要代碼

3.5.1 order模塊的下單和遠程呼叫扣減庫存

全域事務注解：@GlobalTransactional

/**
 * Created On : 1/12/2022.
 * <p>
 * Author : huayu
 * <p>
 * Description: order模塊 下單，呼叫遠程扣減庫存
 */
@Service
@Slf4j
public class KgcMallSeataOrderServiceImpl implements KgcMallSeataOrderService {
    
    @Autowired
    private KgcMallSeataOrderRepository kgcMallSeataOrderRepository; //執行 下單

    @Autowired
    private KgcMallSeataProdFeignService kgcMallSeataProdFeignService;  // 遠程呼叫 執行 扣減庫存

    @Override
    @GlobalTransactional // 分布式事務注解，使用的全域事務，后續所有微服務涉及事務操作，都會被統一管理
    public KgcMallSeataOrder createSeataOrder(KgcMallSeataOrder kgcMallSeataOrder, Integer count) {

        //將分布式事務訂單入庫
        KgcMallSeataOrder seataOrder = kgcMallSeataOrderRepository.save(kgcMallSeataOrder);

        //遠程呼叫商品業務介面，扣減庫存
        kgcMallSeataProdFeignService.invokeSeataProductStockFeign(kgcMallSeataOrder.getProdId(), count);

        //回傳下單詳情
        return seataOrder;
    }

}

3.5.2 prod 模塊扣減庫存

事務注解：@Transactional

/**
 * Created On : 1/12/2022.
 * <p>
 * Author : huayu
 * <p>
 * Description: prod模塊 扣減庫存
 */
@Service
public class KgcMallProdServiceImpl implements KgcMallProdService {

    @Autowired
    private KgcMallSeataProdRepository kgcMallSeataProdRepository; //執行 扣減庫存

    @Override
    @Transactional
    public KgcMallSeataProduct subSeataProductStock(Integer pid, Integer count) {

        //查詢商品庫存
        KgcMallSeataProduct kgcMallSeataProduct = kgcMallSeataProdRepository.findById(pid).orElse(null);

        //判斷商品是否存在
        if (kgcMallSeataProduct != null) {
            kgcMallSeataProduct.setProdStock(kgcMallSeataProduct.getProdStock() - count);
        }
        KgcMallSeataProduct saveKgcMallSeataProduct = kgcMallSeataProdRepository.save(kgcMallSeataProduct);

        //模擬運行時例外
        if (count == 10) {
            int a = 10 / 0;
        }

        //回傳詳情
        return saveKgcMallSeataProduct;
    }

}