【精品】seata综合示例：订单-库存-扣款

时间：2022-10-17 16:00:38

有关seata的安装，请参看博客：https://blog.51cto.com/lianghecai/5759100

业务需求：下单—减库存—扣钱—改订单状态

当用户下单时，会在订单服务中创建一个订单，然后通过远程调用库存服务来扣减下单商品的库存；再通过远程调用账户服务来扣减用户账户里面的余额；最后订单服务中修改订单状态。

需要涉及到三个模块：

模块名 数据库名 port Context-path Application-name
fafu-account seata_account 3001 fafu Fafu-account-3001
fafu-storage seata_storage 4001 fafu Fafu-storage-4001
fafu-order seata_order 5001 fafu Fafu-order-5001

可以看出：该操作需要跨域三个数据库，有两次远程调用，需要用到分布式事务技术。

数据库准备

创建seata_order数据库，然后在其中创建表tb_order：

CREATE TABLE `tb_order`  (
  `id` bigint UNSIGNED NOT NULL COMMENT '订单编号',
  `user_id` bigint UNSIGNED NULL DEFAULT NULL COMMENT '用户编号',
  `sku_id` bigint UNSIGNED NULL DEFAULT NULL COMMENT '商品编号',
  `count` int UNSIGNED NULL DEFAULT NULL COMMENT '数量',
  `money` decimal(10, 3) UNSIGNED NULL DEFAULT NULL COMMENT '金额',
  `state` int UNSIGNED NULL DEFAULT NULL COMMENT '状态',
  PRIMARY KEY (`id`) USING BTREE
) ENGINE = InnoDB CHARACTER SET = utf8mb4 COLLATE = utf8mb4_0900_ai_ci ROW_FORMAT = Dynamic;

上面表的设计只是模拟性质的，大概对应的是拼多多的业务，一个订单中只能购买1种商品，但这种商品可以购买多个。

创建seata_storage数据库，然后在其中创建表tb_storage

CREATE TABLE `tb_storage`  (
  `id` bigint UNSIGNED NOT NULL COMMENT '编号',
  `sku_id` bigint UNSIGNED NULL DEFAULT NULL COMMENT '商品编号',
  `total` int UNSIGNED NULL DEFAULT NULL COMMENT '总库存',
  `used` int UNSIGNED NULL DEFAULT NULL COMMENT '已用库存',
  PRIMARY KEY (`id`) USING BTREE
) ENGINE = InnoDB CHARACTER SET = utf8mb4 COLLATE = utf8mb4_0900_ai_ci ROW_FORMAT = Dynamic;

创建seata_account数据库，然后在其中创建表tb_account：

CREATE TABLE `tb_account`  (
  `id` bigint UNSIGNED NOT NULL COMMENT '编号',
  `total` decimal(11, 3) UNSIGNED NULL DEFAULT NULL COMMENT '总额度',
  `used` decimal(11, 3) UNSIGNED NULL DEFAULT NULL COMMENT '已用额度',
  PRIMARY KEY (`id`) USING BTREE
) ENGINE = InnoDB CHARACTER SET = utf8mb4 COLLATE = utf8mb4_0900_ai_ci ROW_FORMAT = Dynamic;

依次在三个数据库创建undo_log 表，用于保存需要回滚的数据：

CREATE TABLE `undo_log`  (
  `id` bigint NOT NULL AUTO_INCREMENT,
  `branch_id` bigint NOT NULL,
  `xid` varchar(100) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL,
  `context` varchar(128) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL,
  `rollback_info` longblob NOT NULL,
  `log_status` int NOT NULL,
  `log_created` datetime NOT NULL,
  `log_modified` datetime NOT NULL,
  `ext` varchar(100) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,
  PRIMARY KEY (`id`) USING BTREE,
  UNIQUE INDEX `ux_undo_log`(`xid` ASC, `branch_id` ASC) USING BTREE
) ENGINE = InnoDB CHARACTER SET = utf8 COLLATE = utf8_general_ci ROW_FORMAT = Dynamic;

注：每个服务对应的业务数据库都需要创建这个日志表。

项目共同部分

Nacos中

在Nacos添加给客户端加载使用的配置seata-client-demo.yml：

  • Data Id：seata-client-demo.yml
  • Group：SEATA_GROUP 【精品】seata综合示例：订单-库存-扣款

注意：上面配置中的group和nampespace都是在Nacos中创建命名空间时创建的。 上面配置的具体内容如下：

