<dependency>
    <groupId>com.alibaba.cloud</groupId>
    <artifactId>spring-cloud-starter-alibaba-seata</artifactId>
    <version>2021.1</version>
    <exclusions>
        <exclusion>
            <artifactId>seata-spring-boot-starter</artifactId>
            <groupId>io.seata</groupId>
        </exclusion>
    </exclusions>
</dependency>
<dependency>
    <groupId>io.seata</groupId>
    <artifactId>seata-spring-boot-starter</artifactId>
    <version>1.4.2</version>
</dependency>

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 COMMENT ='AT transaction mode undo table';

seata:
  enabled: true
  # 是否自動(dòng)開(kāi)啟數(shù)據(jù)源代理
  enable-auto-data-source-proxy: true
  # 數(shù)據(jù)源代理模式，使用AT模式
  data-source-proxy-mode: AT

seata:
  # 是否自動(dòng)開(kāi)啟數(shù)據(jù)源代理
  enable-auto-data-source-proxy: false

@Bean
    public DataSource dataSourceProxy() {
        // 某一個(gè)數(shù)據(jù)源
        XxxDataSource xxxDataSource = new XxxDataSource();
        // 設(shè)置數(shù)據(jù)源的各種配置屬性
        xxxDataSource.setXXX("");
        // 使用 DataSourceProxy 來(lái)包裝一下
        return new DataSourceProxy(xxxDataSource);
    }

public class BusinessServiceImpl implements BusinessService {
    private final OrderService orderService;
    private final AccountClient accountClient;
    @Override
    // 開(kāi)啟分布式事務(wù)
    @GlobalTransactional(rollbackFor = Exception.class)
    public void createAccountOrder(Integer accountId, Long amount, boolean hasException) {
        System.out.println("xid:" + RootContext.getXID());
        // 1、遠(yuǎn)程扣減賬戶余額
        remoteDebit(accountId, amount);
        // 2、下訂單
        orderService.createOrder(accountId, amount);
        if (hasException) {
            throw new RuntimeException("發(fā)生了異常，分布式事物需要會(huì)滾");
        }
    }
    private void remoteDebit(Integer accountId, Long amount) {
        String result = accountClient.debit(accountId, amount);
        log.info("遠(yuǎn)程扣減庫(kù)存結(jié)果:[{}]", result);
    }
}