分布式事务问题

​

问题描述：

最近在做项目过程中遇到这样一种场景：方法A依次调用方法B、C、D，其中方法B和D都是本地方法，方法C是远程方法（更具体的讲，方法C的功能是发送MQ消息），该场景要求方法A是满足事务的，即A调用B、C、D要么同时成功，要么同时失败。

问题分析：

该问题的难点在于，对于方法B和D，可以通过本地事务支持回滚，对于方法C，不是一个简单的远程调用，是一个发送MQ消息的方法，本地事务不支持回滚，也无法手动调方法回滚，该如何解决？

几种可能的方案：

方案一：将方法C的执行放到最后，保证其他方法执行成功后再执行方法C，这种方案不需要处理回滚；

方案二：使用分布式事务，支持回滚；

方案一：

需要保存方法C的中间结果，然后在所有方法执行完之后再去处理发送消息。关于如何保存中间结果我想到两种方法：一是用缓存，二是用ThreadLocal。

用缓存保存中间结果：

可以使用线程ID作为缓存key，把中间结果放到缓存中，设置一个缓存时间，在最后从缓存中取数据进行处理，处理完要清理缓存。

用ThreadLocal保存中间结果：

可以封装一个工具类，内部定义ThreadLocal的get/set/remove方法。这里一定要注意及时清理ThreadLocal，防止线程复用导致问题。

方案二：

使用事务消息。

这里介绍一下事务消息的执行过程：

​编辑

事务消息需要提供两个接口：

本地事务执行接口：根据事务执行情况返回3种状态：Commit、Rollback、UNKNOW。

本地事务状态查询接口：如果本地事务执行超时，或返回UNKNOW，MQ服务器调用该接口轮询事务状态。

综合以上方案，笔者最终选择了ThreadLocal方案，原因是该方案相对简单，不需要引入外部依赖，该方案的注意点是要及时清理ThreadLocal。读者如果有更好的方案或建议可以交流交流。