事务
严格意义上的事务实现应该是具备原子性、一致性、隔离性和持久性,简称 ACID。
- 原子性(Atomicity),可以理解为一个事务内的所有操作要么都执行,要么都不执行。
- 一致性(Consistency),可以理解为数据是满足完整性约束的,也就是不会存在中间状态的数据。
- 隔离性(Isolation),指的是多个事务并发执行的时候不会互相干扰,即一个事务内部的数据对于其他事务来说是隔离的。
- 持久性(Durability),指的是一个事务完成了之后数据就被永远保存下来,之后的其他操作或故障都不会对事务的结果产生影响。
对于单数据库事务我们可以很好的使用数据库提供的事务机制保证数据安全。那对于单服务多个数据(意味着不同的数据库连接)如何保证事务。
分布式事务概念
- 2PC Two-Phase-Commit (协调者超时 回滚,占用连接)
- 3PC Three-Phase-Commit(2pc的第一阶段 拆成了 2个阶段,协调者和参与者都超时,pre超时是回滚,do 超时是提交)
分布式常规做法
分布式事务解决方案-消息队列-定时任务-本地事件表
分布式事务解决方案LCN(Lock Confirm notify)
分布式事务解决方案TCC(Try Confirm Cancel)
分布式事务解决方案Seata AT模式
AT 模式(总体原则就是通过回滚日志来实现事务回滚)
- 前提
基于支持本地 ACID 事务的关系型数据库。
Java 应用,通过 JDBC 访问数据库。
- 前提
- 整体机制
两阶段提交协议的演变:
- 整体机制
- 一阶段:业务数据和回滚日志记录在同一个本地事务中提交,释放本地锁和连接资源。
- 二阶段:
提交异步化,非常快速地完成。回滚通过一阶段的回滚日志进行反向补偿。
- 二阶段:
读隔离公共 for update SQL语句实现。
-
分布式事务解决方案Seata-TCC
业务写代码进行回滚,配合空提交等操作。
- 分布式事务解决方案-可靠消息服务-最大努力通知-事务消息
1、这种方案就是设置一个消息管理,预先注册事务try,然后本地事务提交后执行commit/rollback。
2、其他业务根据commit状态的消息进行处理后续逻辑。
3、和RocketMQ对应的机制类似,只是说自己实现了消息方案。
-
分布式事务解决方案RocketMQ 事务消息方案
半消息概念 ,执行事务前发送半消息,RocketMQ生产者回调本地事务执行方法,并返回事务ID。
本地执行完SQL后向事务处理表加入一条记录,并向RocketMQ发送消息确认或者取消
如果成功,则RocketMQ对外发布全消息
生产者同RocketMQ保持连接,可以定时回查没有被确认消息,如果存在事务说明已经成功处理。
待确认消息尝试回查一定次数(可配置)后丢掉,认为失败,则这阶段需要人工补偿
确认的消息回投递给下游业务,如果投递失败回加入死信队列。
综上,编写代码时会有一个生产者然后实现2个方法的回调1、本地提交,2、半消息回查。