Seata

简单可扩展自治事务框架
用1.0版本的

image.png

TC:seata服务器
TM
事务的参与方
RM
@GIobaltransactional
事务的发起方多
image.png

分布式事务的执行流程：

  • TM开启分布式事务（TM向TC注册全局事务记录）；
  • 按业务场景，编排数据库、服务等事务内资源（RM向TC汇报资源准备状态）
  • TM结束分布式事务，事务一阶段结束（TM通知TC提交/回滚分布式事务）
  • TC汇总事务信息，决定分布式事务是提交还是回滚；
  • TC通知所有RM提交/回滚资源，事务二阶段结束

TM:事务的发起方，@GlobalTransactional
RM：事务的参与方（订单、库存、账户）
TC：Seata服务器

AT模式如何做到对业务的无侵入

1、一阶段加载

业务数据和回滚日志记录在同一个本地事务中提交，释放本地锁和连接资源

在一阶段，Seata会拦截 “业务SQL”

1、解析SQL语义，找到“业务SQL”要更新的业务数据，在业务数据被更新前，将其保存成“before image”
e3、其保存成“after image”，最后生成锁。

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

image.png
行锁 image.png

2、二阶段提交

二阶段如是顺利提交的话，
因为“业务SQL”在一阶段已经提交至数据库，所以Seata只需将一阶段保存的快照和数据和行锁删掉，完成数据清理即可。
image.png

3、二阶段回滚

二阶段如果是回滚的话，Seata就需要回滚一阶段已经执行的“业务SQL”，还原业务数据，
回滚方式便是用“before image” 还原业务数据，但在还原前要首先进行校验脏写，对比“数据库当前业务数据”和“after image”，
如果两份数据完全一致就说明没有脏写，可以还原业务数据，如果不一致就说明有脏写，出现脏写就需要转人工处理。
image.png

  • 提交异常化，非常快速地完成。
  • 回滚通过一阶段的回滚日志进行反向补偿。

    debug

    补充

    image.png

image.png
global_table
image.png
branch_table
image.pngxid: IP+端口号+全局id

undo
image.png
rollbackinfo—->后面的JSON

lock_table
image.png
row_key为锁的那张表
transaction_id 为统一个事务的ID

image.png
beforeImage

afterImage
image.png
select age from t where id = 1; age = 22

update set age =28 where id =1;

select age from t where id =1 ;age =28

现在想要回退回去，需要