当前位置：首页 > news >正文

SpringCloud Seata集成分布式事务管理事务保护 XA AT两种模式的区别

news 2025/7/5 8:44:07

介绍

阿里巴巴的 Seata（Service Aligned Transaction Alternative）是一个开源的分布式事务解决方案，旨在解决微服务架构中跨服务、跨数据库的事务一致性问题。它可以帮助开发者管理分布式系统中的全局事务，确保在多个服务之间的事务一致性。

引入依赖

<!--seata-->
<dependency><groupId>io.seata</groupId><artifactId>seata-spring-boot-starter</artifactId><version>1.6.1</version>
</dependency>

配置

每个服务中引入

seata:registry: #注册中心的配置type: nacos #注册中心类型为nacosnacos:server-addr: 172.23.4.128:8848 #服务注册地址namespace: "" #命名空间group: DEFAULT_GROUP #默认DEFAULT_GROUPapplication: seata-server #服务名称tx-service-group: test #事务组名称service:vgroup-mapping: #事务与组的映射关系test: "default"

XA模式

阶段1：预提交阶段
参与事务的各个资源（如数据库）会锁定事务需要的资源并准备执行。此时，Seata 会询问每个参与者是否可以提交，参与者进行本地准备并响应是否可以提交。
阶段2：提交或回滚阶段
如果所有参与者都可以提交（即没有遇到错误），Seata 会发出全局提交请求；否则，发出回滚请求。
事务一致性：采用 XA 协议保证跨多个资源的事务的一致性，确保事务在分布式环境中能实现原子性操作。
资源协调：Seata 作为事务协调者，协调所有参与资源的提交与回滚，确保最终一致性。
回滚与补偿：若事务失败，Seata 会确保通过回滚来恢复到事务开始前的状态。
支持的数据库：Seata XA模式支持通过 XA 协议的数据库，常见的如 MySQL、Oracle 等，前提是这些数据库支持 XA 协议。

缺点
性能开销：XA 模式的两阶段提交协议需要多次通信和锁定资源，可能会导致性能下降，特别是在大规模、高并发的场景中。
支持的资源类型较少：XA 协议主要支持数据库等传统资源，对于一些新型的分布式资源（如消息队列、缓存等）可能支持不够好，或者实现较复杂。

开启XA模式
在全局配置中添加

seata:data-source-proxy-mode: XA #开启XA模式

开启事务

    @GetMapping("/pay")@GlobalTransactionalpublic SaResult pay(){//假设余额扣减String userId=StpUtil.getLoginIdAsString();LambdaUpdateWrapper<User> updateWrapper = new LambdaUpdateWrapper<>();updateWrapper.eq(User::getId, userId)  // 根据用户ID进行查询.setSql("play_num = play_num - 1");  // 扣减play_numberuserService.update(updateWrapper);if(true){  //模拟报错int i = 1 / 0;}goodsClient.delete();//删除return SaResult.ok();}

AT模式

主推的是AT模式，AT模式同样是分阶段提交的事务模型，缺弥补了XA模型中资源锁定周期过长的缺陷。AT模式会导致几毫秒的数据不一致因为立马提交了SQL语句。
运行步骤：
阶段一：注册事务分支->记录undo-log(数据快照) ->执行业务SQL并提交
阶段二：删除undo-log(数据快照)
在这里插入图片描述

因此如果使用AT模式需要给每一个微服务都添加undo-log表。

相关文档：https://seata.apache.org/zh-cn/docs/v1.5/overview/what-is-seata

创建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,PRIMARY KEY (`id`),UNIQUE KEY `ux_undo_log` (`xid`,`branch_id`)
) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8;