前言

分布式应用痛点

分布式应用有一个比较明显的问题就是，一个业务流程通常需要几个服务来完成，业务的一致性很难保证。为了保障业务一致性，每一步都要在 catch 里去处理前面所有的“回滚”操作，可读性及维护性差，开发效率低下。

分布式事务解决方案

分布式事务解决方案中的2PC、3PC、TCC等，大多是提供了事务协调器这一角色，协调业务中的各个事务要么全部成功，要么全部失败，不用在业务中嵌套处理“回滚事务”，更好的解决分布式事务中一致性问题。

Seata

Seata 是一款开源的分布式事务解决方案，致力于提供高性能和简单易用的分布式事务服务。为用户提供了 AT、TCC、SAGA 和 XA 事务模式，打造一站式的分布式解决方案。其定义了3个角色完成分布式事务的工作。

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

其协调流程如下
在这里插入图片描述

TM 向 TC 申请开启一个全局事务。
TC 创建全局事务后返回全局唯一的 XID，XID 会在全局事务的上下文中传播。
RM 向 TC 注册分支事务，该分支事务归属于拥有相同 XID 的全局事务。
TM 向 TC 发起全局提交或回滚。
TC 调度 XID 下的分支事务完成提交或者回滚。

Seata AT模式

AT模式是Seata默认的分布式解决方案

前提

基于支持本地 ACID 事务的关系型数据库。
依赖回滚日志表UNDO_LOG，以业务表形式存在，需要单独创建。
Java 应用，通过 JDBC 访问数据库。

工作机制

AT模式属于两阶段提交协议的演变：

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

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

业务表：stock

Field	Type	Key
id	bigint(20)	PRI
goods_id	bigint(20)
count	bigint(20)

业务逻辑：

update stock set count = 20 where goods_id = 100001;

一阶段

执行过程：

解析 SQL：得到 SQL 的类型（UPDATE），表（stock），条件（where goods_id = 100001）等相关的信息。
查询前镜像：根据解析得到的条件信息，生成查询语句，定位数据。
```
select id,goods_id,count from stock where goods_id = 100001;
```
得到前镜像

id goods_id count
1 100001 0
执行业务sql，count 更新为20。
查询后镜像：根据前镜像的结果，通过主键定位数据。
```
select id, goods_id,count from stock where id = 1;
```
得到后镜像

id goods_id count
1 100001 20

id	goods_id	count
1	100001	0

id	goods_id	count
1	100001	20

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

{
	"branchId": xxxxxxxx,
	"undoItems": [{
		"afterImage": {
			"rows": [{
				"fields": [{
					"name": "id",
					"type": 4,
					"value": 1
				}, {
					"name": "goods_id",
					"type": 4,
					"value": 100001
				}, {
					"name": "count",
					"type": 4,
					"value": 0
				}]
			}],
			"tableName": "stock"
		},
		"beforeImage": {
			"rows": [{
				"fields": [{
					"name": "id",
					"type": 4,
					"value": 1
				}, {
					"name": "goods_id",
					"type": 4,
					"value": 100001
				}, {
					"name": "count",
					"type": 4,
					"value": 20
				}]
			}],
			"tableName": "stock"
		},
		"sqlType": "UPDATE"
	}],
	"xid": "xid:xxx"
}

提交事务前，向 TC 注册分支：申请 stock 表中，主键值等于 1 的记录的 全局锁 。
本地事务提交：业务数据的更新和前面步骤中生成的 UNDO LOG 一并提交。
将本地事务提交的结果上报给 TC。

二阶段-提交

收到 TC 的分支提交请求，把请求放入一个异步任务的队列中，马上返回提交成功的结果给 TC。
异步任务阶段批量地删除相应 UNDO LOG 记录。

二阶段-回滚

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

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

Seata TCC模式

前提

回顾TCC解决方案，其 Try、Confirm、Cancel 3 个方法均由业务编码实现。

以传统的订单、库存、账户服务为例

在 try 阶段尝试预留资源，插入订单、扣减库存、扣减金额，这三个服务都是要提交本地事务的，这里可以把资源转入中间表。
在 commit 阶段，再把 try 阶段预留的资源转入最终表。
而在 cancel 阶段，把 try 阶段预留的资源进行释放，比如把账户金额返回给客户的账户。

TCC 模式在 try 阶段的锁定资源并不是真正意义上的锁定，而是真实提交了本地事务，将资源预留到中间态，并不需要阻塞等待，因此效率比其他模式要高。

工作机制

Seata中所谓 TCC 模式，是指支持把自定义的分支事务纳入到全局事务的管理中，不依赖于底层数据资源的事务支持，其工作流程如下：

一阶段 prepare 行为：调用 自定义 的 prepare 逻辑。
二阶段 commit 行为：调用 自定义 的 commit 逻辑。
二阶段 rollback 行为：调用 自定义 的 rollback 逻辑。

在自定义的逻辑中，可以操作redis完成数据的一致性以提升业务性能。

Seata Saga模式

Saga模式是SEATA提供的长事务解决方案，在Saga模式中，业务流程中每个参与者都提交本地事务，当出现某一个参与者失败则补偿前面已经成功的参与者，一阶段正向服务和二阶段补偿服务都由业务开发实现。

实现机制

目前SEATA提供的Saga模式是基于状态机引擎来实现的，机制是：

通过状态图来定义服务调用的流程并生成 json 状态语言定义文件。
状态图中一个节点可以是调用一个服务，节点可以配置它的补偿节点。
状态图 json 由状态机引擎驱动执行，当出现异常时状态引擎反向执行已成功节点对应的补偿节点将事务回滚。
可以实现服务编排需求，支持单项选择、并发、子流程、参数转换、参数映射、服务执行状态判断、异常捕获等功能

示例状态图:
在这里插入图片描述

Seata XA模式

前提

支持XA 事务的数据库。
Java 应用，通过 JDBC 访问数据库。

工作机制

在 Seata 定义的分布式事务框架内，利用事务资源（数据库、消息服务等）对 XA 协议的支持，以 XA 协议的机制来管理分支事务的一种事务模式。
在这里插入图片描述

执行阶段：
- 可回滚：业务 SQL 操作放在 XA 分支中进行，由资源对 XA 协议的支持来保证可回滚。
- 持久化：XA 分支完成后，执行 XA prepare，同样，由资源对 XA 协议的支持来保证持久化（即，之后任何意外都不会造成无法回滚的情况）
完成阶段：
- 分支提交：执行 XA 分支的 commit
- 分支回滚：执行 XA 分支的 rollback