Spring Cloud同步场景分布式事务怎样做？试试Seata
一、概述
在微服务架构下，虽然我们会尽量避免分布式事务，但是只要业务复杂的情况下这是一个绕不开的问题，如何保证业务数据一致性呢？本文主要介绍同步场景下使用 Seata 的 AT模式 来解决一致性问题。
Seata 是 阿里巴巴 开源的 一站式分布式事务解决方案 中间件，以 高效 并且对业务 0 侵入 的方式，解决 微服务 场景下面临的分布式事务问题
二、Seata介绍
整体事务逻辑是基于 两阶段提交 的模型，核心概念包括以下3个角色：
- TM ：事务的发起者。用来告诉 TC，全局事务的开始，提交，回滚。
- RM ：具体的事务资源，每一个 RM 都会作为一个分支事务注册在 TC。
- TC ：事务的协调者seata-server，用于接收我们的事务的注册，提交和回滚。
目前的 Seata 有两种模式可使用分别对应不同业务场景
2.1. AT模式
该模式适合的场景：
ACID JDBC
一个典型的分布式事务过程：
-
TM向TC申请开启一个全局事务，全局事务创建成功并生成一个全局唯一的XID。 -
XID在微服务调用链路的上下文中传播。 -
RM向TC注册分支事务，将其纳入 XID 对应全局事务的管辖。 -
TM向TC发起针对XID的全局提交或回滚决议。 -
TC调度XID下管辖的全部分支事务完成提交或回滚请求。
2.2. MT模式
该模式逻辑类似 TCC ，需要 自定义实现 prepare 、 commit 和 rollback 的逻辑，适合 非关系型数据库 的场景
三、Seata场景样例
模拟一个简单的用户下单场景，4个子工程分别是 Bussiness(事务发起者) 、 Order(创建订单) 、 Storage(扣减库存) 和 Account(扣减账户余额)
3.1. 部署Seata的Server端
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配置
-
修改 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
需在业务相关的数据库中添加 undo_log 表，用于保存需要回滚的数据
3.2.2. 添加registry.conf配置
直接把 seata-server 中的 registry.conf 复制到每个服务中去即可，不需要修改
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
正文到此结束
- 本文标签： 同步 git bean map Spring cloud App http 数据库 id 数据 JDBC 开源 db Service sql 一致性 CEO 部署 src tar Master UI 注册中心 mybatis 测试 Action 阿里巴巴 模型 GitHub druid lib IO 配置 bus 分布式事务 spring 下载 集群 springboot NSA 微服务 dataSource https ORM 安装 配置中心 HTML mysql ACE cat 分布式 Bootstrap Proxy
- 版权声明： 本文为互联网转载文章，出处已在文章中说明(部分除外)。如果侵权，请联系本站长删除，谢谢。
- 本文海报： 生成海报一 生成海报二
热门推荐
相关文章
Loading...
![[HBLOG]公众号](https://www.liuhaihua.cn/img/qrcode_gzh.jpg)
