📄 common-seata 分布式事务使用

本章文档对应视频 📺 10.分布式事务使用讲解

什么是分布式事务

上图所示，当请求 A 模块时

• 1. A 模块 Mapper 直接操作 DB 得到数据集
• 2. 使用 Feign 调用 B 模块
• 3. B 模块 Mapper 操作 DB 得到数据集
• 4. 合并 1.3 两步操作或者其他的操作

分析上图可能 发生异常及其回滚

• 步骤 1 发生异常， spring 事务会自动回滚
• 步骤 2 发生异常， spring 事务会自动回滚
• 步骤 3 发生异常， 3 会自动回滚， 2 根据返回码抛出自定义异常 1 会自动回滚
• 步骤 4 发生异常， spring 事务会自动 1 的操作 ，但是 3 的操作不会回滚

  分布式事务的目标 当 A 模块开启事务时，如果 4 操作过程异常，3 的操作应该回滚

  

运行 Seata Server 服务端

docker run --name seata-server -p 8091:8091 -p 7091:7091 registry.cn-hangzhou.aliyuncs.com/dockerhub_mirror/seata-server:2.0.0

微服务客户端接入

① 添加依赖

服务提供方、调用方都需要添加此依赖

<dependency>
    <groupId>com.pig4cloud</groupId>
    <artifactId>pigx-common-seata</artifactId>
</dependency>

② 服务调用方声明 GlobalTransactional

@GlobalTransactional // 分布式事务注解
@Transactional(rollbackFor = Exception) // spring 事务注解
public R consumer() {
    feign.providerMethod()  // 通过feign 调用 服务提供方的接口
}

另外:服务提供方、调用方都需要添加 @Transactional spring 事务注解

③ 微服务涉及数据库添加 undo_log 表

服务提供方、调用方都需要添加此表

CREATE TABLE `undo_log` (
  `id` bigint(20) NOT NULL AUTO_INCREMENT,
  `branch_id` bigint(20) NOT NULL,
  `xid` varchar(100) NOT NULL,
  `context` varchar(128) NOT NULL,
  `rollback_info` longblob NOT NULL,
  `log_status` int(11) NOT NULL,
  `log_created` datetime NOT NULL,
  `log_modified` datetime NOT NULL,
  `ext` varchar(100) DEFAULT NULL,
  PRIMARY KEY (`id`),
  UNIQUE KEY `ux_undo_log` (`xid`,`branch_id`)
) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8;