分布式事务（三）Seata分布式事务框架-AT模式介绍

傷城~ 2023-03-01 12:38 80阅读 0赞

### 文章目录 ###

*  Seata介绍
 *  Seata AT事务方案
 *   *   *  业务场景
     *  Seata AT基本原理
     *   *  第一阶段：执行各分支事务
         *  第二阶段：控制全局事务最终提交
         *  第二阶段：控制全局事务最终回滚
     *  Seata AT具体工作机制
     *   *  第一阶段：执行分支事务
         *  第二阶段：控制全局事务最终回滚
         *  第二阶段：控制全局事务最终提交

# Seata介绍 #

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

2019 年 1 月，阿里巴巴中间件团队发起了开源项目 Fescar（Fast & EaSy Commit And Rollback），和社区一起共建开源分布式事务解决方案。Fescar 的愿景是让分布式事务的使用像本地事务的使用一样，简单和高效，并逐步解决开发者们遇到的分布式事务方面的所有难题。

Fescar 开源后，蚂蚁金服加入 Fescar 社区参与共建，并在 Fescar 0.4.0 版本中贡献了 TCC 模式。

为了打造更中立、更开放、生态更加丰富的分布式事务开源社区，经过社区核心成员的投票，大家决定对 Fescar 进行品牌升级，并更名为 Seata，意为：Simple Extensible Autonomous Transaction Architecture，是一套一站式分布式事务解决方案。

Seata 融合了阿里巴巴和蚂蚁金服在分布式事务技术上的积累，并沉淀了新零售、云计算和新金融等场景下丰富的实践经验，但要实现适用于所有的分布式事务场景的愿景，仍有很长的路要走。

# Seata AT事务方案 #

Seata 的 AT 模式（Automatic Transaction）是一种**无侵入**的分布式事务解决方案。下面结合具体业务场景来分析其执行的原理。

### 业务场景 ###

订单系统

![业务][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zODMwNTQ0MA_size_16_color_FFFFFF_t_70_pic_center]  
当用户下订单时，执行以下三步流程：

1.  **订单系统**保存订单
2.  订单系统调用**库存服务**，减少商品库存
3.  订单系统调用**账户服务**，扣减用户金额

这三步要作为一个整体事务进行管理，要么整体成功，要么整体失败。

## Seata AT基本原理 ##

Seata AT 事务分两个阶段来管理全局事务：  
**第一阶段：** 执行各分支事务  
**第二阶段：** 控制全局事务最终提交或回滚

### 第一阶段：执行各分支事务 ###

微服务系统中，各服务之间无法相互感知事务是否执行成功，这时就需要一个专门的服务，来协调各个服务的运行状态。这个服务称为 TC（Transaction Coordinator），事务协调器。

![tc][]

订单系统开始执行保存订单之前，首先启动 TM（Transaction Manager，事务管理器），由 TM 向 TC 申请开启一个全局事务：

![TM][]  
这时TC会产生一个**全局事务ID**，称为 **XID**，并将 XID 传回 TM：

![xid][]

这样就开启了**全局事务**！

全局事务开启后，开始执行创建订单的业务。首先执行保存订单，这时会先启动一个 RM（Resource Manager，资源管理器），并将 XID 传递给 RM。

![rm][]

RM 负责对分支事务（即微服务的本地事务）进行管理，并与 TC 通信，上报分支事务的执行状态、接收全局事务的提交或回滚指令。

RM 首先会使用 XID 向 TC 注册分支事务，将分支事务纳入对应的全局事务管辖。

![rm][rm 1]

现在可以执行保存订单的分支事务了。一旦分支事务执行成功，RM 会上报事务状态：

![tx][]  
TC 收到后，会将该状态信息传递到 TM：  
![o][]

到此，保存订单过程结束。下面是调用库存服务，减少商品库存，与订单的执行过程相同。

首先调用库存服务，启动 RM，并传递 XID：

![s][]

库存服务的 RM 使用 XID 向 TC 进行注册，纳入全局事务管辖：

![s][s 1]

执行本地事务成功后上报状态，TC会将状态发送给TM：

![s][s 2]

相同的，完成账户分支事务：

![a][]

### 第二阶段：控制全局事务最终提交 ###

现在，TM（全局事务管理器）收集齐了全部分支事务的成功状态，它会进行决策，确定全局事务成功，向 TC 发送全局事务的提交请求：

![tm][]

然后，TC 会向所有 RM 发送提交操作指令，RM 会完成最终提交操作：

![tc][tc 1]  
到此，全局事务全部提交完成！

### 第二阶段：控制全局事务最终回滚 ###

上面是全局事务执行成功的情况，下面再来看看事务执行失败的情况。

