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

seata at使用

news 2025/7/22 15:11:35

seata at使用

下载

修改配置

seata-server-0.9.0.zip解压到指定目录并修改conf目录下的file.conf配置文件。

主要修改：自定义事务组名称+事务日志存储模式为db+数据库连接信息。

创建seata数据库

修改配置

conf目录下的registry.conf配置文件，修改注册信息

启动nacos

具体nacos使用方式请自行学习

启动seata-server

运行bin/seata-server.bat

使用

引入包

项目引入seata的starter，即可使用seata（注意，与seata版本对应）。

<groupId>com.alibaba.cloud</groupId>

<artifactId>spring-cloud-starter-alibaba-seata</artifactId>

<artifactId>seata-all</artifactId>

<groupId>io.seata</groupId>

</exclusion>

</exclusions>

</dependency>

<groupId>io.seata</groupId>

<artifactId>seata-all</artifactId>

</dependency>

AI写代码

XML

配置seata

spring:

cloud:

alibaba:

seata:

tx-service-group: fsp_tx_group

我们只需要@GlobalTransactional注解标注在业务方法上，即可开启分布式事务！

案例测试

一、简介

Seata 是一款开源的分布式事务解决方案，致力于提供高性能和简单易用的分布式事务服务。Seata 将为用户提供了 AT、TCC、SAGA 和 XA 事务模式，为用户打造一站式的分布式解决方案

二、应用集成Seata使用AT模式的前提：

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

三、AT模式的整体机制是由两阶段提交协议的演变：

一阶段：业务数据和回滚日志记录在同一个本地事务中提交，释放本地锁和连接资源
二阶段：
- 提交异步化，非常快速地完成
- 回滚通过一阶段的回滚日志进行反向补偿

四、Seata的术语

TC（Transaction Coordinator）事务协调器：就是Seata，负责维护全局事务和分支事务的状态，驱动全局事务提交或回滚
TM（Transaction Manager）事务管理器：标注全局@GlobalTransactional启动入口动作的微服务模块（比如订单模块），它是事务的发起者，负责定义全局事务的范围，并根据TC 维护的全局事务和分支事务状态，做出开始事务、提交事务、回滚事务的决议
RM（Resource Manager）资源管理器：就是mysql数据库本身，可以是多个RM，负责管理分支事务上的资源，向 TC注册分支事务，汇报分支事务状态，驱动分支事务的提交或回滚

执行过程

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

五、Seata AT模式一阶段整体操作流程如下图所示：

一阶段：准备阶段

业务 SQL 解析与执行：
- RM 拦截业务 SQL，解析 SQL 类型（如 update、insert）、表名、条件等信息
- 执行 SQL 前，查询并保存数据的前镜像（before image），即修改前的数据状态
生成回滚日志：
- 执行 SQL 后，查询并保存数据的后镜像（after image），即修改后的数据状态
- 将前镜像（before image）、后镜像（after image）以及 SQL信息组成回滚日志（undo log），插入到 undo_log 表中
注册分支事务：
- RM 会注册一个分支事务到事务协调者TC中，保持在Seata的 branch_table表中，并申请全局锁（Seata的lock_table表中），确保事务隔离性
提交本地事务：
- 业务数据和回滚日志在同一个本地事务中提交，释放本地锁和连接资源，并向TC报告事务状态

六、Seata AT模式二阶段整体操作流程如下图所示：

二阶段提交

提交：
- 如果所有分支事务成功，TC 通知 RM 提交全局事务
- RM 异步删除 undo_log 记录和 Seata的行锁，完成事务提交

二阶段回滚

回滚：
- 如果任一分支事务失败，TC 通知 RM 回滚全局事务
- RM 回滚方式根据 undo_log 记录中的 "before image" 还原业务数据；但在还原前要首先要校验脏写，对比"数据库当前业务数据和 "after image" 如果两份数据完全一致就说明没有脏写，可以还原业务数据
- 删除 undo_log 记录和 Seata的 lock_table表中锁记录，完成事务回滚

七、AT案例演示：

AT模式只需要将配置中的data-source-proxy-mode: XA改为AT，或者是直接去除这一行配置即可

