Seata 分布式事务

本地事务

大多数场景下，我们的应用都只需要操作单一的数据库，这种情况下的事务称之为本地事务 (Local Transaction)。本地事务的ACID特性是数据库直接提供支持。

常见分布式事务解决方案

2PC两阶段提交协议：

2PC问题

等 ) ，所以也无法顺利处理上一个事务。

3. 数据不一致 Commit 事务过程中 Commit 请求 /Rollback 请求可能因为协调者宕机或协调者与参与者网络问题丢失，那么就导致了部分参与者没有收到 Commit/Rollback 请求，而其他参与者则正常收到执行了 Commit/Rollback 操作，没有收到请求的参与者则继续阻塞。这时，参与者之间的数据就不再一致了。

当参与者执行 Commit/Rollback 后会向协调者发送 Ack ，然而协调者不论是否收到所有的参与者的

Ack ，该事务也不会再有其他补救措施了，协调者能做的也就是等待超时后像事务发起者返回一个“ 我不确定该事务是否成功” 。

4. 环境可靠性依赖 协调者 Prepare 请求发出后，等待响应，然而如果有参与者宕机或与协调者之间的网络中断，都会导致协调者无法收到所有参与者的响应，那么在 2PC 中，协调者会等待一定时间，然后超时后，会触发事务中断，在这个过程中，协调者和所有其他参与者都是出于阻塞的。这种机制对网络问题常见的现实环境来说太苛刻了。

2. AT 模式介绍

AT 模式是一种无侵入的分布式事务解决方案。阿里 Seata 框架，实现了该模式。在 AT 模式下，用户只 需关注自己的“ 业务 SQL” ，用户的 “ 业务 SQL” 作为一阶段， Seata 框架会自动生成事务的二阶段提交和回滚操作。

一阶段：

Seata 会拦截 " 业务 SQL" ，解析 SQL 语义

查询 “ 业务 SQL” 要更新的业务数据，在业务数据被更新前，将其保存成 “before image”

执行 “ 业务 SQL” ，更新业务数据

查询更新后的数据，将其保存成 “after image”

将 before image 和 after image 保存至 Undo Log 表中

生成行锁

以上操作全部在一个数据库事务内完成，这样保证了一阶段操作的原子性。

Seata的三大角色

# 库存表
CREATE TABLE `stock_tab` (
`id` int(11) NOT NULL AUTO_INCREMENT, #库存ID
`product_id` int(11) NULL DEFAULT NULL, #商品ID
`count` int(11) NULL DEFAULT 0, #商品数量
PRIMARY KEY (`id`) USING BTREE
) ENGINE = InnoDB AUTO_INCREMENT = 1 CHARACTER SET = utf8 COLLATE =
utf8_general_ci ROW_FORMAT = Compact;
CREATE TABLE `undo_log` (
`id` bigint(20) NOT NULL AUTO_INCREMENT,
`branch_id` bigint(20) NOT NULL,
`xid` varchar(100) NOT NULL,
`context` varchar(128) NOT NULL,
`rollback_info` longblob NOT NULL,
`log_status` int(11) NOT NULL,
`log_created` datetime NOT NULL,
`log_modified` datetime NOT NULL,
PRIMARY KEY (`id`),
UNIQUE KEY `ux_undo_log` (`xid`,`branch_id`)
) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8;
# 订单表
CREATE TABLE `order_tab` (
`id` int(11) NOT NULL AUTO_INCREMENT,
`product_id` int(11) NULL DEFAULT 0 COMMENT '商品id',
`total_amount` int(11) NULL DEFAULT 0 COMMENT '总金额',
`status` int(255) NULL DEFAULT NULL COMMENT '0->待付款；1->待发货',
PRIMARY KEY (`id`) USING BTREE
) ENGINE = InnoDB AUTO_INCREMENT = 1 CHARACTER SET = utf8 COLLATE =
utf8_general_ci ROW_FORMAT = Compact;
CREATE TABLE `undo_log` (
`id` bigint(20) NOT NULL AUTO_INCREMENT,
`branch_id` bigint(20) NOT NULL,
`xid` varchar(100) NOT NULL,
`context` varchar(128) NOT NULL,
`rollback_info` longblob NOT NULL,
`log_status` int(11) NOT NULL,
`log_created` datetime NOT NULL,
`log_modified` datetime NOT NULL,
PRIMARY KEY (`id`),
UNIQUE KEY `ux_undo_log` (`xid`,`branch_id`)
) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8