1.前提

已经完成了seata服务端启动的环境部署，并已经启动seata服务端
参考：https://www.yuque.com/u27809381/ca4o9w/avy27g

2.案例

如下，假设当前存在一个存在一个订单确认的功能
image.png
该功能的对外暴露接口存在于订单服务，接口的功能包括3步

  1. 订单状态改为已确认
  2. 物品扣减库存
  3. 账户扣除花费

接下来以上述案例来进行seataAT模式的具体使用

3.创建物品服务

建库建表

  1. -- 创建物品数据库
  2. CREATE DATABASE `item`;
  4. -- 使用物品数据库
  5. USE `item`;
  7. -- 创建物品表
  8. DROP TABLE IF EXISTS `t_item`;
  9. CREATE TABLE `t_item` (
  10.   `id` BIGINT NOT NULL AUTO_INCREMENT,
  11.   `count` INT DEFAULT NULL COMMENT '库存',
  12.   PRIMARY KEY (`id`)
  13. ) ENGINE=INNODB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8;
  15. -- 创建回滚日志表
  16. DROP TABLE IF EXISTS `undo_log`;
  17. CREATE TABLE `undo_log`
  18. (
  19.     `branch_id`     BIGINT       NOT NULL COMMENT 'branch transaction id',
  20.     `xid`           VARCHAR(128) NOT NULL COMMENT 'global transaction id',
  21.     `context`       VARCHAR(128) NOT NULL COMMENT 'undo_log context,such as serialization',
  22.     `rollback_info` LONGBLOB     NOT NULL COMMENT 'rollback info',
  23.     `log_status`    INT(11)      NOT NULL COMMENT '0:normal status,1:defense status',
  24.     `log_created`   DATETIME(6)  NOT NULL COMMENT 'create datetime',
  25.     `log_modified`  DATETIME(6)  NOT NULL COMMENT 'modify datetime',
  26.     UNIQUE KEY `ux_undo_log` (`xid`, `branch_id`)
  27. ) ENGINE = INNODB AUTO_INCREMENT = 1 DEFAULT CHARSET = utf8mb4 COMMENT ='AT transaction mode undo table';
  29. -- 插入测试数据
  30. INSERT INTO t_item (id,COUNT) 
  31. VALUES 
  32. (1,5),
  33. (2,15),
  34. (3,20),
  35. (4,25);

项目引入依赖

  1. <!--web服务依赖-->
  2. <dependency>
  3.   <groupId>org.springframework.boot</groupId>
  4.   <artifactId>spring-boot-starter-web</artifactId>
  5. </dependency>
  7. <!--Nacos 服务发现依赖-->
  8. <dependency>
  9.   <groupId>com.alibaba.cloud</groupId>
  10.   <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
  11. </dependency>
  13. <!--引入 seata 依赖-->
  14. <dependency>
  15.   <groupId>com.alibaba.cloud</groupId>
  16.   <artifactId>spring-cloud-starter-alibaba-seata</artifactId>
  17. </dependency>
  19. <!--第三方工具类库-->
  20. <dependency>
  21.   <groupId>cn.hutool</groupId>
  22.   <artifactId>hutool-all</artifactId>
  23.   <version>5.7.18</version>
  24. </dependency>
  26. <!--代码生成器依赖-->
  27. <dependency>
  28.   <groupId>com.baomidou</groupId>
  29.   <artifactId>mybatis-plus-generator</artifactId>
  30.   <version>3.5.0</version>
  31. </dependency>
  32. <dependency>
  33.   <groupId>org.apache.velocity</groupId>
  34.   <artifactId>velocity-engine-core</artifactId>
  35.   <version>2.3</version>
  36. </dependency>
  38. <!-- ...................多数据源连接数据库相关依赖 start................... -->
  39. <!--动态数据源-->
  40. <dependency>
  41.   <groupId>com.baomidou</groupId>
  42.   <artifactId>dynamic-datasource-spring-boot-starter</artifactId>
  43.   <version>3.5.0</version>
  44. </dependency>
  46. <!--Mybatis连接依赖-->
  47. <dependency>
  48.   <groupId>mysql</groupId>
  49.   <artifactId>mysql-connector-java</artifactId>
  50.   <version>8.0.23</version>
  51. </dependency>
  53. <!--mybatis-plus依赖-->
  54. <dependency>
  55.   <groupId>com.baomidou</groupId>
  56.   <artifactId>mybatis-plus-boot-starter</artifactId>
  57.   <version>3.5.0</version>
  58. </dependency>
  60. <!--druid连接池-->
  61. <dependency>
  62.   <groupId>com.alibaba</groupId>
  63.   <artifactId>druid-spring-boot-starter</artifactId>
  64.   <version>1.2.8</version>
  65. </dependency>
  67. <!--log4j-->
  68. <dependency>
  69.   <groupId>log4j</groupId>
  70.   <artifactId>log4j</artifactId>
  71.   <version>1.2.17</version>
  72. </dependency>
  73. <!-- ...................多数据源连接数据库相关依赖 end................... -->
  75. <!--Lombok依赖-->
  76. <dependency>
  77.   <groupId>org.projectlombok</groupId>
  78.   <artifactId>lombok</artifactId>
  79.   <optional>true</optional>
  80. </dependency>
  82. <!--swagger依赖-->
  83. <dependency>
  84.   <groupId>com.spring4all</groupId>
  85.   <artifactId>swagger-spring-boot-starter</artifactId>
  86.   <version>1.8.0.RELEASE</version>
  87. </dependency>
  89. <!--单元测试-->
  90. <dependency>
  91.   <groupId>org.springframework.boot</groupId>
  92.   <artifactId>spring-boot-starter-test</artifactId>
  93.   <scope>test</scope>
  94. </dependency>

编写bootstrap.yml文件

  1. #端点配置
  2. management:
  3.   endpoints:
  4.     web:
  5.       exposure:
  6.         include: '*'
  8. #spring配置
  9. spring:
  11.   #服务名称
  12.   application:
  13.     name: item
  15.   cloud:
  17.     #注册中心配置
  18.     nacos:
  19.       discovery:
  20.         server-addr: 8.142.132.135:8848   #nacos地址
  22.     #事务分组配置
  23.     alibaba:
  24.       seata:
  25.         tx-service-group: service-item-group