AT模式会使用到我们前面执行过脚本的几个数据库表:

回滚日志表：undo_log
分支事务表：branch_table
全局事务表：global_table
全局锁表：lock_table

全局事务表跟分支事务表是一对多的关系，一个全局事务对应多个分支事务

测试正常流程

我们这里把余额表的数据修改回原来的money=1000、库存表的数据修改回 count = 10

发起请求：http://localhost:8082/order?userId=user112233&commodityCode=storage112233&count=1&money=200

当断点停这里的时候，我们看db_account和db_order两个数据库的undo_log表，在这两个表中各自生成了一条日志记录，

xid都为：192.168.3.1:8091:5215564685333463148，这说明他们确实是在同一个全局事务当中

再看订单表和余额表，可以看到数据库中都是提交了的

我们再把断点放开，可以看到日志表的两条记录都被删除了，这也印证了我们上面的原理图

测试回滚流程

我们再次把余额表的数据修改回原来的money=1000、库存表的数据修改回 count = 10。

用样打个断点

发起请求：http://localhost:8082/order?userId=user112233&commodityCode=storage112233&count=11&money=200

这回请求的库存 count 为11，而库存为10，明显是不够的，所以肯定会报错

当上图断点到扣减库存这里的时候，我们看订单和余额对应的快照日志表，新增了各一条日志，可以看到他们的全局事务 xid 是相同的

我们看一下余额的快照信息 rollback_info:

这里主要记录了前置镜像beforeImage和后置镜像afterImage，也就是我们说的快照，可以看到他的valuew值，前置的（扣减前的余额）为1000，后置的（扣减后的余额）为800，它恢复的时候就是先查询后置的value是否跟现在的value相等，如果相等，则恢复成前置镜像的value值。如果不相等，默认他会在一定的时间内重试5次

<span style="color:#000000"><span style="background-color:#eeeeee"><code class="language-perl">  {<span style="color:#a31515">"@class"</span>: <span style="color:#a31515">"io.seata.rm.datasource.undo.BranchUndoLog"</span>,<span style="color:#a31515">"xid"</span>: <span style="color:#a31515">"192.168.3.1:8091:5215564685333463152"</span>,<span style="color:#a31515">"branchId"</span>: <span style="color:#880000">5215564685333463154</span>,<span style="color:#a31515">"sqlUndoLogs"</span>: [<span style="color:#a31515">"java.util.ArrayList"</span>,[{<span style="color:#a31515">"@class"</span>: <span style="color:#a31515">"io.seata.rm.datasource.undo.SQLUndoLog"</span>,<span style="color:#a31515">"sqlType"</span>: <span style="color:#a31515">"UPDATE"</span>,<span style="color:#a31515">"tableName"</span>: <span style="color:#a31515">"account_tbl"</span>,<span style="color:#a31515">"beforeImage"</span>: {<span style="color:#a31515">"@class"</span>: <span style="color:#a31515">"io.seata.rm.datasource.sql.struct.TableRecords"</span>,<span style="color:#a31515">"tableName"</span>: <span style="color:#a31515">"account_tbl"</span>,<span style="color:#a31515">"rows"</span>: [<span style="color:#a31515">"java.util.ArrayList"</span>,[{<span style="color:#a31515">"@class"</span>: <span style="color:#a31515">"io.seata.rm.datasource.sql.struct.Row"</span>,<span style="color:#a31515">"fields"</span>: [<span style="color:#a31515">"java.util.ArrayList"</span>,[{<span style="color:#a31515">"@class"</span>: <span style="color:#a31515">"io.seata.rm.datasource.sql.struct.Field"</span>,<span style="color:#a31515">"name"</span>: <span style="color:#a31515">"id"</span>,<span style="color:#a31515">"keyType"</span>: <span style="color:#a31515">"PRIMARY_KEY"</span>,<span style="color:#a31515">"type"</span>: <span style="color:#880000">4</span>,<span style="color:#a31515">"value"</span>: <span style="color:#880000">1</span>},{<span style="color:#a31515">"@class"</span>: <span style="color:#a31515">"io.seata.rm.datasource.sql.struct.Field"</span>,<span style="color:#a31515">"name"</span>: <span style="color:#a31515">"money"</span>,<span style="color:#a31515">"keyType"</span>: <span style="color:#a31515">"NULL"</span>,<span style="color:#a31515">"type"</span>: <span style="color:#880000">4</span>,<span style="color:#a31515">"value"</span>: <span style="color:#880000">1000</span>}]]}]]},<span style="color:#a31515">"afterImage"</span>: {<span style="color:#a31515">"@class"</span>: <span style="color:#a31515">"io.seata.rm.datasource.sql.struct.TableRecords"</span>,<span style="color:#a31515">"tableName"</span>: <span style="color:#a31515">"account_tbl"</span>,<span style="color:#a31515">"rows"</span>: [<span style="color:#a31515">"java.util.ArrayList"</span>,[{<span style="color:#a31515">"@class"</span>: <span style="color:#a31515">"io.seata.rm.datasource.sql.struct.Row"</span>,<span style="color:#a31515">"fields"</span>: [<span style="color:#a31515">"java.util.ArrayList"</span>,[{<span style="color:#a31515">"@class"</span>: <span style="color:#a31515">"io.seata.rm.datasource.sql.struct.Field"</span>,<span style="color:#a31515">"name"</span>: <span style="color:#a31515">"id"</span>,<span style="color:#a31515">"keyType"</span>: <span style="color:#a31515">"PRIMARY_KEY"</span>,<span style="color:#a31515">"type"</span>: <span style="color:#880000">4</span>,<span style="color:#a31515">"value"</span>: <span style="color:#880000">1</span>},{<span style="color:#a31515">"@class"</span>: <span style="color:#a31515">"io.seata.rm.datasource.sql.struct.Field"</span>,<span style="color:#a31515">"name"</span>: <span style="color:#a31515">"money"</span>,<span style="color:#a31515">"keyType"</span>: <span style="color:#a31515">"NULL"</span>,<span style="color:#a31515">"type"</span>: <span style="color:#880000">4</span>,<span style="color:#a31515">"value"</span>: <span style="color:#880000">800</span>}]]}]]}}]]}
</code></span></span>

