使用分布式事务 Seata 的 AT 模式-526互联

有了上篇博客实现 XA 模式的基础，本篇博客在实现 AT 模式时，不需要修改任何代码，只需要增加一张数据库表，修改以下 application.yml 配置即可实现。AT 模式也是分两个阶段提交的事务模型，它缺弥补了 XA 模型中资源锁定周期过长的问题。

其实现的两个阶段的工作原理如下：

第一阶段注册分支事务，记录 undo-log 快照，执行业务 sql 后，直接提交，释放资源。
第二阶段也是根据第一阶段的执行结果而决定。如果一阶段都成功，则删除 undo-log 快照记录即可；如果一阶段任意一个参与者失败，根据 undo-log 快照记录进行数据恢复，并删除 undo-log 快照。

一、实现 AT 模式

本篇博客的 Demo 与上一篇博客的 Demo 相同，具体的实现代码没有进行更改，为了区分上一篇博客的 Demo，我复制了一份代码，将工程的名字修改为 springcloud_seata_at ，工程结构如下图所示：

基于上一篇博客的 Demo，实现 AT 模式只需要 2 个步骤：

1 在业务系统的数据库中，创建 undo-log 数据库表

在 seata 集群部署的博客中，我们解压了 seata 源码压缩包 seata-1.8.0.zip，解压后在其 script\client\at\db 目录中有个 mysql.sql 的文件，其内容如下：

-- for AT mode you must to init this sql for you business database. the seata server not need it.
CREATE TABLE IF NOT EXISTS `undo_log`
(
    `branch_id`     BIGINT       NOT NULL COMMENT 'branch transaction id',
    `xid`           VARCHAR(128) NOT NULL COMMENT 'global transaction id',
    `context`       VARCHAR(128) NOT NULL COMMENT 'undo_log context,such as serialization',
    `rollback_info` LONGBLOB     NOT NULL COMMENT 'rollback info',
    `log_status`    INT(11)      NOT NULL COMMENT '0:normal status,1:defense status',
    `log_created`   DATETIME(6)  NOT NULL COMMENT 'create datetime',
    `log_modified`  DATETIME(6)  NOT NULL COMMENT 'modify datetime',
    UNIQUE KEY `ux_undo_log` (`xid`, `branch_id`)
) ENGINE = InnoDB AUTO_INCREMENT = 1 DEFAULT CHARSET = utf8mb4 COMMENT ='AT transaction mode undo table';
ALTER TABLE `undo_log` ADD INDEX `ix_log_created` (`log_created`);

运行该 sql 到你的业务库中，在本篇博客的 demo 中，业务库的名称是 seatatest 数据库。

2 修改 AccountService、OrderService、StockService 的 application.yml 文件

修改 3 个微服务项目的 application.yml 配置文件，将 data-source-proxy-mode 修改为 AT 即可，以 OrderService 为例内容如下：

server:
  port: 9090
spring:
  application:
    name: order-service
  datasource:
    driver-class-name: com.mysql.jdbc.Driver
    url: jdbc:mysql://192.168.136.128:3306/seatatest?characterEncoding=utf8&allowMultiQueries=true&useSSL=false
    username: root
    password: root
  cloud:
    nacos:
      server-addr: 192.168.136.128:8848

seata:
  registry:
    type: nacos
    nacos:
      server-addr: 192.168.136.128:8848
      # 空字符串表示使用 nacos 的默认 namespace（public）
      namespace: ""
      group: SEATA_GROUP
      application: seata-server
      #username: nacos
      #password: nacos
  tx-service-group: myseata_test
  service:
    vgroup-mapping:
      myseata_test: jobs
  # 这里配置 Seata 使用 AT 模式（默认值也是 AT 模式）
  data-source-proxy-mode: AT

其实对于 data-source-proxy-mode 来说，如果不进行配置，其默认值也是 AT