news 2026/8/6 12:30:35

【SpringCloud | 第5篇】Seata分布式事务

作者头像

张小明

前端开发工程师

1.2k 24
文章封面图
【SpringCloud | 第5篇】Seata分布式事务

文章目录

  • Seata
  • Seata——架构原理
  • Seata——实现分布式事务
  • Seata——原理
    • 1. 二阶提交协议
    • 2. 四种事务模式

Seata

官方文档:https://seata.apache.org/zh-cn/docs/user/configurations/

在单体服务中,一个请求只会在一个服务中,连接一个数据库,对事务的回滚就可以使用 @Transational 进行回滚,保证数据的一致性。
在微服务项目中,一个请求可能会涉及多个服务,每个服务会单独连接数据库,此时的 @Transactional 注解无法保证微服务下数据的一致性。

Seata 用于解决分布式下的数据一致性。

Seata——架构原理

  • TC(Transaction Coordinator)事务协调者:维护全局和分支事务的状态,驱动全局事务提交或回滚。
  • TM(Transaction Manager)事务管理器:定义全局事务的范围:开始全局事务、提交或回滚全局事务。
  • RM(Resource Manager)资源管理器:管理分支事务处理的资源,与TC交谈以注册分支事务和报告分支事务的状态,并驱动分支事务提交或回滚。

Seata——实现分布式事务

在项目中配置Seata之后,
只需要在 TM 事务管理器的方法上添加@GlobalTransactional注解,在其他本地事务加@EnableTransactionManagement,@Transactional,即可保证事务的一致性。

Seata——原理

1. 二阶提交协议

  1. 第一阶段——本地事务提交
    (1)解析SQL
    (2)生成前镜像:根据 SQL 中的 where 条件,查询修改操作前的数据,称为前镜像
    (3)执行业务 SQL
    (4)生成后镜像:根据 id 查询修改后的数据,称为后镜像
    (5)插入回滚日志undo_log:将前镜像和后镜像保存到 undo_log 日志中
    (6)注册分支事务:在TC中申请一个全局锁,锁定操作的数据防止其他人操作。TC的全局锁相当于MySQL的行级别锁,只锁操作的数据。
    (7)本地事务提交:将业务数据和 undo_log 日志提交保存
    (8)向 TC 汇报事务执行状态
  2. 第二阶段
    各事务分支均成功——分支提交
    (1)收到 TC 提交响应请求,立即响应OK
    (2)给异步任务队列添加异步任务
    (3)异步和批量删除 undo_log 日志记录
    存在某个事务分支失败——分支回滚
    (1)先找到uodo_log记录(通过XID,BranchID)
    (2)数据校验,后镜像和当前数据是否一致,不一致说明当前数据被其他操作给篡改了,需要配置相应的策略;如果一致就说明一起ok,只需要回滚。
    (3)回滚数据到前镜像的内容,完成后删除uodo_log记录。

2. 四种事务模式

官方文档:https://seata.apache.org/zh-cn/docs/user/mode/at

  1. AT 模式
    默认模式。
    一阶段:业务数据和回滚日志记录在同一个本地事务中提交,释放本地锁和连接资源。
    二阶段:(1)提交异步化,非常快速地完成。(2)回滚通过一阶段的回滚日志进行反向补偿。
  2. XA 模式
    第一阶段不会提交数据,阻塞事务请求,在第二阶段确认提交再提交或者回滚。全局锁+MySQL行锁在第一阶段就开启,事务一开始就用阻塞模式,性能差。
    AT和XA区别:AT第一阶段执行完SQL释放行锁;XA是到第二阶段才提交SQL导致行锁从开始到最后,阻塞时间长性能差。但二者都是一直持有seata的全局锁的。
  3. Saga 模式
    Saga 模式是 SEATA 提供的长事务解决方案。
    对于短时间内执行不完的事务。例如请假审批,其他模式都用了锁,如果长期锁在那是对系统是非常大的阻塞。Saga是基于消息队列实现。
  4. TCC 模式
    主要是广义上的事务,需要写侵入式的代码。需要业务系统自行实现 Try,Confirm,Cancel 三个操作
    举例:业务需要三个事务,一个事务改数据库,一个发短信,一个发邮件,这就用AT和XA行不通了,无法回滚,如果全局事务失败,只能进行补偿性操作,例如再发邮件和短信提醒对方扣款失败或者订单失败等。
版权声明: 本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若内容造成侵权/违法违规/事实不符,请联系邮箱:809451989@qq.com进行投诉反馈,一经查实,立即删除!
网站建设 2026/8/6 17:43:16

当粒子群学会“刹车“:用IPSO-SVM玩转时序预测

IPSO-SVM时序预测,基于非线性权重粒子群(IPSO)优化算法优化支持向量机(SVM)的时间序列预测 改进后粒子群权重为:非线性权重递减 程序已经调试好,无需更改代码替换数据集即可运行数据格式为excel 1、运行环境要求MATLAB版本为2018b及其以上 2…

作者头像 李华
网站建设 2026/8/5 9:13:39

告别数据孤岛!BookStack 搭配 cpolar 让知识库随身带

文章目录前言1. 安装Docker2. Docker镜像源添加方法3. 创建并启动BookStack容器4. 登录与简单使用5. 公网远程访问本地BookStack5.1 内网穿透工具安装5.2 创建远程连接公网地址5.3 使用固定公网地址远程访问**BookStack 解决了知识管理的整合问题,cpolar 则突破了局…

作者头像 李华
网站建设 2026/8/5 16:25:32

Transformer模型完全指南:从零开始学习大模型架构【收藏必学】

Transformer是谷歌2017年提出的神经网络架构,通过自注意力机制捕捉单词间依赖关系。以翻译任务为例,其工作流程包括:1)文本编码为嵌入向量(含位置信息);2)线性变换生成查询、键、值向量;3)Softmax归一化计算权重&#…

作者头像 李华
网站建设 2026/8/6 4:54:16

数据访问:MyBatisMybatis-Plus

Spring Boot集成MyBatisSpring Boot集成MyBatis的步骤添加依赖 在pom.xml文件中添加MyBatis和数据库驱动依赖。以MySQL为例&#xff1a;<dependency><groupId>org.mybatis.spring.boot</groupId><artifactId>mybatis-spring-boot-starter</artifact…

作者头像 李华
网站建设 2026/8/5 7:24:04

springboot集成h2内存数据库运行测试用例

springboot集成h2内存数据库运行测试用例 首先引入我们的依赖 引入h2的依赖和spring的依赖 dependencies {implementation org.springframework.boot:spring-boot-h2consoleimplementation org.springframework.boot:spring-boot-starter-data-jdbc// 引入h2内存数据库runtimeO…

作者头像 李华
网站建设 2026/8/5 7:18:58

【期末复习02】-分析题和改错题作业

文章目录【期末复习02】-分析题和改错题项目结构分析题01分析题02分析题03分析题04二、程序改错题(20分)项目结构改错题01改错题02【期末复习02】-分析题和改错题 项目结构 分析题01 分析题02 分析题03 分析题04 二、程序改错题(20分) 项目结构 改错题01 考察知识点&#xff…

作者头像 李华