编写application.yml文件

  1. #服务器配置
  2. server:
  3.   port: 8082
  5. spring:
  7.   #配置数据库数据源
  8.   datasource:
  9.     dynamic:
  10.       type: com.alibaba.druid.pool.DruidDataSource
  11.       primary: item
  13.       #配置连接池
  14.       druid:
  15.         initialSize: 10
  16.         minIdle: 1
  17.         maxActive: 20
  18.         maxWait: 60000
  19.         timeBetweenEvictionRunsMillis: 60000
  20.         minEvictableIdleTimeMillis: 300000
  21.         validationQuery: select 'x' FROM DUAL
  22.         testWhileIdle: true
  23.         testOnBorrow: false
  24.         testOnReturn: false
  25.         poolPreparedStatements: false
  26.         maxOpenPreparedStatements: -1
  27.         filters: stat,log4j,wall
  28.         connectionProperties: druid.stat.mergeSql=true;druid.stat.slowSqlMillis=5000
  29.         useGlobalDataSourceStat: true
  31.       #配置数据源
  32.       datasource:
  33.         item:
  34.           url: jdbc:mysql://10.128.41.42:3306/item?characterEncoding=UTF-8&autoReconnect=true&useLegacyDatetimeCode=false&serverTimezone=Asia/Shanghai&zeroDateTimeBehavior=convertToNull&useUnicode=true&zeroDateTimeBehavior=CONVERT_TO_NULL&useSSL=true&rewriteBatchedStatements=true
  35.           username: root
  36.           password: sMviwqONsqW&Ag$5
  37.           type: com.alibaba.druid.pool.DruidDataSource
  38.           driver-class-name: com.mysql.cj.jdbc.Driver
  40. #seata配置
  41. seata:
  43.   #配置中心配置
  44.   config:
  45.     type: nacos
  46.     nacos:
  47.       server-addr: 8.142.132.135:8848
  48.       group: "SEATA_GROUP"
  49.       namespace: ""
  50.       username: "nacos"
  51.       password: "nacos"
  53.   #注册中心配置
  54.   registry:
  55.     type: nacos
  56.     nacos:
  57.       application: seata-server
  58.       server-addr: 8.142.132.135:8848
  59.       group: "SEATA_GROUP"
  60.       namespace: ""
  61.       username: "nacos"
  62.       password: "nacos"

启动类添加注解

  1. import org.springframework.boot.SpringApplication;
  2. import org.springframework.boot.autoconfigure.SpringBootApplication;
  3. import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
  5. @SpringBootApplication
  6. @EnableDiscoveryClient
  7. public class ItemApplication {
  8.     public static void main(String[] args) {
  9.         SpringApplication.run(ItemApplication.class, args);
  10.     }
  11. }

编写扣减库存接口

mapper

  1. import com.example.item.entity.TItemPo;
  2. import com.baomidou.mybatisplus.core.mapper.BaseMapper;
  3. import org.apache.ibatis.annotations.Mapper;
  5. /**
  6.  * <p>
  7.  *  Mapper 接口
  8.  * </p>
  9.  *
  10.  * @author 冯铁城 [fengtiecheng@cyou-inc.com]
  11.  * @since 2022-06-27
  12.  */
  13. @Mapper
  14. public interface TItemMapper extends BaseMapper<TItemPo> {
  16. }

service

  1. import cn.hutool.json.JSONObject;
  2. import com.baomidou.mybatisplus.extension.service.IService;
  3. import com.example.item.entity.TItemPo;
  5. /**
  6.  * <p>
  7.  * 服务类
  8.  * </p>
  9.  *
  10.  * @author 冯铁城 [fengtiecheng@cyou-inc.com]
  11.  * @since 2022-06-27
  12.  */
  13. public interface TItemService extends IService<TItemPo> {
  15.     /**
  16.      * 扣减库存
  17.      *
  18.      * @param id 主键ID
  19.      * @return 扣减后对象
  20.      */
  21.     JSONObject delCount(Integer id);
  22. }

service.impl

  1. import cn.hutool.core.util.ObjectUtil;
  2. import cn.hutool.json.JSONObject;
  3. import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
  4. import com.example.item.entity.TItemPo;
  5. import com.example.item.mapper.TItemMapper;
  6. import com.example.item.service.TItemService;
  7. import org.springframework.stereotype.Service;
  8. import org.springframework.transaction.annotation.Transactional;
  10. /**
  11.  * <p>
  12.  * 服务实现类
  13.  * </p>
  14.  *
  15.  * @author 冯铁城 [fengtiecheng@cyou-inc.com]
  16.  * @since 2022-06-27
  17.  */
  18. @Service
  19. @Transactional(rollbackFor = Exception.class)
  20. public class TItemServiceImpl extends ServiceImpl<TItemMapper, TItemPo> implements TItemService {
  22.     @Override
  23.     public JSONObject delCount(Integer id) {
  25.         //1.id判定
  26.         if (id <= 0) {
  27.             throw new RuntimeException("id异常");
  28.         }
  30.         //2.查询库存
  31.         TItemPo itemPo = getById(id);
  32.         if (ObjectUtil.isNull(itemPo)) {
  33.             throw new RuntimeException("未找到资源");
  34.         }
  36.         //3.修改库存,默认-10,测试使用
  37.         itemPo.setCount(itemPo.getCount() - 10);
  38.         if (itemPo.getCount() < 0) {
  39.             throw new RuntimeException("库存数不足");
  40.         }
  42.         //4.数据库更新
  43.         boolean isSuccess = updateById(itemPo);
  44.         if (!isSuccess) {
  45.             throw new RuntimeException("数据库更新失败");
  46.         }
  48.         //5.封装返回结果
  49.         JSONObject result = new JSONObject(true);
  50.         result.set("status", true);
  51.         result.set("data", itemPo);
  53.         //6.返回
  54.         return result;
  55.     }
  56. }