再看订单表和余额表，订单已经创建完成、余额也已经扣减成功。

我们放开断点，可以看到库存的的服务报错了，那么前面的 db_order 的订单表和 db_account 的余额表就会回滚，而回滚就是根据 undo_log 表的回滚日志

再看回滚后的数据

八、官网示例说明工作原理机制

以一个示例来说明整个 AT 分支的工作过程

业务表：product

AT 分支事务的业务逻辑：

<span style="color:#000000"><span style="background-color:#eeeeee"><code class="language-sql"><span style="color:#0000ff">update</span> product <span style="color:#0000ff">set</span> name <span style="color:#ab5656">=</span> <span style="color:#a31515">'GTS'</span> <span style="color:#0000ff">where</span> name <span style="color:#ab5656">=</span> <span style="color:#a31515">'TXC'</span>;
</code></span></span>

一阶段

过程：

解析 SQL：得到 SQL 的类型（UPDATE），表（product），条件（where name = ‘TXC’）等相关的信息
查询前镜像：根据解析得到的条件信息，生成查询语句，定位数据
```
select id, name, since from product where name = 'TXC';
```

得到前镜像：

<span style="color:#000000"><span style="background-color:#eeeeee"><code class="language-sql"><span style="color:#880000">1</span>、执行业务 <span style="color:#0000ff">SQL</span>：更新这条记录的 name 为 ‘GTS’<span style="color:#880000">2</span>、查询后镜像：根据前镜像的结果，通过 主键 定位数据<span style="color:#0000ff">select</span> id, name, since <span style="color:#0000ff">from</span> product <span style="color:#0000ff">where</span> id <span style="color:#ab5656">=</span> <span style="color:#880000">1</span>;
</code></span></span>

得到后镜像：

1、插入回滚日志：把前后镜像数据以及业务 SQL 相关的信息组成一条回滚日志记录，插入到 UNDO_LOG 表中