# seata配置
seata:
  enabled: true
  application-id: seata-cilent-deme
  # Seata 事务组编号，此处需于 seata 相同
  tx-service-group: default-tx-group
  config:
    type: nacos
    nacos:
      # nacos ip地址
      server-addr: 127.0.0.1:8848
      group: SEATA_GROUP
      namespace: 99970600-6f67-43fd-a2a2-4e9795947bf4
      data-id: seata-server.properties
  registry:
    type: nacos
    nacos:
      application: seata-server
      # nacos ip地址
      server-addr: 127.0.0.1:8848
      group: SEATA_GROUP
      namespace: 99970600-6f67-43fd-a2a2-4e9795947bf4

依赖

<dependency>
    <groupId>org.projectlombok</groupId>
    <artifactId>lombok</artifactId>
</dependency>

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-actuator</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-devtools</artifactId>
    <scope>runtime</scope>
    <optional>true</optional>
</dependency>

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-test</artifactId>
    <scope>test</scope>
</dependency>

<!-- 持久层相关 -->
<dependency>
    <groupId>mysql</groupId>
    <artifactId>mysql-connector-java</artifactId>
</dependency>
<dependency>
    <groupId>com.alibaba</groupId>
    <artifactId>druid-spring-boot-starter</artifactId>
</dependency>
<dependency>
    <groupId>com.baomidou</groupId>
    <artifactId>mybatis-plus-boot-starter</artifactId>
</dependency>

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-openfeign</artifactId>
</dependency>
<!--  nacos自从2020版本之后不再整合的是Netflix，也就没有ribbon了 -->
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-loadbalancer</artifactId>
</dependency>
<dependency>
    <groupId>com.alibaba.cloud</groupId>
    <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
</dependency>
<dependency>
    <groupId>com.alibaba.cloud</groupId>
    <artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
</dependency>
<!-- sentinel配置持久化到Nacos -->
<dependency>
    <groupId>com.alibaba.csp</groupId>
    <artifactId>sentinel-datasource-nacos</artifactId>
</dependency>

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

Result

@Getter
@ToString
public class Result<T> {
    /**
     * 请求响应状态码
     */
    private int code;
    /**
     * 请求结果描述信息
     */
    private String msg;
    /**
     * 请求结果数据
     */
    private T data;
    public Result<T> setCode(int code) {
        this.code = code;
        return this;
    }

    public Result<T> setMsg(String msg) {
        this.msg = msg;
        return this;
    }

    public Result<T> setData(T data) {
        this.data = data;
        return this;
    }

    public static void main(String[] args) {
        Result<Object> result = new Result<>().addData("a", "aaa", "b", 123, "c", new Date());
        System.out.println(result);
    }

    /**
     * 将key-value形式的成对出现的参数转换为JSON
     *
     * @param objs
     * @return
     */
    public Result<T> addData(Object... objs) {
        if (objs.length % 2 != 0) {
            throw new RuntimeException("参数个数不对");
        }
        for (int i = 0; i < objs.length; i += 2) {
            if (!(objs[i] instanceof String)) {
                throw new RuntimeException("奇数参数必须为字符串");
            }
        }

        Map<String, Object> map = new HashMap<>();
        for (int i = 0; i < objs.length; i += 2) {
            map.put((String) objs[i], objs[i + 1]);
        }

        this.data = (T) map;
        return this;
    }
}

ResultUtil

public class ResultUtil {
    public static <T> Result<T> success() {
        Result<T> result = new Result<>();
        result.setCode(200);
        result.setMsg("成功");
        return result;
    }

    public static <T> Result<T> success(Integer code, String msg) {
        Result<T> result = new Result<>();
        result.setCode(code);
        result.setMsg(msg);
        return result;
    }

    public static <T> Result<T> success(T data) {
        Result<T> result = new Result<>();
        result.setCode(200);
        result.setMsg("成功");
        result.setData(data);
        return result;
    }

    public static <T> Result<T> error() {
        Result<T> result = new Result<>();
        result.setCode(500);
        result.setMsg("失败");
        return result;
    }

    public static <T> Result<T> error(Integer code, String msg) {
        Result<T> result = new Result<>();
        result.setCode(code);
        result.setMsg(msg);
        return result;
    }


    public static void main(String[] args) {
        Result error = ResultUtil.error().addData("a", "aaaa", "b", LocalDateTime.now(), "c", true);
        System.out.println(error);

        //ResultBean res = ResultBeanUtil.success(DataUtil.build(UserVO.class));
        //System.out.println(res);
    }
}