entity

  1. import com.baomidou.mybatisplus.annotation.TableName;
  2. import com.baomidou.mybatisplus.annotation.IdType;
  3. import com.baomidou.mybatisplus.extension.activerecord.Model;
  4. import com.baomidou.mybatisplus.annotation.TableId;
  5. import java.io.Serializable;
  6. import io.swagger.annotations.ApiModel;
  7. import io.swagger.annotations.ApiModelProperty;
  8. import lombok.Data;
  9. import lombok.EqualsAndHashCode;
  11. /**
  12.  * <p>
  13.  * 
  14.  * </p>
  15.  *
  16.  * @author 冯铁城 [fengtiecheng@cyou-inc.com]
  17.  * @since 2022-06-27
  18.  */
  19. @Data
  20. @EqualsAndHashCode(callSuper = false)
  21. @TableName("t_item")
  22. @ApiModel(value="TItemPo对象", description="")
  23. public class TItemPo extends Model<TItemPo> {
  25.     private static final long serialVersionUID = 1L;
  27.     @TableId(value = "id", type = IdType.AUTO)
  28.     private Long id;
  30.     @ApiModelProperty(value = "库存")
  31.     private Integer count;
  33.     @Override
  34.     public Serializable pkVal() {
  35.         return this.id;
  36.     }
  37. }

controller

  1. import cn.hutool.json.JSONObject;
  2. import com.example.item.service.TItemService;
  3. import lombok.RequiredArgsConstructor;
  4. import org.springframework.web.bind.annotation.PathVariable;
  5. import org.springframework.web.bind.annotation.PutMapping;
  6. import org.springframework.web.bind.annotation.RequestMapping;
  7. import org.springframework.web.bind.annotation.RestController;
  9. /**
  10.  * <p>
  11.  * 前端控制器
  12.  * </p>
  13.  *
  14.  * @author 冯铁城 [fengtiecheng@cyou-inc.com]
  15.  * @since 2022-06-27
  16.  */
  17. @RestController
  18. @RequestMapping("/api/v1/items")
  19. @RequiredArgsConstructor
  20. public class TItemController {
  22.     private final TItemService itemService;
  24.     @PutMapping("{id}")
  25.     public JSONObject delCount(@PathVariable Integer id) {
  26.         return itemService.delCount(id);
  27.     }
  28. }

4. 创建账户服务

建库建表

  1. -- 创建账户数据库
  2. CREATE DATABASE `account`;
  4. -- 使用账户数据库
  5. USE `account`;
  7. -- 创建账户表
  8. DROP TABLE IF EXISTS `t_account`;
  9. CREATE TABLE `t_account` (
  10.   `id` BIGINT NOT NULL AUTO_INCREMENT,
  11.   `count` INT DEFAULT NULL COMMENT '余额',
  12.   PRIMARY KEY (`id`)
  13. ) ENGINE=INNODB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8;
  15. -- 创建回滚日志表
  16. DROP TABLE IF EXISTS `undo_log`;
  17. CREATE TABLE `undo_log`
  18. (
  19.     `branch_id`     BIGINT       NOT NULL COMMENT 'branch transaction id',
  20.     `xid`           VARCHAR(128) NOT NULL COMMENT 'global transaction id',
  21.     `context`       VARCHAR(128) NOT NULL COMMENT 'undo_log context,such as serialization',
  22.     `rollback_info` LONGBLOB     NOT NULL COMMENT 'rollback info',
  23.     `log_status`    INT(11)      NOT NULL COMMENT '0:normal status,1:defense status',
  24.     `log_created`   DATETIME(6)  NOT NULL COMMENT 'create datetime',
  25.     `log_modified`  DATETIME(6)  NOT NULL COMMENT 'modify datetime',
  26.     UNIQUE KEY `ux_undo_log` (`xid`, `branch_id`)
  27. ) ENGINE = INNODB AUTO_INCREMENT = 1 DEFAULT CHARSET = utf8mb4 COMMENT ='AT transaction mode undo table';
  29. -- 插入测试数据
  30. INSERT INTO t_account (id,COUNT) 
  31. VALUES 
  32. (1,100),
  33. (2,150),
  34. (3,200),
  35. (4,250);

项目引入依赖

  1. <!--web服务依赖-->
  2. <dependency>
  3.   <groupId>org.springframework.boot</groupId>
  4.   <artifactId>spring-boot-starter-web</artifactId>
  5. </dependency>
  7. <!--Nacos 服务发现依赖-->
  8. <dependency>
  9.   <groupId>com.alibaba.cloud</groupId>
  10.   <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
  11. </dependency>
  13. <!--引入 seata 依赖-->
  14. <dependency>
  15.   <groupId>com.alibaba.cloud</groupId>
  16.   <artifactId>spring-cloud-starter-alibaba-seata</artifactId>
  17. </dependency>
  19. <!--第三方工具类库-->
  20. <dependency>
  21.   <groupId>cn.hutool</groupId>
  22.   <artifactId>hutool-all</artifactId>
  23.   <version>5.7.18</version>
  24. </dependency>
  26. <!--代码生成器依赖-->
  27. <dependency>
  28.   <groupId>com.baomidou</groupId>
  29.   <artifactId>mybatis-plus-generator</artifactId>
  30.   <version>3.5.0</version>
  31. </dependency>
  32. <dependency>
  33.   <groupId>org.apache.velocity</groupId>
  34.   <artifactId>velocity-engine-core</artifactId>
  35.   <version>2.3</version>
  36. </dependency>
  38. <!-- ...................多数据源连接数据库相关依赖 start................... -->
  39. <!--动态数据源-->
  40. <dependency>
  41.   <groupId>com.baomidou</groupId>
  42.   <artifactId>dynamic-datasource-spring-boot-starter</artifactId>
  43.   <version>3.5.0</version>
  44. </dependency>
  46. <!--Mybatis连接依赖-->
  47. <dependency>
  48.   <groupId>mysql</groupId>
  49.   <artifactId>mysql-connector-java</artifactId>
  50.   <version>8.0.23</version>
  51. </dependency>
  53. <!--mybatis-plus依赖-->
  54. <dependency>
  55.   <groupId>com.baomidou</groupId>
  56.   <artifactId>mybatis-plus-boot-starter</artifactId>
  57.   <version>3.5.0</version>
  58. </dependency>
  60. <!--druid连接池-->
  61. <dependency>
  62.   <groupId>com.alibaba</groupId>
  63.   <artifactId>druid-spring-boot-starter</artifactId>
  64.   <version>1.2.8</version>
  65. </dependency>
  67. <!--log4j-->
  68. <dependency>
  69.   <groupId>log4j</groupId>
  70.   <artifactId>log4j</artifactId>
  71.   <version>1.2.17</version>
  72. </dependency>
  73. <!-- ...................多数据源连接数据库相关依赖 end................... -->
  75. <!--Lombok依赖-->
  76. <dependency>
  77.   <groupId>org.projectlombok</groupId>
  78.   <artifactId>lombok</artifactId>
  79.   <optional>true</optional>
  80. </dependency>
  82. <!--swagger依赖-->
  83. <dependency>
  84.   <groupId>com.spring4all</groupId>
  85.   <artifactId>swagger-spring-boot-starter</artifactId>
  86.   <version>1.8.0.RELEASE</version>
  87. </dependency>
  89. <!--单元测试-->
  90. <dependency>
  91.   <groupId>org.springframework.boot</groupId>
  92.   <artifactId>spring-boot-starter-test</artifactId>
  93.   <scope>test</scope>
  94. </dependency>

