业务场景：

我们经常会有些方法会调用一些方法异步执行，比如入库操作后要异步发送mq消息，发送短信或者发布事件等等
但是往往我们的业务方法总是包含事务的，要么全部成功，要么全部失败。
有的时候事务执行失败了或者还没有提交，异步方法就执行完成了

我们希望:

当我们事务失败回滚时，我们的异步操作也不执行
我们的异步操作需要等待事务完成后才执行

比如:

@Transactional(rollbackFor = Exception.class)
public boolean testTransactional() {Warehouse warehouse = warehouseService.getById(1);warehouse.setUpdateTime(null);warehouseService.updateById(warehouse);sendMsg();warehouseService.save(warehouse);return Boolean.TRUE;
}public void sendMsg(){ThreadUtils.execute(new Runnable() {@Overridepublic void run() {log.info("发送消息到mq");}});
}

这里我们编辑一个仓库，然后再新增一个数据一样的仓库。仓库表中code字段是有唯一索引的，所以新增肯定会失败，事务会回滚

这里，我们发现事务提交失败回滚了，但是mq消息还是发送成功了，不满足我们的预期

解决方案:

/*** 事务测试** @return*/
@Transactional(rollbackFor = Exception.class)
public boolean testTransactional1() {Warehouse warehouse = warehouseService.getById(1);warehouse.setUpdateTime(LocalDateTime.now());warehouseService.updateById(warehouse);TransactionSynchronizationManager.registerSynchronization(new TransactionSynchronization() {@Overridepublic void afterCommit() {sendMsg();}});warehouseService.save(warehouse);return Boolean.TRUE;
}

使用TransactionSynchronizationManager，重写afterCommit方法，把需要事务提交之后再执行的代码放到afterCommit中去，然后执行

发现并没有执行发送mq的方法。成功了

最后我们再去掉唯一索引试一下

发现发送mq永远都是在事务提交之后执行的，问题解决

我们看TransactionSynchronization 里还有 afterCompletion() 方法，这个是不管事务成功还是失败，当事务完成后就会执行。

如何在spring事务提交成功后再进行异步操作相关推荐

spring 事务提交成功后，再去发送事件
TransactionSynchronizationManager.registerSynchronization( new TransactionSynchronizationAdapter() { ...
Spring中事务提交成功后处理的异步调用方法
为什么80%的码农都做不了架构师?>>> 问题想要在Spring中提交事务成功后,调用一部分异步方法. 解决 TransactionSynchronizationManage ...
Spring 事务提交回滚源码解析
2019独角兽企业重金招聘Python工程师标准>>> 前言在上篇文章 Spring 事务初始化源码分析中分析了 Spring 事务初始化的一个过程,当初始化完成后,Spring ...
帆软填报增加记录提交成功后没有_大病医疗填报图解
判断是否符合扣除条件在一个纳税年度内,纳税人发生的与基本医保相关的医药费用支出,扣除医保报销后个人负担(指医保目录范围内的自付部分)累计超过15000元的部分,由纳税人在办理年度汇算清缴时,在800 ...
dedecms自定义表单提交成功后提示信息修改和跳转链接修改
我们在用dedecms自定义表单提交成功后提示信息一般是"Dedecms 提示信息",这个要怎么改成自己想要的文字呢?还有就是提示页停留时间,目前估计就2秒,太快了,要如何设置长点 ...
页面提交成功后，弹窗提示
因为要求提交成功后返回弹窗,本来用的是@ResponseBody ,直接输出的成功但是不好看嘛,所以用下图这样的我自己想了个方法,不知道有没有更好的. 写了个div隐藏,页面加载默认传一个mode ...
js提交成功后，清空表单
js提交成功后,清空表单: $("form")[0].reset(); //清空表单转载于:https://www.cnblogs.com/bagnliu/p/8205536.h ...
vue的form表单在提交成功后置空
vue的form表单在提交成功后置空 form表单说明 :form表单加上属性值 ref="form" 点击事件加入 roleManager.$refs['form'].rese ...
java spring 事务提交_Spring 事务提交之后再执行操作
Spring代码实现: import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.ster ...

如何在spring事务提交成功后再进行异步操作

业务场景：

我们希望:

解决方案:

如何在spring事务提交成功后再进行异步操作相关推荐

最新文章

热门文章