druid数据源代理配置

  • MyBatis版本
@Configuration
public class DataSourceProxyConfig {
    @Bean
    @ConfigurationProperties(prefix = "spring.datasource")
    public DataSource druidDataSource() {
        DruidDataSource druidDataSource = new DruidDataSource();
        return druidDataSource;
    }
    @Bean
    public SqlSessionFactory sqlSessionFactory(DataSource dataSource) throws Exception {
        SqlSessionFactoryBean factoryBean = new SqlSessionFactoryBean();
        factoryBean.setDataSource(dataSource);
        factoryBean.setMapperLocations(new PathMatchingResourcePatternResolver()
                .getResources("classpath*:/mapper/*.xml"));
        return factoryBean.getObject();
    }
}
  • MyBatisPlus版本
@Configuration
public class DataSourceProxyConfig {
    @Bean
    @ConfigurationProperties(prefix = "spring.datasource.druid")
    public DataSource druidDataSource() {
        DruidDataSource druidDataSource = new DruidDataSource();
        return druidDataSource;
    }
}

在2.2.0.RELEASE及以后，数据源代理自动实现了，不需要再手动去配置一个代理类。

seata-account-3001

第一步；创建项目，添加依赖，修改application.yml文件：

server:
  port: 3001
  servlet:
    context-path: /seata

spring:
  application:
    name: seata-account-3001
  #配置数据源
  datasource:
    type: com.alibaba.druid.pool.DruidDataSource
    druid:
      driver-class-name: com.mysql.cj.jdbc.Driver
      url: jdbc:mysql://127.0.0.1:3306/seata_account?useSSL=false&serverTimezone=GMT%2B8&useUnicode=true&characterEncoding=UTF8&autoReconnect=true&failOverReadOnly=false
      username: root
      password: root
      # 连接池的配置信息:初始化大小，最小，最大
      initial-size: 8
      min-idle: 1
      max-active: 20
      # 配置获取连接等待超时的时间
      max-wait: 60000
      # 配置间隔多久才进行一次检测，检测需要关闭的空闲连接，单位是毫秒
      time-between-eviction-runs-millis: 60000
      # 配置一个连接在池中最小生存的时间，单位是毫秒
      min-evictable-idle-time-millis: 300000
      #验证库是否正常sql
      validation-query: select 'x' from dual
      #空闲时验证，防止连接断开
      test-while-idle: true
      test-on-borrow: false
      test-on-return: false
      # 打开PSCache，并且指定每个连接上PSCache的大小
      pool-prepared-statements: true
      max-open-prepared-statements: 20
      max-pool-prepared-statement-per-connection-size: 20
      # 配置监控统计拦截的filters，去掉后监控界面sql无法统计，'wall'用于防火墙
      filters: stat,wall,slf4j
      # 通过connectProperties属性来打开mergeSql功能；慢SQL记录
      connection-properties: druid.stat.mergeSql=true;druid.stat.slowSqlMillis=5000
      # 合并多个DruidDataSource的监控数据
      use-global-data-source-stat: true
  cloud:
    nacos:
      discovery:
        server-addr: 127.0.0.1:8848 # 配置nacos地址
    sentinel:
      transport:
        # 配置sentinel dashboard地址
        dashboard: 127.0.0.1:8080
        # 默认端口8719，假如被占用会自动从8719开始依次+1扫描，直至找到未被占用的端口
        port: 8719
  config:
    import:
      - optional:nacos:seata-client-demo.yml

seata:
  service:
    vgroup-mapping:
      default_tx_group: default
    grouplist:
      default: 127.0.0.1:8091

management:
  endpoints:
    web:
      exposure:
        include: '*' #暴露出所有的端点

