关于Spring的@Transaction导致数据库回滚全部生效问题(又删库跑路)

1 前言

很多需要使用事务的场景,都只是在方法上直接添加个@Transactional注解

但是,你以为这真的够了吗?

事务如果未达到完美效果,在开发和测试阶段都难以被发现,因为你难以考虑到太多意外场景。但当业务数据量发展,就可能导致大量数据不一致的问题,就会造成前人栽树后人踩坑,需要大量人力排查解决问题和修复数据。

2 如何确认Spring事务生效了?

使用@Transactional一键开启声明式事务, 这就真的事务生效了?过于信任框架总有“意外惊喜”。来看如下案例

领域层 实体

领域服务

createUserError1调用private方法

createUserPrivate,被@Transactional注解。当传入的用户名包含test则抛异常,让用户的创建操作失败

getUserCount

用户接口层

调用UserService#createUserError1

测试结果
即便用户名不合法,用户也能创建成功。刷新浏览器,多次发现有十几个的非法用户注册。 @Transactional生效原则 public方法

除非特殊配置(比如使用AspectJ静态织入实现AOP),@Transactional必须定义在public方法才生效。

因为Spring的AOP,private方法无法被代理到,自然也无法动态增强事务处理逻辑。

那简单,把createUserPrivate方法改为public不就行了。
但发现事务依旧未生效

必须通过代理过的类从外部调用目标方法

要调用增强过的方法必然是调用代理后的对象。
尝试修改UserService,注入一个self,然后再通过self实例调用标记有 @Transactional 注解的createUserPublic方法。设置断点可以看到,self是由Spring通过CGLIB方式增强过的类:

CGLIB通过继承实现代理类,private方法在子类不可见,所以无法进行事务增强。而this指针代表调用对象本身,Spring不可能注入this,所以通过this访问方法必然不是代理。
把this改为self,这时即可验证事务生效:非法的用户注册操作可回滚。

虽然在UserDomainService内部注入自己调用自己的createUserPublic可正确实现事务,但这不符常规。更合理的实现方式是,让Controller直接调用之前定义的UserService的createUserPublic方法。

this/self/Controller调用UserDomainService

  • this自调用

无法走到Spring代理类

  • 后两种

调用的Spring注入的UserService,通过代理调用才有机会对createUserPublic方法进行动态增强。

推荐开发时打开Debug日志以了解Spring事务实现的细节。
比如JPA数据库访问,开启Debug日志:
logging.level.org.springframework.orm.jpa=DEBUG

开启日志后再比较下在UserService中this调用、Controller中通过注入的UserService Bean调用createUserPublic的区别。

很明显,this调用因没走代理,事务没有在createUserPublic生效,只在Repository的save生效:

// 在UserService中通过this调用public的createUserPublic
[23:04:30.748] [http-nio-45678-exec-5] [DEBUG] [o.s.orm.jpa.JpaTransactionManager:370 ] -
Creating new transaction with name [org.springframework.data.jpa.repository.support.SimpleJpaRepository.save]:
PROPAGATION_REQUIRED,ISOLATION_DEFAULT

[DEBUG] [o.s.orm.jpa.JpaTransactionManager       :370 ] - Creating new transaction with name [org.springframework.data.jpa.repository.support.SimpleJpaRepository.save]: PROPAGATION_REQUIRED,ISOLATION_DEFAULT
//在Controller中通过注入的UserService Bean调用createUserPublic
[10:10:47.750] [http-nio-45678-exec-6] [DEBUG] [o.s.orm.jpa.JpaTransactionManager       :370 ] - Creating new transaction with name [org.geekbang.time.commonmistakes.transaction.demo1.UserService.createUserPublic]: PROPAGATION_REQUIRED,ISOLATION_DEFAULT

这种实现在Controller里处理异常显得繁琐,还不如直接把createUserWrong2@Transactional注解,然后在Controller中直接调用该方法。
这既能从外部(Controller中)调用UserService方法,方法又是public的能够被动态代理AOP增强。

小结

务必确认调用被@Transactional注解标记的方法被public修饰,并且是通过Spring注入的Bean进行调用。

但有时因没有正确处理异常,导致事务即便生效也不一定能回滚。

2 事务生效不代表能正确回滚

