查看原文
其他

踩坑!Spring 事务方法与非事务方法相互调用 @Transactional 注解失效不回滚?

Java精选 2022-08-09
>>号外:关注“Java精选”公众号,回复“2021面试题”,领取免费资料!Java精选面试题”小程序,3000+ 道面试题在线刷,最新、最全 Java 面试题!
写这篇文章的初衷呢就是最近遇到了一个Spring事务的大坑。与其说是坑,还不如说是自己事务这块儿太薄弱导致的(自嘲下)。

项目环境 Spring Boot

下面开始问题描述,发生的过程有点长,想直接看方案的直接跳过哦~!

最近在做项目中有个业务是每天定时更新xx的数据,某条记录更新中数据出错,不影响整体数据,只需记录下来并回滚当条记录所关联的表数据;好啊!

这个简单,接到任务后,楼主我三下五除二就写完了,由于这个业务还是有些麻烦,我就在一个service里拆成了两个方法去执行,一个方法(A)是查询数据与验证组装数据。

推荐后台管理开源框架,基于 Spring Boot、Spring Security、JWT 后端框架,Vue & Element 前端框架的前后端分离的用户权限管理系统,代码易读易懂、界面简洁美观。其核心技术采用 Spring、MyBatis、Shiro 没有任何其它过度依赖包,下载即可运行使用。

https://gitee.com/yoodb/jing-xuan

另外一个方法(B)更新这条数据所对应的表(执行的时候是方法A中调用方法B);由于这个数据是循环更新,所以我想的是,一条数据更新失败直接回滚此条数据就是,不会影响其他数据,其他的照常更新,所以我就在方法B上加了事务,方法A没有加;以为很完美,自测一下正常。

ok通过,再测试一下报错情况,是否回滚,一测没回滚,懵圈儿?以为代码写错了,改了几处地方,再测了几次,均没回滚。这下是真难受了。

好啦,写到这里相信各位看官心里肯定在嘲讽老弟了,spring的传播机制都没搞明白(难受

下面开始一步步分析解决问题:

首先我们来看下spring事务的传播机制及原因分析;

PROPAGATION_REQUIRED – 支持当前事务,如果当前没有事务,就新建一个事务。
这是最常见的选择。
PROPAGATION_SUPPORTS – 支持当前事务,如果当前没有事务,就以非事务方式执行。
PROPAGATION_MANDATORY – 支持当前事务,如果当前没有事务,就抛出异常。
PROPAGATION_REQUIRES_NEW – 新建事务,如果当前存在事务,把当前事务挂起。
PROPAGATION_NOT_SUPPORTED – 以非事务方式执行操作,如果当前存在事务,就把当前事务挂起。
PROPAGATION_NEVER – 以非事务方式执行,如果当前存在事务,则抛出异常。
PROPAGATION_NESTED – 如果当前存在事务,则在嵌套事务内执行。
如果当前没有事务,则进行与PROPAGATION_REQUIRED类似的操作。 

spring默认的是PROPAGATION_REQUIRED机制,如果方法A标注了注解@Transactional 是完全没问题的,执行的时候传播给方法B,因为方法A开启了事务,线程内的connection的属性autoCommit=false,并且执行到方法B时。事务传播依然是生效的,得到的还是方法A的connection,autoCommit还是为false,所以事务生效;

反之,如果方法A没有注解@Transactional 时是不受事务管理的,autoCommit=true,那么传播给方法B的也为true,执行完自动提交,即使B标注了@Transactional ;

在一个Service内部,事务方法之间的嵌套调用,普通方法和事务方法之间的嵌套调用,都不会开启新的事务。是因为spring采用动态代理机制来实现事务控制,而动态代理最终都是要调用原始对象的,而原始对象在去调用方法时,是不会再触发代理了!

所以以上就是为什么我在没有标注事务注解方法A里去调用标注有事务注解方法B而没有事务滚回的原因。

看到这里,有的看官可能在想你在方法A上标个注解不就完了吗?为什么非要标注在方法B上?

由于我这里是循环更新数据,调用一次方法B就更新一次数据,涉及到几张表,需要执行几条update sql,一条数据更新失败不影响所有数据,所以说一条数据更新执行完毕后就提交一次事务,如果标注在方法A上,要所有的都执行完毕了才提交事务,这样子是有问题滴。

下边先上下代码:

方法A:无事务控制

方法B:有事务控制

方法B处理失败手动抛出异常触发回滚:

方法A调用方法B:

从上图可以看到,如果方法B中User更新出错后需要回滚RedPacket数据,所以User更新失败就抛出了继承自RuntimeException的自定义异常,并且在调用方把这个异常catch到重新抛出,触发事务回滚,但是并没有执行;

解决方案

1、把方法B抽离到另外一个XXService中去,并且在这个Service中注入XXService,使用XXService调用方法B。

显然,这种方式一点也不优雅,且要产生很多冗余文件,看起来很烦,实际开发中也几乎没人这么做吧?反正我不建议采用此方案;

2、通过在方法内部获得当前类代理对象的方式,通过代理对象调用方法B

上面说了:动态代理最终都是要调用原始对象的,而原始对象在去调用方法时,是不会再触发代理了!

所以我们就使用代理对象来调用,就会触发事务;

综上解决方案,我觉得第二种方式简直方便到炸,那怎么获取代理对象呢?这里提供两种方式:

1、使用 ApplicationContext 上下文对象获取该对象;

2、使用 AopContext.currentProxy() 获取代理对象,但是需要配置exposeProxy=true

我这里使用的是第二种解决方案,具体操作如下:

springboot启动类加上注解:@EnableAspectJAutoProxy(exposeProxy = true)

方法内部获取代理对象调用方法

完了后再测试,数据顺利回滚,至此,问题得到解决!

都是事务这块儿基础太差的错啊~~希望各位遇到这种问题的兄弟些都好好的去研究研究spring这块儿,好了不说了,我也该去深造了

作者:西风一任秋

blog.csdn.net/m0_38027656/article/details/84190949

往期精选  点击标题可跳转

Spring Boot 中如何实现 Mybatis 逆向工程,你 GET 到了吗?(附源码)

你了解 JDK 8 Stream 数据流效率吗?千万级数据量性能如何?

Spring 中毒太深,离开 Spring 居然连最基本的接口都不会写了!

Spring Boot 线程池的使用心得,你真会用吗?

从原理到实践彻底搞懂 Java 日志系统,再也不迷茫了!

如何设计 QQ、微信、微博、Github 等第三方账号登陆 ?(附表设计)

【源码解读】JDK1.8 中 ConcurrentHashMap 不支持空键值对源码剖析

为什么要代码重构?如何重构?常见重构技巧,值得收藏!

面试官问:为什么 Java 线程没有 Running 状态?一下被问懵!

SpringBoot + Mybatis + Druid + PageHelper 实现多数据源并分页(附源码)

Intellij IDEA 中的各种调试代码技巧,轻松定位 Bug 问题(涵盖超全面)

点个赞,就知道你“在看”!

您可能也对以下帖子感兴趣

文章有问题?点此查看未经处理的缓存