#MyBatisPlus相关配置
mybatis-plus:
  #mapper映射文件位置，多个目录用逗号或者分号分隔（告诉 Mapper 所对应的 XML 文件位置）
  mapper-locations: classpath:mapper/*.xml
  #实体扫描，多个package用逗号或者分号分隔
  typeAliasesPackage: com.seata.account.domain
  #  以下配置均有默认值,可以不设置
  global-config:
    db-config:
      #主键类型
      id-type: auto

      table-underline: true

      #数据库大写下划线转换
      capital-mode: true
  configuration:
    # 是否开启自动驼峰命名规则映射:从数据库列名到Java属性驼峰命名的类似映射
    map-underscore-to-camel-case: true

    cache-enabled: false
    #配置JdbcTypeForNull
    jdbc-type-for-null: 'null'
    # 如果查询结果中包含空值的列，则 MyBatis 在映射的时候，不会映射这个字段
    call-setters-on-nulls: true
    # 将执行的sql打印出来，在开发或测试的时候可以用
    log-impl: org.apache.ibatis.logging.stdout.StdOutImpl

第二步：项目主启动类：

@EnableDiscoveryClient
@SpringBootApplication
public class SeataAccountApplication {
    public static void main(String[] args) {
        SpringApplication.run(SeataAccountApplication.class, args);
    }
}

第三步：利用MyBatisCodeHelperPro生成Account表对应的实体类、Mapper、Service代码。

第四步：控制器AccountController

@RestController
@RequestMapping("/account")
public class AccountController {
    @Resource
    private AccountService accountService;

    @PostMapping("/decrease")
    Result decrease(@RequestParam("userId") Long userId, @RequestParam("money") BigDecimal money) {
        //模拟异常，全局事务回滚
        // System.out.println(3/0);      //--------------------①
        accountService.update(Wrappers.<Account>lambdaUpdate()
                .eq(Account::getId, userId)
                .setSql("used = used + " + money)
        );
        return ResultUtil.success().setMsg("扣款成功");
    }
}

启动项目，在Nacos中会看到：

【精品】seata综合示例：订单-库存-扣款

post方式请求：http://localhost:3001/seata/account/decrease?userId=1&money=15
能够正常访问。

seata-storage-4001

第一步；创建项目，添加依赖，修改application.yml文件：

server:
  port: 4001
  servlet:
    context-path: /seata

spring:
  application:
    name: seata-storage-4001
  #配置数据源
  datasource:
    type: com.alibaba.druid.pool.DruidDataSource
    druid:
      driver-class-name: com.mysql.cj.jdbc.Driver
      url: jdbc:mysql://127.0.0.1:3306/seata_storage?useSSL=false&serverTimezone=GMT%2B8&useUnicode=true&characterEncoding=UTF8&autoReconnect=true&failOverReadOnly=false
      username: root
      password: root
      # 连接池的配置信息:初始化大小，最小，最大
      initial-size: 8
      min-idle: 1
      max-active: 20
      # 配置获取连接等待超时的时间
      max-wait: 60000
      # 配置间隔多久才进行一次检测，检测需要关闭的空闲连接，单位是毫秒
      time-between-eviction-runs-millis: 60000
      # 配置一个连接在池中最小生存的时间，单位是毫秒
      min-evictable-idle-time-millis: 300000
      #验证库是否正常sql
      validation-query: select 'x' from dual
      #空闲时验证，防止连接断开
      test-while-idle: true
      test-on-borrow: false
      test-on-return: false
      # 打开PSCache，并且指定每个连接上PSCache的大小
      pool-prepared-statements: true
      max-open-prepared-statements: 20
      max-pool-prepared-statement-per-connection-size: 20
      # 配置监控统计拦截的filters，去掉后监控界面sql无法统计，'wall'用于防火墙
      filters: stat,wall,slf4j
      # 通过connectProperties属性来打开mergeSql功能；慢SQL记录
      connection-properties: druid.stat.mergeSql=true;druid.stat.slowSqlMillis=5000
      # 合并多个DruidDataSource的监控数据
      use-global-data-source-stat: true
  cloud:
    nacos:
      discovery:
        server-addr: 127.0.0.1:8848 # 配置nacos地址
    sentinel:
      transport:
        # 配置sentinel dashboard地址
        dashboard: 127.0.0.1:8080
        # 默认端口8719，假如被占用会自动从8719开始依次+1扫描，直至找到未被占用的端口
        port: 8719
  config:
    import:
      - optional:nacos:seata-client-demo.yml

seata:
  service:
    vgroup-mapping:
      default_tx_group: default
    grouplist:
      default: 127.0.0.1:8091

management:
  endpoints:
    web:
      exposure:
        include: '*' #暴露出所有的端点

#MyBatisPlus相关配置
mybatis-plus:
  #mapper映射文件位置，多个目录用逗号或者分号分隔（告诉 Mapper 所对应的 XML 文件位置）
  mapper-locations: classpath:mapper/*.xml
  #实体扫描，多个package用逗号或者分号分隔
  typeAliasesPackage: com.seata.storage.domain
  #  以下配置均有默认值,可以不设置
  global-config:
    db-config:
      #主键类型
      id-type: auto

      table-underline: true

      #数据库大写下划线转换
      capital-mode: true
  configuration:
    # 是否开启自动驼峰命名规则映射:从数据库列名到Java属性驼峰命名的类似映射
    map-underscore-to-camel-case: true

    cache-enabled: false
    #配置JdbcTypeForNull
    jdbc-type-for-null: 'null'
    # 如果查询结果中包含空值的列，则 MyBatis 在映射的时候，不会映射这个字段
    call-setters-on-nulls: true
    # 将执行的sql打印出来，在开发或测试的时候可以用
    log-impl: org.apache.ibatis.logging.stdout.StdOutImpl

第二步：项目主启动类添加注解

@EnableFeignClients
@EnableDiscoveryClient
@SpringBootApplication(exclude = DataSourceAutoConfiguration.class)//取消数据源自动创建
public class SeataStorageApplication {
    public static void main(String[] args) {
        SpringApplication.run(SeataStorageApplication.class, args);
    }
}

第三步：利用MyBatisCodeHelperPro生成Storage表对应的实体类、Mapper、Service代码。

第四步：控制器StorageController

@RestController
@RequestMapping("/storage")
public class StorageController {
    @Resource
    private StorageService storageService;

    @PostMapping("/decrease")
    Result decrease(@RequestParam("skuId") Long skuId, @RequestParam("count") Integer count) {
        storageService.update(Wrappers.<Storage>lambdaUpdate()
                .eq(Storage::getSkuId, skuId)
                .setSql("used= used+" + count)
        );
        return ResultUtil.success().setMsg("库存扣减成功");
    }
}

启动项目，在Nacos中会看到：

【精品】seata综合示例：订单-库存-扣款 post方式请求：http://localhost:4001/seata/storage/decrease?skuId=1&money=3
能够正常访问。

seata-order-5001

第一步；创建项目，添加依赖，修改application.yml文件：

server:
  port: 5001
  servlet:
    context-path: /seata

spring:
  application:
    name: seata-order-5001
  #配置数据源
  datasource:
    type: com.alibaba.druid.pool.DruidDataSource
    druid:
      driver-class-name: com.mysql.cj.jdbc.Driver
      url: jdbc:mysql://127.0.0.1:3306/seata_order?useSSL=false&serverTimezone=GMT%2B8&useUnicode=true&characterEncoding=UTF8&autoReconnect=true&failOverReadOnly=false
      username: root
      password: root
      # 连接池的配置信息:初始化大小，最小，最大
      initial-size: 8
      min-idle: 1
      max-active: 20
      # 配置获取连接等待超时的时间
      max-wait: 60000
      # 配置间隔多久才进行一次检测，检测需要关闭的空闲连接，单位是毫秒
      time-between-eviction-runs-millis: 60000
      # 配置一个连接在池中最小生存的时间，单位是毫秒
      min-evictable-idle-time-millis: 300000
      #验证库是否正常sql
      validation-query: select 'x' from dual
      #空闲时验证，防止连接断开
      test-while-idle: true
      test-on-borrow: false
      test-on-return: false
      # 打开PSCache，并且指定每个连接上PSCache的大小
      pool-prepared-statements: true
      max-open-prepared-statements: 20
      max-pool-prepared-statement-per-connection-size: 20
      # 配置监控统计拦截的filters，去掉后监控界面sql无法统计，'wall'用于防火墙
      filters: stat,wall,slf4j
      # 通过connectProperties属性来打开mergeSql功能；慢SQL记录
      connection-properties: druid.stat.mergeSql=true;druid.stat.slowSqlMillis=5000
      # 合并多个DruidDataSource的监控数据
      use-global-data-source-stat: true
  cloud:
    nacos:
      discovery:
        server-addr: 127.0.0.1:8848 # 配置nacos地址
    sentinel:
      transport:
        # 配置sentinel dashboard地址
        dashboard: 127.0.0.1:8080
        # 默认端口8719，假如被占用会自动从8719开始依次+1扫描，直至找到未被占用的端口
        port: 8719
  config:
    import:
      - optional:nacos:seata-client-demo.yml

seata:
  service:
    vgroup-mapping:
      default_tx_group: default
    grouplist:
      default: 127.0.0.1:8091

management:
  endpoints:
    web:
      exposure:
        include: '*' #暴露出所有的端点

#MyBatisPlus相关配置
mybatis-plus:
  #mapper映射文件位置，多个目录用逗号或者分号分隔（告诉 Mapper 所对应的 XML 文件位置）
  mapper-locations: classpath:mapper/*.xml
  #实体扫描，多个package用逗号或者分号分隔
  typeAliasesPackage: com.seata.order.domain
  #  以下配置均有默认值,可以不设置
  global-config:
    db-config:
      #主键类型
      id-type: auto

      table-underline: true

      #数据库大写下划线转换
      capital-mode: true
  configuration:
    # 是否开启自动驼峰命名规则映射:从数据库列名到Java属性驼峰命名的类似映射
    map-underscore-to-camel-case: true

    cache-enabled: false
    #配置JdbcTypeForNull
    jdbc-type-for-null: 'null'
    # 如果查询结果中包含空值的列，则 MyBatis 在映射的时候，不会映射这个字段
    call-setters-on-nulls: true
    # 将执行的sql打印出来，在开发或测试的时候可以用
    log-impl: org.apache.ibatis.logging.stdout.StdOutImpl

第二步：项目主启动类上添加注解：

@EnableFeignClients
@EnableDiscoveryClient
@SpringBootApplication(exclude = DataSourceAutoConfiguration.class)//取消数据源自动创建
public class SeataOrderApplication {
    public static void main(String[] args) {
        SpringApplication.run(SeataOrderApplication.class, args);
    }
}

第三步：利用MyBatisCodeHelperPro生成Order表对应的实体类、Mapper、Service代码。

第四步：在feign包下创建：

  • AccountFeignService.java
@FeignClient(name = "seata-account-3001", path = "/seata")
@RequestMapping("/account")
public interface AccountFeignService {
    /**
     * 将skuId对应的商品的库存减少count
     * @param userId
     * @param money
     * @return
     */
    @PostMapping("/decrease")
    Result decrease(@RequestParam("userId") Long userId, @RequestParam("money") BigDecimal money);
}
  • StorageFeignService.java
