原子性(Atomicity),可以理解为一个事务内的式事识所有操作要么都执行,要么都不执行。分布
一致性(Consistency),式事识可以理解为数据是分布满足完整性约束的,也就是式事识不会存在中间状态的数据,比如你账上有400,分布我账上有100,式事识你给我打200块,分布此时你账上的式事识钱应该是200,我账上的分布钱应该是300,不会存在我账上钱加了,式事识你账上钱没扣的分布中间状态。
隔离性(Isolation),式事识指的分布是多个事务并发执行的时候不会互相干扰,即一个事务内部的数据对于其他事务来说是隔离的。
持久性(Durability),云服务器指的是一个事务完成了之后数据就被永远保存下来,之后的其他操作或故障都不会对事务的结果产生影响。Redis 的事务不能保证所有操作要么都执行要么都不执行。
Redis事务中的某个命令失败了,之后的命令还是会被处理,Redis 不会停止命令,意味着也不会回滚。
Redis认为如果命令出错是语法使用错误,应该在开发的时候就被检测出来,不应在生产环境中出现。回滚并不能免于编程错误。是一种强一致性设计
引入一个事务协调者的角色来协调管理各参与者(也可称之为各本地资源)的提交和回滚,二阶段分别指的是准备(投票)和提交两个阶段
正常情况
准备阶段:协调者会给各参与者发送准备命令,理解成除了提交事务之外啥事都做完。同步等待所有资源的响应进入提交阶段。 提交阶段:协调者则向所有参与者发送提交事务命令(提交事务或者回滚事务),网站模板然后等待所有事务都提交成功之后,返回事务执行成功。异常情况
若准备阶段有一个参与者返回失败,那么协调者就会向所有参与者发送回滚事务的请求,即分布式事务执行失败。协调者故障分析
2PC 是同步阻塞协议 协调者有超时机制 协调者是一个单点,存在单点故障问题 协调者在发送准备命令之前挂了,事务没开始,无影响 协调者在发送准备命令之后挂了,亿华云处于事务资源锁定的状态,事务无法执行,阻塞其他操作 协调者在发送回滚事务命令之前挂了,事务无法继续提交,第一阶段准备成功的参与者都阻塞 协调者在发送回滚事务命令之后挂了,大的概率都会回滚成功,资源都会释放。但是如果出现网络分区问题,某些参与者将因为收不到命令而阻塞 协调者在发送提交事务命令之前挂了,资源都阻塞 协调者在发送提交事务命令之后挂了,大的概率都会回滚成功,资源都会释放。但是如果出现网络分区问题,某些参与者将因为收不到命令而阻塞通过选举得到新协调者
每个参与者自身的状态只有自己和协调者知道,因此新协调者无法通过在场的参与者的状态推断出挂了的参与者是什么情况 极端情况下还是无法避免数据不一致问题总结
同步阻塞的,尽量保证强一致性的分布式事务 总体而言效率低,并且存在单点故障问题,在极端条件下存在数据不一致的风险 不能做到数据一致,需要补偿机制TCC
Try 指的是预留,即资源的预留和锁定,注意是预留。 Confirm 指的是确认操作,这一步其实就是真正的执行了。 Cancel 指的是撤销操作,可以理解为把预留阶段的动作撤销了。思想上类似2PC,TCC 就是通过代码人为实现了两阶段提交
TCC模型还有个事务管理者的角色,变成多点,引入集群。用来记录TCC全局事务状态并提交或者回滚事务
引入超时,超时后进行补偿,并且不会锁定整个资源
优势
TCC可以跨数据库、跨不同的业务系统来实现事务劣势
TCC 对业务的侵入较大和业务紧耦合撤销和确认操作的执行可能需要重试,因此还需要保证操作的幂等
利用各系统本地的事务来实现分布式事务
有一张存放本地消息的表,一般都是放在数据库中,然后在执行业务的时候将业务的执行和将消息放入消息表中的操作放在同一个事务中,保证消息放入本地表中业务肯定是执行成功的
后台任务定时去读取本地消息表,筛选出还未成功的消息再调用对应的服务,服务更新成功了再变更消息的状态。
重试就得保证对应服务的方法是幂等的,而且一般重试会有最大次数,超过最大次数可以记录下报警让人工处理
实现的是最终一致性
利用MQ事务
先给 Broker 发送事务消息即半消息,半消息不是说一半消息,而是这个消息对消费者来说不可见,然后发送成功后发送方再执行本地事务
再根据本地事务的结果向 Broker 发送 Commit 或者RollBack命令
RocketMQ的发送方会提供一个反查事务状态接口,如果一段时间内半消息没有收到任何操作请求,那么 Broker 会通过反查接口得知发送方事务是否执行成功,然后执行Commit 或者RollBack命令。
如果是 Commit 那么订阅方就能收到这条消息,然后再做对应的操作,做完了之后再消费这条消息即可
如果是RollBack那么订阅方收不到这条消息,等于事务就没执行过
消息事务实现的也是最终一致性
长事务的解决方案,更适合于“业务流程长、业务流程多”的场景
特别是针对参与事务的服务是遗留系统服务,此类服务无法提供TCC模式下的三个接口,就可以采用Saga模式
针对每一个分布式事务的每个执行操作或者是步骤都是一个 Ti,例如扣减库存是T1、创建订单是T2、支付服务是T3。那么针对每个Ti都对应一个补偿动作Ci,例如回复库存C1、订单回滚C2、支付回滚C3
优势
一阶段提交本地事务,无锁,高性能 参与者可异步执行,高吞吐 补偿服务易于实现,因为一个更新操作的反向操作是比较容易理解的劣势
不保证隔离性(可以看到其他事务) Saga操作模式更像发电子邮件,发出的电子邮件是正确的,接收者按正常方式解读。如果邮件发错了,就再发一封告诉接收者,请忽略上一封邮件。但有时候这个操作已经不可逆了。 举例 分布式事务内先给用户A充值,然后给用户B扣减余额,如果在给A用户充值成功,在事务提交以前,A用户把余额消费掉了,如果事务发生回滚,这时则没有办法进行补偿了。 应对方法 业务流程设计时遵循“宁可长款,不可短款”的原则,长款意思是客户少了钱机构多了钱,以机构信誉可以给客户退款,反之则是短款,少的钱可能追不回来了,所以在业务流程设计上一定是先扣款; 有些业务场景可以允许让业务最终成功,在回滚不了的情况下可以继续重试完成后面的流程,达到最终一致性的目的两种恢复策略
向前恢复:对于执行不通过的事务,会尝试重试事务,这里有一个假设就是每个子事务最终都会成功。这种方式适用于必须要成功的场景
向后恢复:在执行事务失败时,补偿所有已完成的事务,是“一退到底”的方式。
两种模式
编排
是一种去中心化的模式,参与者之间通过消息机制进行沟通,通过监听器的方式监听其他参与者发出的消息,从而执行后续的逻辑处理控制
定义一个控制类,它会告诉参与者(服务)应该执行哪些操作(子事务)。 Saga控制类通过命令以及异步回复的方式与参与者进行交互。