优雅实现多系统一致性补偿方案（多系统协同）

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

以一个财务报账业务为例，涉及到的系统如下：

详细解释下各系统作用：

“审核通过”业务流程

当审核人员审核通过时，大致流程如下：

代码如下

风险分析

如图所示，如果在1和2出现异常，由于有事务的存在，操作1内的几条mysql写操作会被回滚，因此所有数据都没有任何变化。

但如果1和2正常执行，操作3发生异常，操作1的数据会因为事务回滚，但操作2并不能。因此整个系统会出现一个很诡异的现象：单据系统内，没有任何日志记录，用户操作的数据也没有保留下来，但BPM那边却已经审核通过了，这在任何正常流程中，都是不可能出现的状态。

对于用户而言，他在页面会收到报错，然后可能会再次点击“审核通过”，而此时BPM那边却显示，流程已经走到下一个节点，该用户无权限操作。

问题分析

根本原因其实不难，因为MYSQL事务只能管他自己，没法控制第三方系统

一个字：拆！

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

上面的操作，打包放进一个大事务就是根因，因此方案就是将大事务拆开，在拆分时，需要遵循以下几个原则：

整体思路就是这样

基于以上原则，改动如下

第一步，新建一张任务表：

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 表中未完成的数据，并执行对应的操作，这里通过简单的策略模式，将框架代码和业务代码做了分离

首先是框架代码核心逻辑

扫描任务

执行任务

这是一个策略模式接口，每个小事务就封装一个独立的实现类

其中更新待审人的任务实现如下，其实就是把那部分代码复制过来

第三步，改造业务代码，不再一次性把流程写完，而且是在第一个小事务中，顺便往 transaction_job 中插入一条数据，以执行第二个小事务

其中步骤2（插入任务数据的代码）的具体实现如下(
transactionJobService.create )

上述方案种，除第一个事务外，后续事务都是通过定时任务来执行的，因此这些事务都存在一定的延迟，用户体验不好，解决办法也非常简单，只需要利用好Spring对于事务的生命周期管理，稍微改造一下插入任务的方法（
transactionJobService.create ）

这是Spring提供的工具类， afterCommit() 方法会在事务提交后执行，因此加上这段代码后，思路就变成了这样

如果小事务顺利执行，会立刻将该任务改为“成功”，因此从用户端是感受不到延迟的

注意

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

目前只给出了解决思路的核心，但真实项目中，还添加了不少额外功能，以后会逐渐更新进来