springcloud整合seata实现分布式事务

ゞ浴缸里的玫瑰 2023-07-03 12:12 27阅读 0赞

### 概览 ###

> 本篇文章，根据官网代码demo演示而来  
> [springcloud整合seata实现分布式事务 DEMO][springcloud_seata_ DEMO]

#### 操作步骤如下： ####

*  1.seata-server端，修改server配置
 *  2.client端（你自己的项目），引入配置文件，修改配置文件
 *  3.数据源代理设置
 *  4.创建数据库表
 *  5.启动注册中心(eureka)，启动server,启动client（包括订单服务，库存服务、账户服务）

### 1.此demo技术选型及版本信息 ###

*  注册中心：eureka 2.1.2
 *  服务间调用：feign 2.1.2
 *  持久层：mybatis 3.5.0
 *  数据库：mysql 5.7.20
 *  Springboot:2.1.8.RELEASE(Greenwich.SR2)
 *  Springcloud:2.1.2
 *  jdk:1.8
 *  seata:1.0 (最新稳定版)

### 2.demo概况 ###

demo分为四个项目，单独启动。

*  eureka: 注册中心（http://localhost:8761/eureka/）
 *  order: 订单服务，用户下单后，会创建一个订单添加在order数据库，同时会扣减库存storage，扣减账户account;
 *  storage: 库存服务，用户扣减库存；
 *  account: 账户服务，用于扣减账户余额；

order服务关键代码如下：

@Override
        @GlobalTransactional(name = "fsp-create-order",rollbackFor = Exception.class) //此注解开启全局事务
        public void create(Order order) { 
            //本地方法 创建订单
            orderDao.create(order);
            //远程方法 扣减库存
            storageApi.decrease(order.getProductId(),order.getCount());
            //远程方法 扣减账户余额 可在accountServiceImpl中模拟异常
            accountApi.decrease(order.getUserId(),order.getMoney());
        }

### 3.创建业务数据库 ###

*  seata\_order：存储订单的数据库；
 *  seata\_storage：存储库存的数据库；
 *  seata\_account：存储账户信息的数据库
 *  seata\_server: 如果使用db模式存储事务日志，需要我们要创建三张表：global\_table，branch\_table，lock\_table
 *  所以在每个业务库中，还要创建undo\_log表，建表sql在/conf/db\_undo\_log.sql中。

### 4.seata server端配置信息修改 ###

seata-server中，/conf目录下，有两个配置文件,需要结合自己的情况来修改：

#### 4.1.单个seata server端配置信息修改 ####

##### 1.file.conf #####

原始内容

service { 
      #transaction service group mapping
      vgroup_mapping.my_test_tx_group = "default"
      #only support when registry.type=file, please don't set multiple addresses
      default.grouplist = "127.0.0.1:8091"
      #disable seata
      disableGlobalTransaction = false
    }
    
    ## transaction log store, only used in seata-server
    store { 
      ## store mode: file、db
      mode = "file"
    
      ## file store property
      file { 
        ## store location dir
        dir = "sessionStore"
      }
    
      ## database store property
      db { 
        ## the implement of javax.sql.DataSource, such as DruidDataSource(druid)/BasicDataSource(dbcp) etc.
        datasource = "dbcp"
        ## mysql/oracle/h2/oceanbase etc.
        db-type = "mysql"
        driver-class-name = "com.mysql.jdbc.Driver"
        url = "jdbc:mysql://127.0.0.1:3306/seata"
        user = "mysql"
        password = "mysql"
      }
    }

里面有事务组配置，锁配置，事务日志存储等相关配置信息，由于此demo使用db存储事务信息，我们这里要修改store中的配置：

## transaction log store
    store { 
      ## store mode: file、db
      mode = "db"   修改这里，表明事务信息用db存储
    
      ## file store 当mode=db时，此部分配置就不生效了，这是mode=file的配置
      file { 
        dir = "sessionStore"
    
        # branch session size , if exceeded first try compress lockkey, still exceeded throws exceptions
        max-branch-session-size = 16384
        # globe session size , if exceeded throws exceptions
        max-global-session-size = 512
        # file buffer size , if exceeded allocate new buffer
        file-write-buffer-cache-size = 16384
        # when recover batch read size
        session.reload.read_size = 100
        # async, sync
        flush-disk-mode = async
      }
    
      ## database store  mode=db时，事务日志存储会存储在这个配置的数据库里
      db { 
        ## the implement of javax.sql.DataSource, such as DruidDataSource(druid)/BasicDataSource(dbcp) etc.
        datasource = "dbcp"
        ## mysql/oracle/h2/oceanbase etc.
        db-type = "mysql"
        driver-class-name = "com.mysql.jdbc.Driver"
        url = "jdbc:mysql://116.62.62.26/seat-server"  修改这里
        user = "root"  修改这里
        password = "root"  修改这里
        min-conn = 1
        max-conn = 3
        global.table = "global_table"
        branch.table = "branch_table"
        lock-table = "lock_table"
        query-limit = 100
      }
    }