@FeignClient(name = "seata-storage-4001", path = "/seata")
@RequestMapping("/storage")
public interface StorageFeignService {
    /**
     * 将skuId对应的商品的库存减少count
     * @param skuId
     * @param count
     * @return
     */
    @PostMapping("/decrease")
    Result decrease(@RequestParam("skuId") Long skuId, @RequestParam("count") Integer count);
}

第五步：修改OrderServiceImpl的代码如下所示：

@Service
public class OrderServiceImpl extends ServiceImpl<OrderMapper, Order> implements OrderService {
    @Resource
    private OrderMapper orderMapper;
    @Resource
    private StorageFeignService storageFeignService;
    @Resource
    private AccountFeignService accountFeignService;

    @Override
    //  @GlobalTransactional(rollbackFor = Exception.class)  //全局异常   //----------------②
    public void create(Order order) {
        System.out.println("user建订单");
        orderMapper.insert(order);

        System.out.println("扣减库存");
        storageFeignService.decrease(order.getSkuId(),order.getCount());

        System.out.println("账户余额扣减");
        accountFeignService.decrease(order.getUserId(),order.getMoney());

        System.out.println("修改订单的状态");
        //1表示完成状态
        orderMapper.updateStateByUserId(order.getUserId(),1);

        System.out.println("下单结束");
    }
}

第六步：控制器OrderController

@RestController
@RequestMapping("/order")
public class OrderController {
    @Resource
    private OrderService orderService;

    @GetMapping("/create")
    public Result create(Order order){
        orderService.create(order);
        return ResultUtil.success().setMsg("下单成功！");
    }
}

启动项目： 【精品】seata综合示例：订单-库存-扣款

测试

url：http://localhost:5001/seata/order/create?userId=1&skuId=1&count=10&money=30

  • 保持编号①和编号②处于注释状态：请求url，tb_order表增加了一条记录，用户账户用掉30，库存用掉10。
  • 保持编号②处于注释状态，去掉编号①前的注释：请求url，tb_order表增加了一条记录但状态值为null，用户账户没有发生变化，库存用掉10。没有能够保证数据的完整性
  • 去掉编号①和编号②前的注释：请求url，三个表的数据都没有发生变化。

结论： 微服务中使用alibaba的seata技术实现全局事务控制只需要在相应的Service实现类中添加@GlobalTransactional注解就可以了。

标签：

相关文章