编写bootstrap.yml文件

  1. #端点配置
  2. management:
  3.   endpoints:
  4.     web:
  5.       exposure:
  6.         include: '*'
  8. #spring配置
  9. spring:
  11.   #服务名称
  12.   application:
  13.     name: account
  15.   cloud:
  17.     #注册中心配置
  18.     nacos:
  19.       discovery:
  20.         server-addr: 8.142.132.135:8848   #nacos地址
  22.     #事务分组配置
  23.     alibaba:
  24.       seata:
  25.         tx-service-group: service-account-group

编写application.yml文件

  1. #服务器配置
  2. server:
  3.   port: 8083
  5. spring:
  7.   #配置数据库数据源
  8.   datasource:
  9.     dynamic:
  10.       type: com.alibaba.druid.pool.DruidDataSource
  11.       primary: account
  13.       #配置连接池
  14.       druid:
  15.         initialSize: 10
  16.         minIdle: 1
  17.         maxActive: 20
  18.         maxWait: 60000
  19.         timeBetweenEvictionRunsMillis: 60000
  20.         minEvictableIdleTimeMillis: 300000
  21.         validationQuery: select 'x' FROM DUAL
  22.         testWhileIdle: true
  23.         testOnBorrow: false
  24.         testOnReturn: false
  25.         poolPreparedStatements: false
  26.         maxOpenPreparedStatements: -1
  27.         filters: stat,log4j,wall
  28.         connectionProperties: druid.stat.mergeSql=true;druid.stat.slowSqlMillis=5000
  29.         useGlobalDataSourceStat: true
  31.       #配置数据源
  32.       datasource:
  33.         account:
  34.           url: jdbc:mysql://10.128.41.42:3306/account?characterEncoding=UTF-8&autoReconnect=true&useLegacyDatetimeCode=false&serverTimezone=Asia/Shanghai&zeroDateTimeBehavior=convertToNull&useUnicode=true&zeroDateTimeBehavior=CONVERT_TO_NULL&useSSL=true&rewriteBatchedStatements=true
  35.           username: root
  36.           password: sMviwqONsqW&Ag$5
  37.           type: com.alibaba.druid.pool.DruidDataSource
  38.           driver-class-name: com.mysql.cj.jdbc.Driver
  40. #seata配置
  41. seata:
  43.   #配置中心配置
  44.   config:
  45.     type: nacos
  46.     nacos:
  47.       server-addr: 8.142.132.135:8848
  48.       group: "SEATA_GROUP"
  49.       namespace: ""
  50.       username: "nacos"
  51.       password: "nacos"
  53.   #注册中心配置
  54.   registry:
  55.     type: nacos
  56.     nacos:
  57.       application: seata-server
  58.       server-addr: 8.142.132.135:8848
  59.       group: "SEATA_GROUP"
  60.       namespace: ""
  61.       username: "nacos"
  62.       password: "nacos"

启动类添加注解

  1. import org.springframework.boot.SpringApplication;
  2. import org.springframework.boot.autoconfigure.SpringBootApplication;
  3. import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
  5. @SpringBootApplication
  6. @EnableDiscoveryClient
  7. public class AccountApplication {
  8.     public static void main(String[] args) {
  9.         SpringApplication.run(AccountApplication.class, args);
  10.     }
  11. }

编写扣减账户余额接口

mapper

  1. import com.example.account.entity.TAccountPo;
  2. import com.baomidou.mybatisplus.core.mapper.BaseMapper;
  3. import org.apache.ibatis.annotations.Mapper;
  5. /**
  6.  * <p>
  7.  *  Mapper 接口
  8.  * </p>
  9.  *
  10.  * @author 冯铁城 [fengtiecheng@cyou-inc.com]
  11.  * @since 2022-06-27
  12.  */
  13. @Mapper
  14. public interface TAccountMapper extends BaseMapper<TAccountPo> {
  16. }

service

  1. import cn.hutool.json.JSONObject;
  2. import com.baomidou.mybatisplus.extension.service.IService;
  3. import com.example.account.entity.TAccountPo;
  5. /**
  6.  * <p>
  7.  * 服务类
  8.  * </p>
  9.  *
  10.  * @author 冯铁城 [fengtiecheng@cyou-inc.com]
  11.  * @since 2022-06-27
  12.  */
  13. public interface TAccountService extends IService<TAccountPo> {
  15.     /**
  16.      * 扣减余额
  17.      *
  18.      * @param id 主键ID
  19.      * @return 扣减后对象
  20.      */
  21.     JSONObject delCount(Integer id);
  22. }

