微服务轮子项目（25） -分布式事务（SEATA）

1. 引言

原文地址：https://mp.weixin.qq.com/s/0yCmHzlXDC9BkbUuEt0_fQ

在微服务架构下，虽然我们会尽量避免分布式事务，但是只要业务复杂的情况下这是一个绕不开的问题，如何保证业务数据一致性呢？本文主要介绍同步场景下使用Seata的AT模式来解决一致性问题。

2. Seata介绍

Seata是 阿里巴巴 开源的 一站式分布式事务解决方案 中间件，以 高效 并且对业务 0 侵入 的方式，解决 微服务 场景下面临的分布式事务问题

整体事务逻辑是基于两阶段提交的模型，核心概念包括以下3个角色：

• TM：事务的发起者。用来告诉 TC，全局事务的开始，提交，回滚。
• RM：具体的事务资源，每一个 RM 都会作为一个分支事务注册在 TC。
• TC：事务的协调者seata-server，用于接收我们的事务的注册，提交和回滚。

目前的Seata有两种模式可使用分别对应不同业务场景 。

2.1 AT模式

该模式适合的场景：

• 基于支持本地 ACID事务的关系型数据库。
• Java 应用，通过 JDBC 访问数据库。

一个典型的分布式事务过程：

1. TM 向 TC 申请开启一个全局事务，全局事务创建成功并生成一个全局唯一的 XID。
2. XID 在微服务调用链路的上下文中传播。
3. RM 向 TC 注册分支事务，将其纳入 XID 对应全局事务的管辖。
4. TM 向 TC 发起针对 XID 的全局提交或回滚决议。
5. TC 调度 XID 下管辖的全部分支事务完成提交或回滚请求。

2.2 MT模式

该模式逻辑类似TCC，需要 自定义实现prepare、commit和rollback的逻辑，适合非关系型数据库的场景:

3. Seata场景样例

模拟一个简单的用户下单场景，4个子工程分别是 Bussiness(事务发起者)、Order(创建订单)、Storage(扣减库存) 和 Account(扣减账户余额)

3.1 测试环境

• mysql 5.7
• seata 1.3
• nacos 1.3

注意：如果nacos使用低于1.3的版本不需要配置username和password；如果使用1.3以上版本必需开启 nacos.core.auth.enabled=true 并且配置username和password，否则读取不到seata-server

3.2 部署Seata的Server端境

Discover注册、Config配置和Store存储模块默认都是使用file只能适用于单机，我们安装的时候分别改成使用nacos和Mysql以支持server端集群

1.下载最新版本并解压:

• https://github.com/seata/seata/releases

2.修改 conf/registry.conf 配置:

• 注册中心和配置中心默认是file这里改为nacos；设置registry和config节点中的type为nacos，修改serverAddr为你的nacos节点地址。

registry {
  # file 、nacos 、eureka、redis、zk、consul、etcd3、sofa
  type = "nacos"

  nacos {
    application = "seata-server"
    serverAddr = "192.168.28.130:8848"
    group = "SEATA_GROUP"
    namespace = ""
    cluster = "default"
    username = "nacos"
    password = "nacos"
  }
}

config {
  # file、nacos 、apollo、zk、consul、etcd3
  type = "nacos"

  nacos {
    serverAddr = "192.168.28.130:8848"
    namespace = ""
    group = "SEATA_GROUP"
    username = "nacos"
    password = "nacos"
  }
}

注意：如果nacos使用低于1.3的版本不需要配置username和password；如果使用1.3以上版本必需开启 nacos.core.auth.enabled=true 并且配置username和password，否则读取不到seata-server

3.修改 conf/nacos-config.txt配置:

• 进入 seata-server 的目录中创建文件 config.txt文件，内容如下：

service.vgroupMapping.test_tx_service_group=default
store.mode=db
store.db.datasource=druid
store.db.dbType=mysql
store.db.url=jdbc:mysql://192.168.28.130:3306/seata?useUnicode=true
store.db.driverClassName=com.mysql.jdbc.Driver
store.db.user=root
store.db.password=root
store.db.minConn=5
store.db.maxConn=30
store.db.globalTable=global_table
store.db.branchTable=branch_table
store.db.queryLimit=100
store.db.lockTable=lock_table
store.db.maxWait=5000

service.vgroupMapping 为应用对应的事务组名称，可通过seata.tx-service-group配置修改 store.mode为db，并修改数据库相关配置

4.初始化seata的nacos配置:

cd conf
sh nacos-config.sh 192.168.28.130

成功后在nacos的配置列表中能看到seata的相关配置: 5. 初始化数据库: 创建一个名为 seata 的数据库，并执行一下sql https://github.com/seata/seata/blob/develop/script/server/db/mysql.sql

6. 启动seata-server:

sh bin/seata-server.sh -p 8091 -h 192.168.28.130

3.3 应用配置

1. 初始化数据库:

• 执行脚本 seata-demo.sql

需在业务相关的数据库中添加 undo_log 表，用于保存需要回滚的数据

2.修改配置: demo中的每个服务各自修改配置文件

• bootstrap.yml修改nacos地址
• application.yml 修改数据库配置

3.配置数据源代理: Seata是通过代理数据源实现分布式事务，所以需要配置io.seata.rm.datasource.DataSourceProxy的Bean，且是@Primary默认的数据源，否则事务不会回滚，无法实现分布式事务

public class DataSourceProxyConfig {
    @Bean
    @ConfigurationProperties(prefix = "spring.datasource")
    public DruidDataSource druidDataSource() {
        return new DruidDataSource();
    }

    @Primary
    @Bean
    public DataSourceProxy dataSourceProxy(DruidDataSource druidDataSource) {
        return new DataSourceProxy(druidDataSource);
    }
}

因为使用了mybatis的starter所以需要排除DataSourceAutoConfiguration，不然会产生循环依赖:

@SpringBootApplication(exclude = {DataSourceAutoConfiguration.class})

4.事务发起者添加全局事务注解:

• 事务发起者 business-service 添加 @GlobalTransactional 注解

@GlobalTransactional
public void placeOrder(String userId) {
    ......
}