1.7 KiB
1.7 KiB
分布式事务： Saga模式
Saga模型
- 每个Saga都由一系列子事务Ti组成
- 每个子事务Ti都有其对应的补偿动作Ci，补偿操作用于对Ti操作产生的结果进行撤销
Saga的执行顺序
- T1, T2, T3, ... ,Tn（全部执行成功）
- T1， T2, T3, ..., Tj, Cj, Cj-1,... , C1 (执行出错之后回滚之前所有成功的子事务)
执行出错时，Saga的恢复策略
- 向后恢复（backword recovery），对所有已经完成的子事务进行补偿操作，任一子事务Ti执行失败，撤销掉之前所有执行成功的子事务，使得整个Saga的执行结果都撤销
- 向前恢复（forward recovery），重新尝试失败的事务。假设每个事务最终都会执行成功。其执行顺序为T1, ... Tj(失败), Tj（重试）,...,...,Tn。该种情况下并不需要Ci操作对子事务Ti的操作结果进行撤销
Saga模式的结构
Saga的嵌套结构只允许存在两个层次：
- 顶层的Saga
- 简单的子事务
Saga特性
- 在外层（各个Sagas都在执行时，各个Sagas在执行过程中已经提交的子事务Ti，其执行结果对其他Sagas可见），隔离性并无法被满足，Sagas可能看到其他Sagas的执行结果
- 每个子事务都是一个独立事务，各个子事务为独立的原子行为
Saga ACID
- 原子性：正常情况下可以保证
- 一致性：执行过程中，可能会有A库和B库违反一致性要求的情况，但是最终成功之后是一致的
- 隔离性：Sagas A能看到Sagas B部分执行的执行结果
- 持久性：对于Sagas中的子事务Ti，其执行完成之后就会commit，而其撤销操作则是会调用Ci对已经提交的操作进行撤销操作