由于此demo我们使用db模式存储事务日志，所以，我们要**创建三张表：global\_table，branch\_table，lock\_table，建表sql在上面下载的seata-server的/conf/db\_store.sql中**；

**由于存储undo\_log是在业务库中，所以在每个业务库中，还要创建undo\_log表**，建表sql在/conf/db\_undo\_log.sql中。

由于我自定义了事务组名称，所以这里也做了修改：

service { 
      #vgroup->rgroup
      vgroup_mapping.fsp_tx_group = "default"  修改这里，fsp_tx_group这个事务组名称是我自定义的，一定要与client端的这个配置一致！否则会报错！
      #only support single node
      default.grouplist = "127.0.0.1:8091"   此配置作用参考:https://blog.csdn.net/weixin_39800144/article/details/100726116
      #degrade current not support
      enableDegrade = false
      #disable
      disable = false
      #unit ms,s,m,h,d represents milliseconds, seconds, minutes, hours, days, default permanent
      max.commit.retry.timeout = "-1"
      max.rollback.retry.timeout = "-1"
    }

其他的可以先使用默认值。

##### 2.registry.conf #####

registry\{\}中是注册中心相关配置，config\{\}中是配置中心相关配置。seata中，注册中心和配置中心是分开实现的，是两个东西。

我们这里用eureka作注册中心，所以，只用修改registry\{\}中的：

registry { 
      # 用eureka作注册中心    
      type = "eureka"  
    
      eureka { 
        # eureka作注册中心地址  
        serviceUrl = "http://localhost:8761/eureka"  
        application = "default"  
        weight = "1"
      }
    }

其他的配置可以暂时使用默认值。

如果是在windows下启动seata-server，现在已经完成配置修改了，等eureka启动后，就可以启动seata-server了：执行/bin/seata-server.bat即可。

#### 4.2.seata-server 高可用（要求版本0.9+） ####

0.9及之前版本，多TC(事务协调者)时，TC会误报异常，此问题0.9之后已经修复，之后的版本应该不会出现此问题。

部署集群，第一台和第二台配置相同，在server端的registry.conf中，注意：