service.impl

  1. import cn.hutool.core.util.ObjectUtil;
  2. import cn.hutool.json.JSONObject;
  3. import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
  4. import com.example.account.entity.TAccountPo;
  5. import com.example.account.mapper.TAccountMapper;
  6. import com.example.account.service.TAccountService;
  7. import org.springframework.stereotype.Service;
  8. import org.springframework.transaction.annotation.Transactional;
  10. /**
  11.  * <p>
  12.  * 服务实现类
  13.  * </p>
  14.  *
  15.  * @author 冯铁城 [fengtiecheng@cyou-inc.com]
  16.  * @since 2022-06-27
  17.  */
  18. @Service
  19. @Transactional(rollbackFor = Exception.class)
  20. public class TAccountServiceImpl extends ServiceImpl<TAccountMapper, TAccountPo> implements TAccountService {
  22.     @Override
  23.     public JSONObject delCount(Integer id) {
  25.         //1.id判定
  26.         if (id <= 0) {
  27.             throw new RuntimeException("id异常");
  28.         }
  30.         //2.查询库存
  31.         TAccountPo accountPo = getById(id);
  32.         if (ObjectUtil.isNull(accountPo)) {
  33.             throw new RuntimeException("未找到资源");
  34.         }
  36.         //3.修改余额,默认-100,测试使用
  37.         accountPo.setCount(accountPo.getCount() - 100);
  38.         if (accountPo.getCount() < 0) {
  39.             throw new RuntimeException("余额不足");
  40.         }
  42.         //4.数据库更新
  43.         boolean isSuccess = updateById(accountPo);
  44.         if (!isSuccess) {
  45.             throw new RuntimeException("数据库更新失败");
  46.         }
  48.         //5.封装返回结果
  49.         JSONObject result = new JSONObject(true);
  50.         result.set("status", true);
  51.         result.set("data", accountPo);
  53.         //6.返回
  54.         return result;
  55.     }
  56. }

entity

  1. import com.baomidou.mybatisplus.annotation.IdType;
  2. import com.baomidou.mybatisplus.annotation.TableId;
  3. import com.baomidou.mybatisplus.annotation.TableName;
  4. import com.baomidou.mybatisplus.extension.activerecord.Model;
  5. import io.swagger.annotations.ApiModel;
  6. import io.swagger.annotations.ApiModelProperty;
  7. import lombok.Data;
  8. import lombok.EqualsAndHashCode;
  10. import java.io.Serializable;
  12. /**
  13.  * <p>
  14.  *
  15.  * </p>
  16.  *
  17.  * @author 冯铁城 [fengtiecheng@cyou-inc.com]
  18.  * @since 2022-06-27
  19.  */
  20. @Data
  21. @EqualsAndHashCode(callSuper = false)
  22. @TableName("t_account")
  23. @ApiModel(value = "TAccountPo对象", description = "")
  24. public class TAccountPo extends Model<TAccountPo> {
  26.     private static final long serialVersionUID = 1L;
  28.     @TableId(value = "id", type = IdType.AUTO)
  29.     private Long id;
  31.     @ApiModelProperty(value = "余额")
  32.     private Integer count;
  34.     @Override
  35.     public Serializable pkVal() {
  36.         return this.id;
  37.     }
  38. }

controller

  1. import cn.hutool.json.JSONObject;
  2. import com.example.account.service.TAccountService;
  3. import lombok.RequiredArgsConstructor;
  4. import org.springframework.web.bind.annotation.PathVariable;
  5. import org.springframework.web.bind.annotation.PutMapping;
  6. import org.springframework.web.bind.annotation.RequestMapping;
  7. import org.springframework.web.bind.annotation.RestController;
  9. /**
  10.  * <p>
  11.  * 前端控制器
  12.  * </p>
  13.  *
  14.  * @author 冯铁城 [fengtiecheng@cyou-inc.com]
  15.  * @since 2022-06-27
  16.  */
  17. @RestController
  18. @RequestMapping("/api/v1/accounts")
  19. @RequiredArgsConstructor
  20. public class TAccountController {
  22.     private final TAccountService accountService;
  24.     @PutMapping("{id}")
  25.     public JSONObject delCount(@PathVariable Integer id) {
  26.         return accountService.delCount(id);
  27.     }
  28. }

5.创建订单服务

建库建表

  1. -- 创建订单数据库
  2. CREATE DATABASE `order`;
  4. -- 使用订单数据库
  5. USE `order`;
  7. -- 创建订单表
  8. DROP TABLE IF EXISTS `t_order`;
  9. CREATE TABLE `t_order` (
  10.   `id` BIGINT NOT NULL AUTO_INCREMENT,
  11.   `status` INT DEFAULT NULL COMMENT '订单状态：0：未完成；1：已完结',
  12.   PRIMARY KEY (`id`)
  13. ) ENGINE=INNODB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8;
  15. -- 创建回滚日志表
  16. DROP TABLE IF EXISTS `undo_log`;
  17. CREATE TABLE `undo_log`
  18. (
  19.   `branch_id`     BIGINT       NOT NULL COMMENT 'branch transaction id',
  20.   `xid`           VARCHAR(128) NOT NULL COMMENT 'global transaction id',
  21.   `context`       VARCHAR(128) NOT NULL COMMENT 'undo_log context,such as serialization',
  22.   `rollback_info` LONGBLOB     NOT NULL COMMENT 'rollback info',
  23.   `log_status`    INT(11)      NOT NULL COMMENT '0:normal status,1:defense status',
  24.   `log_created`   DATETIME(6)  NOT NULL COMMENT 'create datetime',
  25.   `log_modified`  DATETIME(6)  NOT NULL COMMENT 'modify datetime',
  26.   UNIQUE KEY `ux_undo_log` (`xid`, `branch_id`)
  27. ) ENGINE = INNODB AUTO_INCREMENT = 1 DEFAULT CHARSET = utf8mb4 COMMENT ='AT transaction mode undo table';
  29. -- 插入测试数据
  30. INSERT INTO t_order (id,STATUS) 
  31. VALUES 
  32. (1,0),
  33. (2,0),
  34. (3,0),
  35. (4,0);

