在Spring Boot单体服务中，添加@Transactional注解就能实现事务。在单体服务中，执行事务都是在同一个数据库下进行。但是随着业务越来越复杂，数据量越来越大会进行分库分表。在微服务场景下，每个服务都有自己的数据库。之前的单体事务无法处理跨库的事务，这个时候就需要使用分布式事务。

前面 Seata 环境搭建介绍了seata的安装，安装后就需要结合实战项目介绍分布式事务的应用。

版本

spring-cloud-starter-alibaba:2.1.1.RELEASE
spring-cloud-alibaba-dependencies:2.1.1.RELEASE
Seata Server 1.5.2
Nacos Server:2.0.1

不同的版本实现可能不太相同，尽量保持版本一致。

效果展现

用户下单的业务逻辑，整个逻辑有两个微服务提供支持：

仓库服务：给对应的商品扣减库存
订单服务：创建订单

用户下单购买商品。

先创建订单，创建订单之后，再扣库存。
如果库存不够，就回滚订单。

搭建服务

项目结构

有三个项目,仓库服务stock、订单服务order、seata服务。seata服务先调用订单服务，然后调用仓库服务。

maven 依赖

<dependency>

    <groupId>org.springframework.boot</groupId>

    <artifactId>spring-boot-dependencies</artifactId>

    <version>2.1.1.RELEASE</version>

    <type>pom</type>

    <scope>import</scope>

</dependency>

<!--Spring Cloud Alibaba-->

<dependency>

    <groupId>com.alibaba.cloud</groupId>

    <artifactId>spring-cloud-alibaba-dependencies</artifactId>

    <version>2.1.1.RELEASE</version>

    <type>pom</type>

    <scope>import</scope>

</dependency>

<dependency>

    <groupId>org.springframework.cloud</groupId>

    <artifactId>spring-cloud-dependencies</artifactId>

    <version>$Greenwich.SR3</version>

    <type>pom</type>

    <scope>import</scope>

</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-nacos-config</artifactId>

</dependency>

<dependency>

    <groupId>org.springframework.cloud</groupId>

    <artifactId>spring-cloud-starter-openfeign</artifactId>

</dependency>

<!--seata-->

<dependency>

    <groupId>com.alibaba.cloud</groupId>

    <artifactId>spring-cloud-starter-alibaba-seata</artifactId>

</dependency>

<dependency>

    <groupId>io.seata</groupId>

    <artifactId>seata-spring-boot-starter</artifactId>

</dependency>

三个项目的依赖都是一样的。

yml 配置

seata需要分别配置配置中心和注册中心。

配置中心内部放置着各种配置文件,你可以通过自己所需进行获取配置加载到对应的客户端.比如Seata Client端(TM,RM),Seata Server(TC),会去读取全局事务开关,事务会话存储模式等信息。
注册中心可以说是微服务架构中的”通讯录“，它记录了服务和服务地址的映射关系。在分布式架构中，服务会注册到这里，当服务需要调用其它服务时，就到这里找到服务的地址，进行调用.比如Seata Client端(TM,RM),发现Seata Server(TC)集群的地址,彼此通信.

从官网文档找到Nacos 配置中心，在application.yml加入对应的配置：

seata:

  config:

    type: nacos

    nacos:

      server-addr: xxxx

      group: SEATA_GROUP

      namespace: xxxxxx

      username: nacos

      password: nacos

group、namespace在Nacos控制中心页面可以找到，分别对应下图：

Nacos注册中心同样可以获取如下配置：

seata:

  registry:

    type: nacos

    nacos:

      application: seata-server

      server-addr: 127.0.0.1:8848

      group : SEATA_GROUP

      namespace: xxxxx

      username: nacos

      password: nacos

application对应的是Seata Server配置的服务名。Seata Server将自己封装成一个微服务注册到Nacos注册中心。其他配置和配置中心配置一致。

仓库服务

全部贴代码，文章也比较繁琐。所以使用接口的方式，简单声明代码即可。

仓库扣减库存:

public interface StockService {

    /**

     * 减库存

     * @param id    商品id

     * @param num   扣减数量

     */

    void reduceStock(Long id, BigDecimal num);

}

订单服务

创建订单:

public interface OrderService {

    /**

     * 创建订单

     * @param num     下单数量

     * @param price   商品价格

     * @param goodsId 商品id

     */

    Order create(BigDecimal num,BigDecimal price,Long goodsId);

}

下单操作：

先创建订单，然后扣减库存

@GlobalTransactional(rollbackFor = Exception.class)

public void order(Long goodsId) {

    orderService.create(BigDecimal.TEN,BigDecimal.TEN,goodsId);

    stockService.reduceStock(goodsId,BigDecimal.TEN);

}

