Seata入门系列【8】Seata之AT模式执行流程解析

刺骨的言语ヽ痛彻心扉 2024-02-21 09:27 56阅读 0赞

## 1 启动阶段 ##

1.  自动加载各种Bean及配置信息

![在这里插入图片描述][2ee33c74cf7a49d9827a0e9f770bdcd6.png]

1.  初始化TM(事务管理器)

![在这里插入图片描述][11649f32e7f942e38775e55074e33324.jpeg]

1.  初始化RM(资源管理器)

![在这里插入图片描述][6f0cf13b70cc4a579631c79c81cf39ca.jpeg]

1.  初始化分布式事务客户端完成，代理数据源

![在这里插入图片描述][9dd7e7d5b0004c748b7ad19b5cc2444e.jpeg]

1.  连接TC（seata服务端），注册RM

![在这里插入图片描述][224f5e78c2d1403c8461c7c3e724e5c0.jpeg]

1.  连接TC（seata服务端），注册TM

![在这里插入图片描述][e0dad625c5ca4b57b6a93eb7bb7262e0.jpeg]

1.  扫描并动态代理开启了分布式事务的Bean

![在这里插入图片描述][7f2da7feb35d437083e5612bcd5c3959.jpeg]  
![在这里插入图片描述][b8d7a9f459924d46882e4cb1f0b88e57.png]

## 2 执行阶段 ##

### 2.1 一阶段TM 开启全局事务 ###

使用了@GlobalTransactional注解标识的方式执行时，因为进行了动态代理，会进入到拦截器GlobalTransactionalInterceptor

@GlobalTransactional(rollbackFor = Throwable.class, timeoutMills = 300000)

拦截器会获取到当前执行的类、方法、@GlobalTransactional注解的属性。

接着事务管理器TM 会开启全局事务，和seata 服务端进行通信，获取到全局事务xid并绑定到当前线程RootContext中，标记事务状态为开始。

![在这里插入图片描述][0b9c3969791f4c9295525664c9c44e6a.png]  
此时在global\_table 表中会插入一条全局事务信息。

![在这里插入图片描述][35531afb117f4de1996ec71a902a0b4e.png]

### 2.2 一阶段 TM 执行本地事务 ###

开启全局事务后，进入到本地执行方法，执行业务逻辑。

因为Seata 对数据源进行了代理，所以在SQL 执行时，会进入到代理的PreparedStatement（PreparedStatementProxy），首先解析得到 SQL 的类型（UPDATE），表（product），条件（where name = ‘TXC’）等相关的信息。

接着进入到ExecuteTemplate，如果是SELECT操作，则不处理直接执行，其他操作（INSERT、UPDATE、DELETE、SELECT\_FOR\_UPDATE）会创建不同的SQL执行器。

比如 UPDATE操作 会创建UpdateExecutor执行器，执行器在执行方法时，会构建前后镜像，比如以下SQL语句：

# 修改当前账户的余额
    UPDATE account_tbl  SET user_id=?,money=?  WHERE id=?

构建前置镜像时，会通过主键，查询当前数据更新前的状态。

SELECT id, user_id, money FROM account_tbl WHERE id = ? FOR UPDATE

前置镜像记录了更新前该记录的各个字段及对应的值。  
![在这里插入图片描述][fbb805de632648fc8ecc7258f764cbdf.png]  
前置镜像构建以后，执行正常业务操作，然后构建后置镜像，记录了更新后该记录的各个字段及对应的值。

![在这里插入图片描述][4424403ee5e74601948f60525dd1a586.png]  
在远程注册分支事务时，TC 会创建分支事务对象BranchSession，并尝试获取当前记录的全局锁，在查询lock\_table时没有数据，这是会插入一条全局锁数据。

注册后，TC 会在branch\_table 表中插入一条分支事务信息。

![在这里插入图片描述][0b623e4ea4234f669bde0ef52694fb91.jpeg]  
在lock\_table表中插入一条全局锁信息。  
![在这里插入图片描述][4638615b617845ab9ed24de791151357.jpeg]  
分支事务和全局锁插入成功后，分支事务调用 UndoLog 管理器，在当前本地数据库的undo\_log 表中，插入一条回滚日志记录。  
![在这里插入图片描述][64d84ce3ad394cfcb87312cabbe69c33.png]

### 2.3 一阶段 执行远程分支事务 ###

因为使用的是spring-cloud-starter-alibaba-seata，自带了Feign 远程传递xid 的支持，在发起Feign 远程请求时，可以看到将xid 塞入了消息头中。  
![在这里插入图片描述][35193da04b6d4bf4a41efb79d8147609.jpeg]  
在被调用方，spring-cloud-starter-alibaba-seata也提供了支持，使用Spring MVC 中的HandlerInterceptor将消息头中的TX\_XID绑定到RootContext中。  
![在这里插入图片描述][f0548f4001154a88af0bcb43a6136a37.png]  
和之前一样，远程的分支事务，执行时因为远程这个方法是没有@GlobalTransactional注解的，所以不会进入到拦截器，但是代理了数据源，所以在执行SQL 时，还是会进入到代理的Executor中。

执行SQL 时，发现存在xid ,则表明这是一个分布式事务，则会进行分支事务注册处理，之后和第二步一样。

调用TC 注册分支事务时，TC 会查询数据库表中全局事务信息，创建分支事务，可以看到被调用方也生成了当前操作记录的全局锁。

![在这里插入图片描述][f42c35fa140443cf816d498a2f8ec71b.png]  
最后，该远程服务也在TC 数据库中存储了自己的分支事务信息和全局锁信息。  
![在这里插入图片描述][6f40f02751f34c47a95d076c006d8224.jpeg]  
![在这里插入图片描述][660e48544efd4fb08bfea722744ca590.jpeg]