AOP实现事务:使用try/catch包裹@Transactional注解的方法:

  • 当方法出现异常并满足一定条件,在catch里可设置事务回滚
  • 没有异常则直接提交事务 一定条件

只有异常传播出了被@Transactional注解的方法,事务才能回滚。

Spring的 TransactionAspectSupport#invokeWithinTransaction 就是在处理事务。观察源码得知,只有捕获到异常后才能进行后续事务处理:

默认情况下,出现RuntimeException(非受检异常)或Error,Spring才会回滚事务。

Spring的DefaultTransactionAttribute:

  • 受检异常一般是业务异常或类似另一种方法的返回值,出现这种异常可能业务还能完成,所以不会主动回滚
  • 而Error或RuntimeException代表非预期结果,应该回滚

事务无法正常回滚的各种惨案 异常无法传播出方法

受检异常

注册的同时会有一次文件读,若读文件失败,希望用户注册的DB操作回滚。因读文件抛的是受检异常,createUserError2传播出去的也是受检异常


以上方法虽然避开了事务不生效的坑,但因异常处理不当,导致异常时依旧不回滚事务。

修复回滚失败bug 1 手动设置让当前事务处回滚态

若希望自己捕获异常并处理,可手动设置让当前事务处回滚态

查看日志,事务确定回滚。

Transactional code has requested rollback:手动请求回滚。

2 注解中声明,期望所有Exception都回滚事务 突破默认不回滚受检异常的限制

查看日志,提示回滚:

该案例有DB操作、IO操作,在IO操作问题时期望DB事务也回滚,以确保逻辑一致性。 小结

由于异常处理不正确,导致虽然事务生效,但出现异常时没回滚。
Spring默认只对被@Transactional注解的方法出现RuntimeExceptionError时回滚,所以若方法捕获了异常,就需要通过手写代码处理事务回滚。
若希望Spring针对其他异常也可回滚,可相应配置@Transactional注解的rollbackFornoRollbackFor属性覆盖Spring的默认配置。

有些业务可能包含多次DB操作,不一定希望将两次操作作为一个事务,这时就需仔细考虑事务传播的配置。

3 事务传播配置是否符合业务逻辑

案例

用户注册:会插入一个主用户到用户表,还会注册一个关联的子用户。期望将子用户注册的DB操作作为一个独立事务,即使失败也不影响注册主用户的流程。

UserService:创建主、子用户

SubUserService:使子用户注册失败。期望子用户注册作为一个事务单独回滚而不影响注册主用户

启动调用后查看日志:事务回滚了

不对呀!因为运行时异常逃出被@Transactional注解的createUserWrong,Spring当然会回滚事务。若期望主方法不回滚,应捕获子方法所抛的异常。

修正方案

subUserService#createSubUserWithExceptionError包上catch,这样外层主方法createUserError2就不会出现异常

启动后查看日志注意到:

  • createUserError2开启异常处理
  • 子方法因出现运行时异常,标记当前事务为回滚
  • 主方法捕获异常并打印create sub user error
  • 主方法提交事务

但Controller出现一个UnexpectedRollbackException,异常描述提示最终该事务回滚了且为静默回滚:因createUserError2本身并无异常,只不过提交后发现子方法已把当前事务设为回滚,无法完成提交。

明明无异常发生,但事务也不一定可提交
因为主方法注册主用户的逻辑和子方法注册子用户的逻辑为同一事务,子逻辑标记了事务需回滚,主逻辑自然也无法提交。
那么修复方式就明确了,独立子逻辑的事务,即修正SubUserService注册子用户方法,为注解添加propagation = Propagation.REQUIRES_NEW设置REQUIRES_NEW事务传播策略。即执行到该方法时开启新事务,并挂起当前事务。
创建一个新事务,若存在则暂停当前事务。类似同名的EJB事务属性。
注:实际事务暂停不会对所有事务管理器外的开箱。 这特别适于org.springframework.transaction.jta.JtaTransactionManager ,这就需要javax.transaction.TransactionManager被提供给它(这是服务器特定的标准Java EE)

主方法无变化,依旧需捕获异常,防止异常外泄导致主事务回滚,重命名为createUserRight

修正后再查看日志

Creating new transaction with name createUserRight