假设订单业务执行过程中，扣减账户金额这一步分支事务执行失败，那么失败状态对TC上报，然后再发送给TM：

![a][a 1]  
TM 会进行决策，确定全局事务**失败**，向 TC 发送全局事务的**回滚**请求：

![tm][tm 1]  
然后，TC 会向所有 RM 发送回滚操作指令，RM 会完成最终回滚操作：

![tc][tc 2]

## Seata AT具体工作机制 ##

以上了解了 Seata AT 的基本原理、工作流程，那么 Seata 具体是如何实现全局事务的提交和回滚操作呢？下面来分析 Seata 的具体工作机制。

### 第一阶段：执行分支事务 ###

以全面订单业务中的库存服务为例，库存表中存在一条商品的库存信息：

![s][s 3]  
现在要执行业务操作减少库存，从50件减少到40件：

![s][s 4]

执行修改库存业务操作前， 会先取出旧的库存信息：

![s][s 5]

现在可以修改库存了：

![s][s 6]  
接着，取出更新后的新数据：

![s][s 7]

接下来，会把旧数据和新数据合并起来，保存到一个事务回滚日志表：undo\_log表：  
![s][s 8]

至此，第一阶段，分支事务完成，将状态上报给TC：  
![a][a 2]

### 第二阶段：控制全局事务最终回滚 ###

假如全局事务失败，那么第一阶段已提交的分支事务要执行回滚操作。

首先会收到来自 TC 的全局事务回滚指令：

![s][s 9]  
接下来，根据事务回滚日志（undo\_log）表的记录，将商品恢复成旧的库存数据：  
![s][s 10]  
然后删除事务日志，最终完成第二阶段回滚操作：

![s][s 11]

### 第二阶段：控制全局事务最终提交 ###

上面是全局事务回滚操作。如果全局事务成功，要完成最终提交，AT模式最终提交操作非常简单，只需要删除日志数据即可。

首先接收到 TC 的全局事务提交指令：

![s][s 12]  
接着，直接删除事务日志，就完成了第二阶段提交操作：

![a][a 3]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zODMwNTQ0MA_size_16_color_FFFFFF_t_70_pic_center]: /images/20230208/cf218373f5ab47e69ceb94d3457ee560.png
[tc]: /images/20230208/b952e965d0ba4c94afa53b997597e974.png
[TM]: /images/20230208/48f96af9db4749cf852fda3268544228.png
[xid]: /images/20230208/0910b20d4eb149589dd021ce17fbfc4c.png
[rm]: /images/20230208/80db3a54f78b4dc98898044d012ec34b.png
[rm 1]: /images/20230208/96dc435c79f8406097a764ecec2867c2.png
[tx]: /images/20230208/821a18d64d1847deb5e464f296573970.png
[o]: /images/20230208/6cd41954ef7d4be299f461fe19c547c3.png
[s]: /images/20230208/220a59226175493296da073ed16ce19a.png
[s 1]: /images/20230208/1c89bc1b20ac4bd29cb296af68776612.png
[s 2]: /images/20230208/137b76ed2607438aada411a582563c5b.png
[a]: /images/20230208/3bb9cab6540047ce9594c92b837d1176.png
[tm]: /images/20230208/afb1b41a8bfc4e62a45ba2898e29e59f.png
[tc 1]: /images/20230208/b112254b3a394145a25819115399551a.png
[a 1]: /images/20230208/70cea573b9b0435886f84bd0b4e52493.png
[tm 1]: /images/20230208/f0388951a924498ebb5cfac28e8b8111.png
[tc 2]: /images/20230208/c331c8f006f9445db5ea194afeec16db.png
[s 3]: /images/20230208/b981e20571a4494da4943ba02f9b471e.png
[s 4]: /images/20230208/e5c901b605424f09877c8393be7bc432.png
[s 5]: /images/20230208/0312bc59e51540bca4580849e245e3ba.png
[s 6]: /images/20230208/30ca717d87044ca497ea12681fae5d32.png
[s 7]: /images/20230208/aa94edbb26794d8baa2acb9c6260f194.png
[s 8]: /images/20230208/af206ee6dce94229822053884fcda9b7.png
[a 2]: /images/20230208/37b73d5c23a04c37935250ab5a0abdfe.png
[s 9]: /images/20230208/e92de06c2a114eefb22af868efdd4d04.png
[s 10]: /images/20230208/e705e6349cfe48539fc39bd0075329ae.png
[s 11]: /images/20230208/4ba1d6ed3c6d4e5e90fa8e71bfdb8b1c.png
[s 12]: /images/20230208/dd238d7a9d284908890adece592acccd.png
[a 3]: /images/20230208/be8381a4fd724cf28783ba975c3738f8.png