registry { 
      # file 、nacos 、eureka、redis、zk、consul、etcd3、sofa
      type = "eureka"
    ......
      eureka { 
        serviceUrl = "http://localhost:8761/eureka"  //两台tc相同,注册中心的地址
        application = "default" //两台tc相同
        weight = "1"  //权重，截至0.9版本，暂时不支持此参数
      }
     ......

注意上述配置和client的配置要一致，2台和多台情况相同。

### 5.client端相关配置 ###

#### 1.普通配置 ####

client端的几个服务，都是普通的springboot整合了springCloud组件的正常服务，所以，你需要配置eureka，数据库，mapper扫描等，即使不使用seata，你也需要做，这里不做特殊说明，看代码就好。

#### 2.特殊配置 ####

##### 1.application.yml #####

以order服务为例，除了常规配置外，这里还要**配置下事务组**信息：

spring:
        application:
            name: order-server
        cloud:
            alibaba:
                seata:		
                    # 这个fsp_tx_group自定义命名很重要，server，client都要保持一致
                    tx-service-group: fsp_tx_group

##### 2.file.conf #####

自己新建的项目是没有这个配置文件的，copy过来，修改下面配置：

service { 
      #vgroup->rgroup
      # 这个fsp_tx_group自定义命名很重要，server，client都要保持一致    
      vgroup_mapping.fsp_tx_group = "default"   
      #only support single node
      default.grouplist = "127.0.0.1:8091"
      #degrade current not support
      enableDegrade = false
      #disable
      disable = false
      disableGlobalTransaction = false
    }

##### 3.registry.conf #####

使用eureka做注册中心，仅需要修改eureka的配置即可：

registry { 
      # 使用eureka做注册中心 （还支持file 、nacos 、eureka、redis、zk）
      type = "eureka"
    
      eureka { 
        serviceUrl = "http://localhost:8761/eureka"
        application = "default"
        weight = "1"
      }
    
    }
    
    config { 
      # 使用eureka做配置中心 （还支持file、nacos 、apollo、zk）
      type = "file"
      file { 
        name = "file.conf"
      }
    }

其他的使用默认值就好。

#### 3.数据源代理 ####

这个是要特别注意的地方，seata对数据源做了代理和接管，在每个参与分布式事务的服务中，都要做如下配置：

// 在启动类中取消数据源的自动创建
    @SpringBootApplication(exclude = DataSourceAutoConfiguration.class)
    @MapperScan("com.fly.demo.dao")
    @EnableDiscoveryClient
    @EnableFeignClients
    public class OrderServerApplication { 
    
    	public static void main(String[] args) { 
    		SpringApplication.run(OrderServerApplication.class, args);
    	}
    
    }

/** * 数据源代理 * @author wangzhongxiang */
    @Configuration
    public class DataSourceConfiguration { 
    
        @Bean
        @ConfigurationProperties(prefix = "spring.datasource")
        public DataSource druidDataSource(){ 
            DruidDataSource druidDataSource = new DruidDataSource();
            return druidDataSource;
        }
    
        @Primary
        @Bean("dataSource")
        public DataSourceProxy dataSource(DataSource druidDataSource){ 
            return new DataSourceProxy(druidDataSource);
        }
    
        @Bean
        public SqlSessionFactory sqlSessionFactory(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();
        }
    
    }

### 6.启动测试（注意先后顺序） ###

*  1.启动eureka;
 *  2.启动seata-server;
 *  3.启动order,storage,account服务;
 *  4.访问：http://localhost:8180/order/create?userId=1&productId=1&count=10&money=100

然后可以模拟正常情况，异常情况，超时情况等，观察数据库即可。

2020-02-04 11:02:13.942  INFO 3560 --- [nio-8761-exec-6] c.n.e.registry.AbstractInstanceRegistry  : Registered instance DEFAULT/192.168.115.1:default:8091 with status UP (replication=false)
    
    2020-02-04 11:03:13.427  INFO 3560 --- [nio-8761-exec-3] c.n.e.registry.AbstractInstanceRegistry  : Registered instance ORDER-SERVER/192.168.233.1:order-server:8180 with status UP (replication=false)
    
    2020-02-04 11:04:08.318  INFO 3560 --- [nio-8761-exec-9] c.n.e.registry.AbstractInstanceRegistry  : Registered instance STORAGE-SERVER/192.168.233.1:storage-server:8182 with status UP (replication=false)
    
    
    2020-02-04 11:04:48.525  INFO 3560 --- [nio-8761-exec-5] c.n.e.registry.AbstractInstanceRegistry  : Registered instance ACCOUNT-SERVER/192.168.233.1:account-server:8181 with status UP (replication=false)

### 7.测试正常情况 ###

**正常情况：**

> 通过我们访问`/order`下单接口，根据响应的内容我们确定商品已经购买成功
> 
> 数据库内的`账户余额`、`商品库存`是有所扣减

### 8.测试异常情况 ###

在AccountServiceImpl中模拟异常情况，然后可以查看日志

/** * 账户业务实现类 */
    @Service
    public class AccountServiceImpl implements AccountService { 
    
        private static final Logger LOGGER = LoggerFactory.getLogger(AccountServiceImpl.class);
        @Autowired
        private AccountDao accountDao;
    
        /** * 扣减账户余额 */
        @Override
        public void decrease(Long userId, BigDecimal money) { 
            LOGGER.info("------->account-service中扣减账户余额开始");
            //模拟超时异常，全局事务回滚
            try { 
                Thread.sleep(30*1000);
            } catch (InterruptedException e) { 
                e.printStackTrace();
            }
            accountDao.decrease(userId,money);
            LOGGER.info("------->account-service中扣减账户余额结束");
        }
    }

此时我们可以发现下单后数据库数据并没有任何改变 ，**事务会发生回滚**。

但是，当我们**在seata-order-service中注释掉@GlobalTransactional来看看没有Seata的分布式事务管理会发生什么情况**：

> 由于seata-account-service的超时会导致当库存和账户金额扣减后订单状态并没有设置为已经完成，而且由于远程调用的重试机制，账户余额还会被多次扣减。

**参考链接**

*  https://github.com/seata/seata-samples/tree/master/springcloud-eureka-feign-mybatis-seata
 *  https://seata.io/zh-cn/

[springcloud_seata_ DEMO]: https://github.com/Fly0905/springcloud-seata-demo