项目引入依赖

  1. <!--web服务依赖-->
  2. <dependency>
  3.   <groupId>org.springframework.boot</groupId>
  4.   <artifactId>spring-boot-starter-web</artifactId>
  5. </dependency>
  7. <!--Nacos 服务发现依赖-->
  8. <dependency>
  9.   <groupId>com.alibaba.cloud</groupId>
  10.   <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
  11. </dependency>
  13. <!--引入 seata 依赖-->
  14. <dependency>
  15.   <groupId>com.alibaba.cloud</groupId>
  16.   <artifactId>spring-cloud-starter-alibaba-seata</artifactId>
  17. </dependency>
  19. <!-- openfeign依赖 -->
  20. <dependency>
  21.   <groupId>org.springframework.cloud</groupId>
  22.   <artifactId>spring-cloud-starter-openfeign</artifactId>
  23. </dependency>
  25. <!-- openfeign优化请求连接池依赖 -->
  26. <dependency>
  27.   <groupId>io.github.openfeign</groupId>
  28.   <artifactId>feign-httpclient</artifactId>
  29. </dependency>
  31. <!--第三方工具类库-->
  32. <dependency>
  33.   <groupId>cn.hutool</groupId>
  34.   <artifactId>hutool-all</artifactId>
  35.   <version>5.7.18</version>
  36. </dependency>
  38. <!-- ...................多数据源连接数据库相关依赖 start................... -->
  39. <!--动态数据源-->
  40. <dependency>
  41.   <groupId>com.baomidou</groupId>
  42.   <artifactId>dynamic-datasource-spring-boot-starter</artifactId>
  43.   <version>3.5.0</version>
  44. </dependency>
  46. <!--Mybatis连接依赖-->
  47. <dependency>
  48.   <groupId>mysql</groupId>
  49.   <artifactId>mysql-connector-java</artifactId>
  50.   <version>8.0.23</version>
  51. </dependency>
  53. <!--mybatis-plus依赖-->
  54. <dependency>
  55.   <groupId>com.baomidou</groupId>
  56.   <artifactId>mybatis-plus-boot-starter</artifactId>
  57.   <version>3.5.0</version>
  58. </dependency>
  60. <!--druid连接池-->
  61. <dependency>
  62.   <groupId>com.alibaba</groupId>
  63.   <artifactId>druid-spring-boot-starter</artifactId>
  64.   <version>1.2.8</version>
  65. </dependency>
  67. <!--log4j-->
  68. <dependency>
  69.   <groupId>log4j</groupId>
  70.   <artifactId>log4j</artifactId>
  71.   <version>1.2.17</version>
  72. </dependency>
  73. <!-- ...................多数据源连接数据库相关依赖 end................... -->
  75. <!--Lombok依赖-->
  76. <dependency>
  77.   <groupId>org.projectlombok</groupId>
  78.   <artifactId>lombok</artifactId>
  79.   <optional>true</optional>
  80. </dependency>
  82. <!--swagger依赖-->
  83. <dependency>
  84.   <groupId>com.spring4all</groupId>
  85.   <artifactId>swagger-spring-boot-starter</artifactId>
  86.   <version>1.8.0.RELEASE</version>
  87. </dependency>
  89. <!--单元测试-->
  90. <dependency>
  91.   <groupId>org.springframework.boot</groupId>
  92.   <artifactId>spring-boot-starter-test</artifactId>
  93.   <scope>test</scope>
  94. </dependency>

编写bootstramp.yml文件

  1. #端点配置
  2. management:
  3.   endpoints:
  4.     web:
  5.       exposure:
  6.         include: '*'
  8. #spring配置
  9. spring:
  11.   #服务名称
  12.   application:
  13.     name: order
  15.   cloud:
  17.     #注册中心配置
  18.     nacos:
  19.       discovery:
  20.         server-addr: 8.142.132.135:8848   #nacos地址
  22.     #事务分组配置
  23.     alibaba:
  24.       seata:
  25.         tx-service-group: service-order-group

编写application.yml文件

  1. #服务器配置
  2. server:
  3.   port: 8081
  5. spring:
  7.   #配置数据库数据源
  8.   datasource:
  9.     dynamic:
  10.       type: com.alibaba.druid.pool.DruidDataSource
  11.       primary: order
  13.       #配置连接池
  14.       druid:
  15.         initialSize: 10
  16.         minIdle: 1
  17.         maxActive: 20
  18.         maxWait: 60000
  19.         timeBetweenEvictionRunsMillis: 60000
  20.         minEvictableIdleTimeMillis: 300000
  21.         validationQuery: select 'x' FROM DUAL
  22.         testWhileIdle: true
  23.         testOnBorrow: false
  24.         testOnReturn: false
  25.         poolPreparedStatements: false
  26.         maxOpenPreparedStatements: -1
  27.         filters: stat,log4j,wall
  28.         connectionProperties: druid.stat.mergeSql=true;druid.stat.slowSqlMillis=5000
  29.         useGlobalDataSourceStat: true
  31.       #配置数据源
  32.       datasource:
  33.         order:
  34.           url: jdbc:mysql://10.128.41.42:3306/order?characterEncoding=UTF-8&autoReconnect=true&useLegacyDatetimeCode=false&serverTimezone=Asia/Shanghai&zeroDateTimeBehavior=convertToNull&useUnicode=true&zeroDateTimeBehavior=CONVERT_TO_NULL&useSSL=true&rewriteBatchedStatements=true
  35.           username: root
  36.           password: sMviwqONsqW&Ag$5
  37.           type: com.alibaba.druid.pool.DruidDataSource
  38.           driver-class-name: com.mysql.cj.jdbc.Driver
  40. #seata配置
  41. seata:
  43.   #配置中心配置
  44.   config:
  45.     type: nacos
  46.     nacos:
  47.       server-addr: 8.142.132.135:8848
  48.       group: "SEATA_GROUP"
  49.       namespace: ""
  50.       username: "nacos"
  51.       password: "nacos"
  53.   #注册中心配置
  54.   registry:
  55.     type: nacos
  56.     nacos:
  57.       application: seata-server
  58.       server-addr: 8.142.132.135:8848
  59.       group: "SEATA_GROUP"
  60.       namespace: ""
  61.       username: "nacos"
  62.       password: "nacos"
  64. #ribbon配置
  65. ribbon:
  66.   ReadTimeout: 6000
  67.   ConnectionTimeout: 6000
  69. #feign配置
  70. feign:
  71.   client:
  72.     httpclient:
  73.       enabled: true
  74.   compression:
  75.     request:
  76.       enabled: true
  77.       mime-types: text/xml,application/xml, application/json
  78.       min-request-size: 1024
  79.     response:
  80.       enabled: true