数据不回滚

调用下单服务，库存不够，报错了，但是创建订单不会回滚。

分析原因

事务没有回滚，从官网示例下载到本地运行，却可以回滚，对比两者控制台输出之后，发现官网示例使用了mybatis-plus自动添加了DataSourceProxy数据源代理。

所以需要配置seata代理数据源。

配置数据源代理

配置Druid数据源代理：

@Configuration

public class DataSourceProxyConfig {

    @Bean

    @ConfigurationProperties(prefix = "spring.datasource")

    public DataSource druidDataSource(){

        return new DruidDataSource();

    }

    @Bean

    public DataSourceProxy dataSourceProxy(DataSource dataSource) {

        return new DataSourceProxy(dataSource);

    }

    @Bean

    public SqlSessionFactory sqlSessionFactoryBean(DataSourceProxy dataSourceProxy) throws Exception {

        SqlSessionFactoryBean sqlSessionFactoryBean = new SqlSessionFactoryBean();

        sqlSessionFactoryBean.setDataSource(dataSourceProxy);

        sqlSessionFactoryBean.setMapperLocations(new PathMatchingResourcePatternResolver()

                .getResources("classpath*:/mapper/*.xml"));

        sqlSessionFactoryBean.setTransactionFactory(new SpringManagedTransactionFactory());

        return sqlSessionFactoryBean.getObject();

    }

}

同时需要关闭数据源自动代理:

seata.enable-auto-data-source-proxy: false

再调用下单接口，仓库报错报错，创建订单回滚。订单服务控制台也提示了数据回滚：

2023-03-01 23:49:32.162  WARN 66509 --- [nio-8040-exec-3] c.a.c.seata.web.SeataHandlerInterceptor  : xid in change during RPC from 192.168.31.115:8091:1864853653168447501 to null

2023-03-01 23:49:33.653  INFO 66509 --- [h_RMROLE_1_3_24] i.s.c.r.p.c.RmBranchRollbackProcessor    : rm handle branch rollback process:xid=192.168.31.115:8091:1864853653168447501,branchId=1864853653168447502,branchType=AT,resourceId=jdbc:mysql://34.80.215.211:3306/test,applicationData=null

2023-03-01 23:49:33.653  INFO 66509 --- [h_RMROLE_1_3_24] io.seata.rm.AbstractRMHandler            : Branch Rollbacking: 192.168.31.115:8091:1864853653168447501 1864853653168447502 jdbc:mysql://34.80.215.211:3306/test

2023-03-01 23:49:36.005  INFO 66509 --- [h_RMROLE_1_3_24] i.s.r.d.undo.AbstractUndoLogManager      : xid 192.168.31.115:8091:1864853653168447501 branch 1864853653168447502, undo_log deleted with GlobalFinished

2023-03-01 23:49:36.393  INFO 66509 --- [h_RMROLE_1_3_24] io.seata.rm.AbstractRMHandler            : Branch Rollbacked result: PhaseTwo_Rollbacked

PhaseTwo_Rollbacked表示两阶段回滚。

报错 can not get cluster name

控制台报错:

can not get cluster name in registry config 'service.vgroupMapping.nacos-provide-order-seata-service-group', please make sure registry config correct

can not get cluster name in registry config 'service.vgroupMapping.nacos-provide-order-seata-service-group', please make sure registry config correct

can not get cluster name in registry config 'service.vgroupMapping.nacos-provide-order-seata-service-group', please make sure registry config correct

服务在Nacos配置中心找不到service.vgroupMapping.nacos-provide-order-seata-service-group，这是在找分组事务，官网文档有如下介绍：

配置中心有service.vgroupMapping.default_tx_group配置文件,根据上图讲解，需要在application.yml配置:

seata:

   tx-service-group: default_tx_group

配置后还是报错。定位到报错的源码，向上调式源码，在application.yml配置：

spring:

  cloud:

    alibaba:

      seata:

        tx-service-group: default_tx_group

总结

本文介绍了Spring Cloud整合分布式事务seta，主要有：

添加相关依赖
配置application.yml配置，主要添加nacos配置中心和注册中心的配置。
实现一个下单服务，先创建订单，然后扣减库存。库存不够，创建订单回滚。

搭建服务完成之后，事务不回滚，对比官网实例项目。需要添加数据源代理，同时关闭据源自动代理。分布式事务就生效了。

控制台一直报错can not get cluster name in registry config，通过调试源码，找到问题的根源，这里学到了通过源码解决问题。以前前段时间一直在看源码，这次通过源码解决问题，努力还是会有收获的。

源码

Github 源码

巴特西

Spring Cloud Alibaba 整合 Seata 实现分布式事务

版本