优雅实现多系统一致性补偿方案，稳！

01

前言

我们在开发的过程中，如果一个业务操作需要本地写MYSQL数据以及对第三方系统做写操作，那么这种流程就涉及到分布式系统一致性的问题，然而并非所有系统都能使用成熟的分布式事务方案

02

案例说明

详细解释下各系统作用：

• 单据系统： 财务报账，会提交很多信息（例如：报账事由、报账金额与明细）。同时也会生成财务凭证（不了解凭证也没关系，它就是给财务人员看的东西，对技术人员来说就是数据库的一堆数据）
• BPM系统：非常成熟的流程管理系统，以非常直观的方式来实现流程的搭配，不了解的可以自行百度扫盲。在此案例中，需要使用BPM的两个能力：1）调用API，审核通过 2）调用API，获取流程的待审人
• SAP系统： 财务专用系统，不用过多了解，只要知道在财务审核完成后，会将单据系统生成的凭证数据通过API调用的方式发送给SAP即可

1. 保存业务数据+记录审核日志
2. 调用BPM接口，审核通过
3. 调用BPM接口，获取最新待审人
4. 如果没有待审人，说明已经审完，生成凭证并推送SAP

03

风险分析

单据系统内，没有任何日志记录，用户操作的数据也没有保留下来，但BPM那边却已经审核通过了，这在任何正常流程中，都是不可能出现的状态。

04

问题分析

05

解决思路

对于分布式系统，没有任何人能保证远程调用不出问题，因此在做设计时，就必须能够对这种情况做出应对

• 小事务内，尽量只有一个远程写操作

• 该远程写操作放到方法最后，保证在其返回成功后就能立刻提交事务

• 小事务可能会因为某些原因失败，因此需要机制来进行重试

CREATETABLE`transaction_job` (
`id`bigint(20) NOTNULL AUTO_INCREMENT COMMENT'主键',
`type`varchar(255) NOTNULLCOMMENT'任务类型',
`data`varchar(255) NOTNULLCOMMENT'任务数据',
`error_message`varchar(255) DEFAULTNULLCOMMENT'错误信息',
`context`varchar(255) DEFAULTNULLCOMMENT'任务上下文（主要是保存当前操作人）',
`create_time`bigint(20) NOTNULLCOMMENT'创建时间',
`update_time`bigint(20) NOTNULLCOMMENT'更新时间',
`retry_times`int(11) NOTNULLDEFAULT'0'COMMENT'重试次数',
PRIMARY KEY (`id`)
) ENGINE=InnoDBDEFAULTCHARSET=utf8mb4 COMMENT='事务任务表';

作用：保存小事务的关键数据到data字段中，以保证通过该字段，就能正确执行小事务。另外也需要保存当前操作人的信息context。

第二步，通过定时任务，查出transaction_job表中未完成的数据，并执行对应的操作，这里通过简单的策略模式，将框架代码和业务代码做了分离

06

优化

07

注意

可能存在添加任务后，定时任务也立刻扫描到了这条数据，同一任务就会被主线程与定时任务线程同时执行，所以实际应用中需要考虑这个问题（比如：加锁再执行，执行前再检查数据库状态）

08

结语