Spring Cloud同步场景分布式事务怎样做？试试Seata
作者简介：
陶陶老师
10年后端工作经验，
专注Java、SpringBoot、SpringCloud、分布式系统/微服务、中间件等领域。
公众号：陶陶技术笔记
一、概述
在微服务架构下，虽然我们会尽量避免分布式事务，但是只要业务复杂的情况下这是一个绕不开的问题，如何保证业务数据一致性呢？本文主要介绍同步场景下使用Seata的AT模式来解决一致性问题。
Seata是 阿里巴巴 开源的 一站式分布式事务解决方案 中间件，以 高效 并且对业务 0 侵入 的方式，解决 微服务 场景下面临的分布式事务问题
二、Seata介绍
整体事务逻辑是基于 两阶段提交 的模型，核心概念包括以下3个角色：
TM：事务的发起者。用来告诉 TC，全局事务的开始，提交，回滚。
RM：具体的事务资源，每一个 RM 都会作为一个分支事务注册在 TC。
TC：事务的协调者seata-server，用于接收我们的事务的注册，提交和回滚。
目前的Seata有两种模式可使用分别对应不同业务场景
2.1. AT模式
该模式适合的场景：
基于支持本地 ACID 事务的关系型数据库。
Java 应用，通过 JDBC 访问数据库。
![`QHAF1B6)LT]E_ZWMNH3N%G.png](https://img.haomeiwen.com/i5954723/07a9cb25134579ef.png?imageMogr2/auto-orient/strip%7CimageView2/2/w/1240)
一个典型的分布式事务过程：
TM 向 TC 申请开启一个全局事务，全局事务创建成功并生成一个全局唯一的 XID。
XID 在微服务调用链路的上下文中传播。
RM 向 TC 注册分支事务，将其纳入 XID 对应全局事务的管辖。
TM 向 TC 发起针对 XID 的全局提交或回滚决议。
TC 调度 XID 下管辖的全部分支事务完成提交或回滚请求。
2.2. MT模式
该模式逻辑类似TCC，需要 自定义实现 prepare、commit和rollback的逻辑，适合 非关系型数据库 的场景
Q@BLE82TA6WC{Y4)2CV%AVS.png
3.1. 部署Seata的Server端
![XX}NRSRV]MW}0IJO(ZDWEUP.png](https://img.haomeiwen.com/i5954723/6338e91e04662a50.png?imageMogr2/auto-orient/strip%7CimageView2/2/w/1240)
Discover注册、Config配置和Store存储模块默认都是使用file只能适用于单机，我们安装的时候分别改成使用nacos和Mysql以支持server端集群
3.1.1. 下载最新版本并解压
https://github.com/seata/seata/releases
3.1.2. 修改 conf/registry.conf 配置
注册中心和配置中心默认是file这里改为nacos；设置 registry 和 config 节点中的type为nacos，修改serverAddr为你的nacos节点地址。
registry {
type = "nacos"
nacos {
serverAddr = "192.168.28.130"
namespace = "public"
cluster = "default"
}
}
config {
type = "nacos"
nacos {
serverAddr = "192.168.28.130"
namespace = "public"
cluster = "default"
}
}
3.1.3. 修改 conf/nacos-config.txt配置
![7%~V2FGU62DFBOG]TBN3S5N(1).png](https://img.haomeiwen.com/i5954723/e7fdca45637c63cc.png?imageMogr2/auto-orient/strip%7CimageView2/2/w/1240)
修改 service.vgroup_mapping 为自己应用对应的名称；如果有多个服务，添加相应的配置
默认组名为${spring.application.name}-fescar-service-group，可通过spring.cloud.alibaba.seata.tx-service-group配置修改
修改 store.mode 为db，并修改数据库相关配置
3.1.4. 初始化seata的nacos配置
cd conf
sh nacos-config.sh 192.168.28.130
成功后在nacos的配置列表中能看到seata的相关配置
3.1.5. 初始化数据库
执行conf/db_store.sql中的脚本
3.1.6. 启动seata-server
sh bin/seata-server.sh -p 8091 -h 192.168.28.130
3.2. 应用配置
3.2.1. 初始化数据库
执行脚本 seata-demo.sql
CREATE DATABASE seata-demo DEFAULT CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci;
USE seata-demo;
--==========================回滚日志表==========================
-- 此脚本必须初始化在你当前的业务数据库中，用于AT 模式XID记录。与server端无关（注：业务数据库）
drop table undo_log;
CREATE TABLE undo_log (
id bigint(20) NOT NULL AUTO_INCREMENT,
branch_id bigint(20) NOT NULL,
xid varchar(100) NOT NULL,
context varchar(128) NOT NULL,
rollback_info longblob NOT NULL,
log_status int(11) NOT NULL,
log_created datetime NOT NULL,
log_modified datetime NOT NULL,
ext varchar(100) DEFAULT NULL,
PRIMARY KEY (id),
UNIQUE KEY ux_undo_log (xid,branch_id)
) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8;
--==========================业务模拟表==========================
DROP TABLE IF EXISTS storage_tbl;
CREATE TABLE storage_tbl (
id int(11) NOT NULL AUTO_INCREMENT,
commodity_code varchar(255) DEFAULT NULL,
count int(11) DEFAULT 0,
PRIMARY KEY (id),
UNIQUE KEY (commodity_code)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;
DROP TABLE IF EXISTS order_tbl;
CREATE TABLE order_tbl (
id int(11) NOT NULL AUTO_INCREMENT,
user_id varchar(255) DEFAULT NULL,
commodity_code varchar(255) DEFAULT NULL,
count int(11) DEFAULT 0,
money int(11) DEFAULT 0,
PRIMARY KEY (id)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;
DROP TABLE IF EXISTS account_tbl;
CREATE TABLE account_tbl (
id int(11) NOT NULL AUTO_INCREMENT,
user_id varchar(255) DEFAULT NULL,
money int(11) DEFAULT 0,
PRIMARY KEY (id)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;
-- 初始化库存模拟数据
INSERT INTO storage_tbl (id, commodity_code, count) VALUES (1, 'P001', 9999999);
INSERT INTO account_tbl (id, user_id, money) VALUES ('1', 'U001', 10000);
需在业务相关的数据库中添加 undo_log 表，用于保存需要回滚的数据
3.2.2. 添加registry.conf配置
直接把 seata-server 中的registry.conf复制到每个服务中去即可，不需要修改
D@H)TTRQU3123AE[~)]UN_T(1).png
3.2.3. 修改配置
demo中的每个服务各自修改配置文件
bootstrap.yml 修改nacos地址
application.yml 修改数据库配置
3.2.4. 配置数据源代理
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})
3.2.5. 事务发起者添加全局事务注解
事务发起者 business-service 添加 @GlobalTransactional 注解
@GlobalTransactional
public void placeOrder(String userId) {
......
}
3.3. 测试
提供两个接口测试
事务成功：扣除库存成功 > 创建订单成功 > 扣减账户余额成功
http://localhost:9090/placeOrder
事务失败：扣除库存成功 > 创建订单成功 > 扣减账户余额失败，事务回滚
http://localhost:9090/placeOrderFallBack
3.4. demo地址
https://gitee.com/zlt2000/microservices-platform/tree/master/zlt-demo/seata-demo
作者简介：
陶陶老师
10年后端工作经验，
专注Java、SpringBoot、SpringCloud、分布式系统/微服务、中间件等领域。
公众号：陶陶技术笔记
本文已经获得陶陶老师授权转发，其他人若有兴趣转载，请直接联系作者授权。