<span style="color:#000000"><span style="background-color:#eeeeee"><code class="language-json">  {<span style="color:#ff0000">"branchId"</span>: <span style="color:#880000">641789253</span>,<span style="color:#ff0000">"undoItems"</span>: [{<span style="color:#ff0000">"afterImage"</span>: {<span style="color:#ff0000">"rows"</span>: [{<span style="color:#ff0000">"fields"</span>: [{<span style="color:#ff0000">"name"</span>: <span style="color:#a31515">"id"</span>,<span style="color:#ff0000">"type"</span>: <span style="color:#880000">4</span>,<span style="color:#ff0000">"value"</span>: <span style="color:#880000">1</span>}, {<span style="color:#ff0000">"name"</span>: <span style="color:#a31515">"name"</span>,<span style="color:#ff0000">"type"</span>: <span style="color:#880000">12</span>,<span style="color:#ff0000">"value"</span>: <span style="color:#a31515">"GTS"</span>}, {<span style="color:#ff0000">"name"</span>: <span style="color:#a31515">"since"</span>,<span style="color:#ff0000">"type"</span>: <span style="color:#880000">12</span>,<span style="color:#ff0000">"value"</span>: <span style="color:#a31515">"2014"</span>}]}],<span style="color:#ff0000">"tableName"</span>: <span style="color:#a31515">"product"</span>},<span style="color:#ff0000">"beforeImage"</span>: {<span style="color:#ff0000">"rows"</span>: [{<span style="color:#ff0000">"fields"</span>: [{<span style="color:#ff0000">"name"</span>: <span style="color:#a31515">"id"</span>,<span style="color:#ff0000">"type"</span>: <span style="color:#880000">4</span>,<span style="color:#ff0000">"value"</span>: <span style="color:#880000">1</span>}, {<span style="color:#ff0000">"name"</span>: <span style="color:#a31515">"name"</span>,<span style="color:#ff0000">"type"</span>: <span style="color:#880000">12</span>,<span style="color:#ff0000">"value"</span>: <span style="color:#a31515">"TXC"</span>}, {<span style="color:#ff0000">"name"</span>: <span style="color:#a31515">"since"</span>,<span style="color:#ff0000">"type"</span>: <span style="color:#880000">12</span>,<span style="color:#ff0000">"value"</span>: <span style="color:#a31515">"2014"</span>}]}],<span style="color:#ff0000">"tableName"</span>: <span style="color:#a31515">"product"</span>},<span style="color:#ff0000">"sqlType"</span>: <span style="color:#a31515">"UPDATE"</span>}],<span style="color:#ff0000">"xid"</span>: <span style="color:#a31515">"xid:xxx"</span>}
</code></span></span>

1、提交前，向 TC 注册分支：申请 product 表中，主键值等于 1 的记录的全局锁

2、本地事务提交：业务数据的更新和前面步骤中生成的 UNDO LOG 一并提交

3、将本地事务提交的结果上报给 TC

二阶段-回滚

1、收到 TC 的分支回滚请求，开启一个本地事务，执行如下操作

2、通过 XID 和 Branch ID 查找到相应的 UNDO LOG 记录

3、数据校验：拿 UNDO LOG 中的后镜与当前数据进行比较，如果有不同，说明数据被当前全局事务之外的动作做了修改。这种情况，需要根据配置策略来做处理，默认会有重试机制

4、根据 UNDO LOG 中的前镜像和业务 SQL 的相关信息生成并执行回滚的语句：

<span style="color:#000000"><span style="background-color:#eeeeee"><code class="language-bash">update product <span style="color:#0000ff">set</span> name = <span style="color:#a31515">'TXC'</span> <span style="color:#0000ff">where</span> <span style="color:#0000ff">id</span> = 1;a、提交本地事务。并把本地事务的执行结果（即分支事务回滚的结果）上报给 TC
</code></span></span>

二阶段-提交

1、收到 TC 的分支提交请求，把请求放入一个异步任务的队列中，马上返回提交成功的结果给 TC

2、异步任务阶段的分支提交请求将异步和批量地删除相应 UNDO LOG 记录

参考

分布式事务SEATA的AT模式的简单使用_seata at使用步骤-CSDN博客

cnblogs.com/jock766/p/18577856

查看全文

http://www.dtcms.com/a/291512.html