对createUserRight开启主方法事务
createMainUser finish
创建主用户完成
Suspending current transaction, creating new transaction with name createSubUserWithExceptionRight
主事务挂起,开启新事务,即对createSubUserWithExceptionRight创建子用户的逻辑
Initiating transaction rollback
子方法事务回滚
Resuming suspended transaction after completion of inner transaction
子方法事务完成,继续主方法之前挂起的事务
create sub user error:invalid status
主方法捕获到了子方法的异常
Committing JPA transaction on EntityManager
主方法的事务提交了,随后我们在Controller里没看到静默回滚异常

小结

若方法涉及多次DB操作,并希望将它们作为独立事务进行提交或回滚,即需考虑细化配置事务传播方式,即配置@Transactional注解的Propagation属性。

4 总结

若要针对private方法启用事务,动态代理方式的AOP不可行,需要使用静态织入方式的AOP,也就是在编译期间织入事务增强代码,可以配置Spring框架使用AspectJ来实现AOP。

以上就是关于Spring的@Transaction导致数据库回滚全部生效问题(又删库跑路)的详细内容,更多关于Spring @Transaction数据库回滚的资料请关注我们其它相关文章!

时间: 2021-05-15

Spring @Transactional注解失效解决方案

这篇文章主要介绍了Spring @Transactional注解失效解决方案,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下 这几天在项目里面发现我使用@Transactional注解事务之后,抛了异常居然不回滚.后来终于找到了原因. 如果你也出现了这种情况,可以从下面开始排查. 一.特性 先来了解一下@Transactional注解事务的特性吧,可以更好排查问题 1.service类标签(一般不建议在接口上)上添加@Transactional,

深入学习Spring Boot排查 @Transactional 引起的 NullPointerException问题

写在前面 这个demo来说明怎么排查一个@Transactional引起的NullPointerException. https://github.com/hengyunabc/spring-boot-inside/tree/master/demo-Transactional-NullPointerException 定位 NullPointerException 的代码 Demo是一个简单的spring事务例子,提供了下面一个StudentDao,并用@Transactional来声明事务:

Spring中@Transactional用法详细介绍

Spring中@Transactional用法详细介绍 引言: 在spring中@Transactional提供一种控制事务管理的快捷手段,但是很多人都只是@Transactional简单使用,并未深入了解,其各个配置项的使用方法,本文将深入讲解各个配置项的使用. 1.  @Transactional的定义 Spring中的@Transactional基于动态代理的机制,提供了一种透明的事务管理机制,方便快捷解决在开发中碰到的问题.在现实中,实际的问题往往比我们预期的要复杂很多,这就要求对@Tr

springboot中事务管理@Transactional的注意事项与使用场景

前言:在service层的方法上使用@Transactional 即可实现处理数据库发生错误时触发事务回滚机制. 注意: Spring 基于注解的声明式事物 @Transactional 默认情况下只会对运行期异常(java.lang.RuntimeException及其子类)和 Error 进行回滚. 数据库引擎要支持事物,使用InnoDB. @Transactional 只能被应用到public方法上, 对于其它非public的方法,如果标记了@Transactional也不会报错,但方法没

Spring @Transactional工作原理详解