启动类添加注解

  1. import org.springframework.boot.SpringApplication;
  2. import org.springframework.boot.autoconfigure.SpringBootApplication;
  3. import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
  4. import org.springframework.cloud.openfeign.EnableFeignClients;
  6. @SpringBootApplication
  7. @EnableDiscoveryClient
  8. @EnableFeignClients
  9. public class OrderApplication {
  10.     public static void main(String[] args) {
  11.         SpringApplication.run(OrderApplication.class, args);
  12.     }
  13. }

编写订单确认接口

mapper

  1. import com.example.order.entity.TOrderPo;
  2. import com.baomidou.mybatisplus.core.mapper.BaseMapper;
  3. import org.apache.ibatis.annotations.Mapper;
  5. /**
  6.  * <p>
  7.  *  Mapper 接口
  8.  * </p>
  9.  *
  10.  * @author 冯铁城 [fengtiecheng@cyou-inc.com]
  11.  * @since 2022-06-27
  12.  */
  13. @Mapper
  14. public interface TOrderMapper extends BaseMapper<TOrderPo> {
  16. }

service

  1. import cn.hutool.json.JSONObject;
  2. import com.baomidou.mybatisplus.extension.service.IService;
  3. import com.example.order.entity.TOrderPo;
  5. /**
  6.  * <p>
  7.  * 服务类
  8.  * </p>
  9.  *
  10.  * @author 冯铁城 [fengtiecheng@cyou-inc.com]
  11.  * @since 2022-06-27
  12.  */
  13. public interface TOrderService extends IService<TOrderPo> {
  15.     /**
  16.      * 修改订单状态
  17.      *
  18.      * @param id 订单ID
  19.      * @return 修改后的订单
  20.      */
  21.     JSONObject updateOrder(Integer id);
  22. }

service.impl

  1. import cn.hutool.core.util.ObjectUtil;
  2. import cn.hutool.json.JSONObject;
  3. import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
  4. import com.example.order.entity.TOrderPo;
  5. import com.example.order.mapper.TOrderMapper;
  6. import com.example.order.service.TOrderService;
  7. import org.springframework.stereotype.Service;
  8. import org.springframework.transaction.annotation.Transactional;
  10. /**
  11.  * <p>
  12.  * 服务实现类
  13.  * </p>
  14.  *
  15.  * @author 冯铁城 [fengtiecheng@cyou-inc.com]
  16.  * @since 2022-06-27
  17.  */
  18. @Service
  19. @Transactional(rollbackFor = Exception.class)
  20. public class TOrderServiceImpl extends ServiceImpl<TOrderMapper, TOrderPo> implements TOrderService {
  22.     @Override
  23.     public JSONObject updateOrder(Integer id) {
  25.         //1.id判定
  26.         if (id <= 0) {
  27.             throw new RuntimeException("id异常");
  28.         }
  30.         //2.查询账户
  31.         TOrderPo orderPo = getById(id);
  32.         if (ObjectUtil.isNull(orderPo)) {
  33.             throw new RuntimeException("未找到资源");
  34.         }
  36.         //3.修改订单状态
  37.         orderPo.setStatus(1);
  39.         //4.数据库更新
  40.         boolean isSuccess = updateById(orderPo);
  41.         if (!isSuccess) {
  42.             throw new RuntimeException("数据库更新失败");
  43.         }
  45.         //5.封装返回结果
  46.         JSONObject result = new JSONObject(true);
  47.         result.set("status", true);
  48.         result.set("data", orderPo);
  50.         //6.返回
  51.         return result;
  52.     }
  53. }

entity

  1. import com.baomidou.mybatisplus.annotation.TableName;
  2. import com.baomidou.mybatisplus.annotation.IdType;
  3. import com.baomidou.mybatisplus.extension.activerecord.Model;
  4. import com.baomidou.mybatisplus.annotation.TableId;
  5. import java.io.Serializable;
  6. import io.swagger.annotations.ApiModel;
  7. import io.swagger.annotations.ApiModelProperty;
  8. import lombok.Data;
  9. import lombok.EqualsAndHashCode;
  11. /**
  12.  * <p>
  13.  * 
  14.  * </p>
  15.  *
  16.  * @author 冯铁城 [fengtiecheng@cyou-inc.com]
  17.  * @since 2022-06-27
  18.  */
  19. @Data
  20. @EqualsAndHashCode(callSuper = false)
  21. @TableName("t_order")
  22. @ApiModel(value="TOrderPo对象", description="")
  23. public class TOrderPo extends Model<TOrderPo> {
  25.     private static final long serialVersionUID = 1L;
  27.     @TableId(value = "id", type = IdType.AUTO)
  28.     private Long id;
  30.     @ApiModelProperty(value = "订单状态：0：未完成；1：已完结")
  31.     private Integer status;
  33.     @Override
  34.     public Serializable pkVal() {
  35.         return this.id;
  36.     }
  37. }

ItemFeign

  1. import cn.hutool.json.JSONObject;
  2. import org.springframework.cloud.openfeign.FeignClient;
  3. import org.springframework.stereotype.Component;
  4. import org.springframework.web.bind.annotation.PathVariable;
  5. import org.springframework.web.bind.annotation.PutMapping;
  7. /**
  8.  * @author 冯铁城 [fengtiecheng@cyou-inc.com]
  9.  * @date 2022-06-27 18:24:50
  10.  * @describe:
  11.  */
  12. @Component
  13. @FeignClient(value = "item")
  14. public interface ItemFeign {
  16.     @PutMapping("/api/v1/items/{id}")
  17.     JSONObject delCount(@PathVariable Integer id);
  18. }