### 2.4 二阶段-提交 ###

TM 事务管理器负责开始全局事务、提交或回滚全局事务。所以二阶段提交和回滚都是由发起全局事务的那个服务负责的，也是就使用了@GlobalTransactional注解的服务。

二阶段的核心代码在TransactionalTemplate类中：

try {
        
                        	// 执行业务逻辑
                            rs = business.execute();
                        } catch (Throwable var17) {
        
                            ex = var17;
                            // 发生异常，全局回滚
                            this.completeTransactionAfterThrowing(txInfo, tx, var17);
                            throw var17;
                        }
    					// 无异常，全局提交
                        this.commitTransaction(tx);
                        ex = rs;
                        return ex;

没有异常，会进行全局提交，这里有个配置参数client.tm.commitRetryCount，提交重试次数，提交时依然是调用TC 服务端，提交失败，会重试默认5次。

TC 收到TM全局提交请求后，会删除分支事务全局锁记录，开启提交事件发送请求到各分支事务，各分支收到 TC 的分支提交请求，把请求放入一个异步任务的队列中，马上返回提交成功的结果给 TC。异步任务阶段的分支提交请求将异步和批量地删除相应 UNDO LOG 记录。

### 2.5 二阶段-回滚 ###

TM 所在服务发起远程调用发生异常时，会向TC 发送回滚请求，大致流程和全局提交一致。

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

*  通过 XID 和 Branch ID 查找到相应的 UNDO LOG 记录。
 *  数据校验：拿 UNDO LOG 中的后镜与当前数据进行比较，如果有不同，说明数据被当前全局事务之外的动作做了修改。
 *  根据 UNDO LOG 中的前镜像和业务 SQL 的相关信息生成并执行回滚的语句：  
    update product set name = ‘TXC’ where id = 1;
 *  提交本地事务。并把本地事务的执行结果（即分支事务回滚的结果）上报给 TC。

![在这里插入图片描述][74f6c23a8cf84011b9de9d6772f713fe.png]

[2ee33c74cf7a49d9827a0e9f770bdcd6.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/02/21/6f0e150d0fae4be9a4b752bb9b94dfa6.png
[11649f32e7f942e38775e55074e33324.jpeg]: https://image.dandelioncloud.cn/pgy_files/images/2024/02/21/1b97c14add5f47bba48946959d143de8.png
[6f0cf13b70cc4a579631c79c81cf39ca.jpeg]: https://image.dandelioncloud.cn/pgy_files/images/2024/02/21/564b91370d354316ad5a4e0a160cace1.png
[9dd7e7d5b0004c748b7ad19b5cc2444e.jpeg]: https://image.dandelioncloud.cn/pgy_files/images/2024/02/21/7c966dfb6b10438c9a3912bf9fbb8850.png
[224f5e78c2d1403c8461c7c3e724e5c0.jpeg]: https://image.dandelioncloud.cn/pgy_files/images/2024/02/21/3c87c39506cc413c90436148614b697b.png
[e0dad625c5ca4b57b6a93eb7bb7262e0.jpeg]: https://image.dandelioncloud.cn/pgy_files/images/2024/02/21/dc2d00cadc304145842c199f04e94a3b.png
[7f2da7feb35d437083e5612bcd5c3959.jpeg]: https://image.dandelioncloud.cn/pgy_files/images/2024/02/21/7bb16e57eb35464abb981a7d7af3c0e0.png
[b8d7a9f459924d46882e4cb1f0b88e57.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/02/21/62702f6d92cd49528b0dfc50f1647767.png
[0b9c3969791f4c9295525664c9c44e6a.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/02/21/6fb3176a85c34f56bd2f2593391e549a.png
[35531afb117f4de1996ec71a902a0b4e.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/02/21/fdfeedd880974fc3af71bcdd467cee3f.png
[fbb805de632648fc8ecc7258f764cbdf.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/02/21/1c1b1895b0094f629244a935d33c828f.png
[4424403ee5e74601948f60525dd1a586.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/02/21/bbc89a0011fe4d49959a28f1571e512a.png
[0b623e4ea4234f669bde0ef52694fb91.jpeg]: https://image.dandelioncloud.cn/pgy_files/images/2024/02/21/40551292fefb441fb10abeb406350e92.png
[4638615b617845ab9ed24de791151357.jpeg]: https://image.dandelioncloud.cn/pgy_files/images/2024/02/21/f2f2ff10e4db461193564e1789de0814.png
[64d84ce3ad394cfcb87312cabbe69c33.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/02/21/67317ed618b14ff5a69679c54ed96c83.png
[35193da04b6d4bf4a41efb79d8147609.jpeg]: https://image.dandelioncloud.cn/pgy_files/images/2024/02/21/3df37bb4495644c984d07acd8b3863f4.png
[f0548f4001154a88af0bcb43a6136a37.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/02/21/803823506ae2468089df07f1ecd0714e.png
[f42c35fa140443cf816d498a2f8ec71b.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/02/21/e9f53ae784c14671b635ca03613d5a72.png
[6f40f02751f34c47a95d076c006d8224.jpeg]: https://image.dandelioncloud.cn/pgy_files/images/2024/02/21/3aa28463d3954ca0ba726c9338ea9d96.png
[660e48544efd4fb08bfea722744ca590.jpeg]: https://image.dandelioncloud.cn/pgy_files/images/2024/02/21/e922c889ff9341bc9e434f8558059d7b.png
[74f6c23a8cf84011b9de9d6772f713fe.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/02/21/ba5884433e634b6e996f54c9b2f523a7.png