本文将深入研究Spring的事务管理.主要介绍@Transactional在底层是如何工作的.之后的文章将介绍: propagation(事务传播)和isolation(隔离性)等属性的使用 事务使用的陷阱有哪些以及如何避免 JPA和事务管理 很重要的一点是JPA本身并不提供任何类型的声明式事务管理.如果在依赖注入容器之外使用JPA,事务处理必须由开发人员编程实现. UserTransaction utx = entityManager.getTransaction(); try{ utx.be

浅谈Spring中@Transactional事务回滚及示例(附源码)

一.使用场景举例 在了解@Transactional怎么用之前我们必须要先知道@Transactional有什么用.下面举个栗子:比如一个部门里面有很多成员,这两者分别保存在部门表和成员表里面,在删除某个部门的时候,假设我们默认删除对应的成员.但是在执行的时候可能会出现这种情况,我们先删除部门,再删除成员,但是部门删除成功了,删除成员的时候出异常了.这时候我们希望如果成员删除失败了,之前删除的部门也取消删除.这种场景就可以使用@Transactional事物回滚. 二.checked异常和unc

浅谈spring中isolation和propagation的用法

可以在XML文件中进行配置,下面的代码是个示意代码 <tx:advice id="txAdvice" transaction-manager="txManager"> <tx:attributes> <tx:method name="add*" propagation="REQUIRED" isolation="READ_COMMITTED"/>增加记录的方法 <t

浅谈spring中的default-lazy-init参数和lazy-init

在spring的配置中的根节点上有个  default-lazy-init="true"配置: 1.spring的default-lazy-init参数 此参数表示延时加载,即在项目启动时不会实例化注解的bean,除非启动项目时需要用到,未实例化的注解对象在程序实际访问调用时才注入调用 spring在启动的时候,default-lazy-init参数默认为false,会默认加载整个对象实例图,从初始化ACTION配置.到 service配置到dao配置.乃至到数据库连接.事务等等.这样

浅谈spring中scope作用域

今天研究了一下scope的作用域.默认是单例模式,即scope="singleton".另外scope还有prototype.request.session.global session作用域.scope="prototype"多例.再配置bean的作用域时,它的头文件形式如下: 如何使用spring的作用域: <bean id="role" class="spring.chapter2.maryGame.Role" s

浅谈Spring中Bean的作用域、生命周期

本文主要探究的是关于Bean的作用域.生命周期的相关内容,具体如下. Bean的作用域 Spring 3中为Bean定义了5中作用域,分别为singleton(单例).prototype(原型).request.session和global session,5种作用域说明如下: 1.singleton:单例模式,Spring IoC容器中只会存在一个共享的Bean实例,无论有多少个Bean引用它,始终指向同一对象.Singleton作用域是Spring中的缺省作用域,也可以显示的将Bean定义为

在laravel中实现事务回滚的方法

之前做项目用到了事务回滚这个机制.我把代码贴出来多多交流给点意见,我用的是laravel 5.1bane版本的, public static function createDeal($to_status, $params, $new_balance, $update = true) { \DB::beginTransaction(); try { $update_order_status = \DB::table('wallet_order') ->where('order_id', $para

浅谈Spring中@Import注解的作用和使用

@Import用来导入@Configuration注解的配置类.声明@Bean注解的bean方法.导入ImportSelector的实现类或导入ImportBeanDefinitionRegistrar的实现类. @Import注解的作用 查看Import注解源码 /** * Indicates one or more {@link Configuration @Configuration} classes to import. * * <p>Provides functionality eq

Java中的使用及连接Redis数据库(附源码)

引言: 本文主要分享了Redis如何在IDEA中部署,运行:模拟加入Redis的操作: 目录结构 1. 在IDEA中搭建Redis 1.1 创建项目 新建含有web的SpringBoot项目: 搭建项目参考:SpringBoot超详细笔记:https://blog.csdn.net/weixin_42601136/article/details/108396511 1.2 添加依赖(不够手动添加) <dependencies> <!-- 1. Jedis--> <depend

SQL Server中TRUNCATE事务回滚操作方法

我们一般都认为TRUNCATE是一种不可回滚的操作,它会删除表中的所有数据以及重置Identity列. 如果你在事务中进行TRUNCATE操作,就能回滚.反之,它就不会从日志文件文件恢复数据.它不会在日志文件中记录删除的那些数据,它只在日志中记录数据页的单元分配. 下面的例子就能解释上面的所说的.       复制代码 代码如下: USE temp_test_database GO --创建一个临时表 CREATE TABLE TruncateTabel(ID INT) INSERT INTO

浅谈Spring中如何使用设计模式

关于设计模式,如果使用得当,将会使我们的代码更加简洁,并且更具扩展性.本文主要讲解Spring中如何使用策略模式,工厂方法模式以及Builder模式. 1. 策略模式 关于策略模式的使用方式,在Spring中其实比较简单,从本质上讲,策略模式就是一个接口下有多个实现类,而每种实现类会处理某一种情况.我们以发奖励为例进行讲解,比如我们在抽奖系统中,有多种奖励方式可供选择,比如积分,虚拟币和现金等.在存储时,我们必然会使用一个类似于type的字段用于表征这几种发放奖励的,那么这里我们就可以使用多态的