AccountFeign

  1. import cn.hutool.json.JSONObject;
  2. import org.springframework.cloud.openfeign.FeignClient;
  3. import org.springframework.stereotype.Component;
  4. import org.springframework.web.bind.annotation.PathVariable;
  5. import org.springframework.web.bind.annotation.PutMapping;
  7. /**
  8.  * @author 冯铁城 [fengtiecheng@cyou-inc.com]
  9.  * @date 2022-06-27 18:24:50
  10.  * @describe:
  11.  */
  12. @Component
  13. @FeignClient(value = "account")
  14. public interface AccountFeign {
  16.     @PutMapping("/api/v1/accounts/{id}")
  17.     JSONObject delCount(@PathVariable Integer id);
  18. }

controller

  1. import cn.hutool.json.JSONObject;
  2. import cn.hutool.log.StaticLog;
  3. import com.example.order.feign.AccountFeign;
  4. import com.example.order.feign.ItemFeign;
  5. import com.example.order.service.TOrderService;
  6. import lombok.RequiredArgsConstructor;
  7. import org.springframework.web.bind.annotation.PathVariable;
  8. import org.springframework.web.bind.annotation.PutMapping;
  9. import org.springframework.web.bind.annotation.RequestMapping;
  10. import org.springframework.web.bind.annotation.RestController;
  12. /**
  13.  * <p>
  14.  * 前端控制器
  15.  * </p>
  16.  *
  17.  * @author 冯铁城 [fengtiecheng@cyou-inc.com]
  18.  * @since 2022-06-27
  19.  */
  20. @RestController
  21. @RequestMapping("/api/v1/orders")
  22. @RequiredArgsConstructor
  23. public class TOrderController {
  25.     private final TOrderService orderService;
  27.     private final ItemFeign itemFeign;
  29.     private final AccountFeign accountFeign;
  31.     @PutMapping("{id}")
  32.     public JSONObject updateOrder(@PathVariable Integer id) {
  34.         //1.修改订单状态
  35.         JSONObject result = orderService.updateOrder(id);
  37.         //2.调用物品服务扣减库存
  38.         JSONObject itemResult = itemFeign.delCount(id);
  39.         StaticLog.info("物品服务扣减库存响应:[{}]", itemResult);
  41.         //3.调用账户服务扣减余额
  42.         JSONObject accountResult = accountFeign.delCount(id);
  43.         StaticLog.info("账户服务扣减余额响应:[{}]", accountResult);
  45.         //4.返回
  46.         return result;
  47.     }
  48. }

6.未引入seata触发修改订单状态接口

因为item服务每次会扣除10库存，而id=1的库存=5，当库存不足时，item服务会抛出异常，因此调用item服务的order服务也会异常
如图：响应异常
image.png
异常原因出现在item服务
image.png
但是此时查看order数据库，id为1的订单状态，发现状态已经变更了，此时就出现了数据不一致问题
image.png

7.@GlobalTransactional注解引入

注解说明

seata提供了@GlobalTransactional标签来控制全局事务的开启、管理以及控制
@GlobalTransactional注解最常用的属性

  1. name：声明全局事务的名称
  2. rollbackFor：出现什么异常时全局回滚

@GlobalTransactional注解的作用域

  1. 在方法上使用时，全局事务的范围就是该方法以及它所涉及的所有服务。
  2. 在类上使用时，全局事务的范围就是这个类中的所有方法以及这些方法涉及的服务。

    order服务改造

    ```java import cn.hutool.json.JSONObject; import cn.hutool.log.StaticLog; import com.example.order.feign.AccountFeign; import com.example.order.feign.ItemFeign; import com.example.order.service.TOrderService; import io.seata.spring.annotation.GlobalTransactional; import lombok.RequiredArgsConstructor; import org.springframework.web.bind.annotation.PathVariable; import org.springframework.web.bind.annotation.PutMapping; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController;

/**

  • 前端控制器

  • *
  • @author 冯铁城 [fengtiecheng@cyou-inc.com]

  • @since 2022-06-27 */ @RestController @RequestMapping(“/api/v1/orders”) @RequiredArgsConstructor public class TOrderController {

    private final TOrderService orderService;

    private final ItemFeign itemFeign;

    private final AccountFeign accountFeign;

    @PutMapping(“{id}”) @GlobalTransactional(name = “order-update-order”, rollbackFor = Exception.class) public JSONObject updateOrder(@PathVariable Integer id) {

    1.   //1.修改订单状态
    2.   JSONObject result = orderService.updateOrder(id);
    4.   //2.调用物品服务扣减库存
    5.   JSONObject itemResult = itemFeign.delCount(id);
    6.   StaticLog.info("物品服务扣减库存响应:[{}]", itemResult);
    8.   //3.调用账户服务扣减余额
    9.   JSONObject accountResult = accountFeign.delCount(id);
    10.   StaticLog.info("账户服务扣减余额响应:[{}]", accountResult);
    12.   //4.返回
    13.   return result;

    } } ```

    改造后具体逻辑步骤

  1. order服务作为TM向TC注册一个全局事务，TC返回一个XID
  2. order服务一阶段修改订单状态，之后提交并保存前后镜像回滚日志
  3. TC发送一阶段执行命令给item服务（RM）
  4. item服务一阶段执行过程中出现异常，事务回滚。返回结果给TC
  5. TC将item服务的返回结果给TM
  6. TM决定全局回滚
  7. TC发送全局回滚命令
  8. order服务接收到全局回滚命令，根据前后镜像回滚日志进行订单数据回滚

    验证

    如图：订单id=1的数据状态并没有改变
    image.png
    同时查看订单服务控制台，出现订单回滚字样
    image.png
    全局事务成功！！！