解析spring事务管理@Transactional为什么要添加rollbackFor=Exception.class
作者:卖柴火的小伙子 发布时间:2021-09-03 17:07:41
spring中事务处理原理
利用aop生成代理对象执行带有Transactional事务注解的方法业务逻辑.项目启动过程中会生成代理对象并将Transactional注解中的属性进行解析加载处理.在方法执行过程中如果出现异常,会根据注解配置决定是进入到事务回滚处理还是事务提交处理逻辑中,事务回滚处理逻辑中最终还是基于数据库的事务回滚处理.
异常的分类
案例说明
以自定义异常为例说明一下@Transactional中是否指定rollbackFor=Exception.class的区别
未指定rollbackFor属性
@Transactional
@GetMapping("/addSysMenu")
public void addSysMenu() throws Exception {
// 更新菜单名称(将id为1的菜单名修改为系统管理测试)
int k = sysMenuDao.updateSysMenu(1, "系统管理测试");
System.out.println(k);
// 自定义异常,抛出非运行期异常
throw new Exception("自定义异常");
// 执行结果:程序终止,数据库中菜单id为1的菜单名修改成功.说明事物没有回滚.
}
指定rollbackFor属性
@Transactional(rollbackFor = Exception.class)
@GetMapping("/addSysMenu")
public void addSysMenu(String menuName) throws Exception {
// 更新菜单名称(将id为1的菜单名修改为系统管理测试)
int k = sysMenuDao.updateSysMenu(1, "系统管理测试");
System.out.println(k);
// 自定义异常,抛出非运行期异常
throw new Exception("自定义异常");
// 执行结果:程序终止,数据库中菜单id为1的菜单名没有修改.说明事物回滚.
}
原因分析
其他帖子都说如果不加的话仅支持运行期异常以及error错误类型.对于非运行期异常是不支持的.这里提供一下这种说法的来源.
先看一下@Transactional注解中关于rollbackFor的使用说明
@Target({ElementType.TYPE, ElementType.METHOD})
@Retention(RetentionPolicy.RUNTIME)
@Inherited
@Documented
public @interface Transactional {
// 省略部分代码............
// By default, a transaction will be rolling back on {@link RuntimeException} and {@link Error} but not on checked exceptions (business exceptions).
// 翻译:指定事物回滚的异常类型,默认仅对于运行期异常和错误支持事务回滚,对于检查异常(业务异常是不支持的)
Class<? extends Throwable>[] rollbackFor() default {};
}
至于加上@Transactional中指定rollbackFor=Exception.class以后是如何起作用的接着往下看.
spring中事务回滚的大概逻辑是,发生异常之后,会根据配置的事务属性判断是否进行回滚的处理,如果不进行事务回滚则直接进行事务提交.这里重要的体现是在:TransactionAspectSupport.java中completeTransactionAfterThrowing
// 发生异常时事务处理方式
protected void completeTransactionAfterThrowing(@Nullable TransactionInfo txInfo, Throwable ex) {
if (txInfo != null && txInfo.getTransactionStatus() != null) {
// 省略部分代码.......
// 判断异常是否为运行期异常或是error,如果是则执行回滚处理,如果不是则提交事务
if (txInfo.transactionAttribute != null && txInfo.transactionAttribute.rollbackOn(ex)) {
// 回滚事务处理
txInfo.getTransactionManager().rollback(txInfo.getTransactionStatus());
// 省略部分代码......
}
else {
// 提交事务
txInfo.getTransactionManager().commit(txInfo.getTransactionStatus());
// 省略部分代码.......
}
}
}
而判断事务是否支持回滚的处理在RuleBasedTransactionAttribute.java中transactionAttribute.rollbackOn()
// 判断异常是否支持事务回滚处理
public boolean rollbackOn(Throwable ex) {
RollbackRuleAttribute winner = null;
// 省略部分代码....................
// winner 是判断@Transactional中是否有rollBackFor属性,如果没有则说明没有指定,按照默认的方式进行判断(DefaultTransactionAttribute.java中rollbackOn),如果有则只判断是否属于NoRollbackRuleAttribute类型,如果不是则说明支持事务回滚.关于变量win对应的RollbackRuleAttribute如何进行的赋值下面继续.
if (winner == null) {
return super.rollbackOn(ex);
}
return !(winner instanceof NoRollbackRuleAttribute);
}
DefaultTransactionAttribute.java中rollbackOn,是否支持事务回滚的默认判断方式:是否是运行期异常或是是否是错误类型(与Transactional注解中的rollbackFor属性说明相对应).
public boolean rollbackOn(Throwable ex) {
return (ex instanceof RuntimeException || ex instanceof Error);
}
RollbackRuleAttribute中如何进行的赋值问题,具体来讲是项目启动之后会扫描带有Transactional注解的方法,然后将注解中标注的属性获取之后进行参数配置.具体体现是在:SpringTransactionAnnotationParser.java中parseTransactionAnnotation
protected TransactionAttribute parseTransactionAnnotation(AnnotationAttributes attributes) {
RuleBasedTransactionAttribute rbta = new RuleBasedTransactionAttribute();
// 省略部分代码.........
// 获取注解上的rollbackFor属性值
List<RollbackRuleAttribute> rollbackRules = new ArrayList<>();
for (Class<?> rbRule : attributes.getClassArray("rollbackFor")) {
rollbackRules.add(new RollbackRuleAttribute(rbRule));
}
// 省略部分代码.........
return rbta;
}
至此关于为什么@Transactional为什么要添加rollbackFor=Exception.class原因以讲述完毕!
来源:https://blog.csdn.net/weixin_43401380/article/details/121153444


猜你喜欢
- 在谈 JVM 内存区域划分之前,我们先来看一下 Java 程序的具体执行过程,我画了一幅图。Java 源代码文件经过编译器编译后生成字节码文
- 一、首先在主布局中,用帧布局来填充 RecycleView 和 两个模拟发送消息的Button<?xml version="
- 在日常工作中,我们可能需要连接多个MongoDB数据源,比如用户库user,日志库log。本章我们来记录连接多个数据源的步骤,以两个数据源为
- 首先介绍下JSON的定义,JSON是JavaScript Object Notation的缩写。一种轻量级的数据交换格式,具有良好的可读和便
- name和value属性的区别从源码可以得知,name是value的别名,value也是name的别名。两者的作用是一致的,name指定Fe
- 栈(Stack)和队列是非常类似的一个容器,只是栈是一个后进先出(LIFO)的容器。栈用Push()方法在栈中添加元素,用Pop()方法获取
- Seata介绍Seata:Simple Extensible Autonomous Transaction Architecture,简易可
- 作为一个合格的开发人员,对项目进行管理自然必不可少。今天就给各位看客介绍一下如何用git将自己的AS项目上传到码云。
- 简单版/** * 产生4位随机数(0000-9999) * * @return 4位随机数 &nb
- 本文实例为大家分享了JSON处理工具类的具体代码,供大家参考,具体内容如下import java.io.IOException; impor
- 网络基础知识1、OSI分层模型和TCP/IP分层模型的对应关系这里对于7层模型不展开来讲,只选择跟这次系列主题相关的知识点介绍。2、七层模型
- 高并发访问时,缓存、限流、降级往往是系统的利剑,在互联网蓬勃发展的时期,经常会面临因用户暴涨导致的请求不可用的情况,甚至引发连锁反映导致整个
- C#实体类转换方式将一个实体类的数据赋值到另一个实体类中(亦或者实现深拷贝)。以下提供两种方式一种是序列化一种是泛型+反射实现功能两个实体类
- 结束firefox的进程,一句代码就够了,如下:Runtime.getRuntime().exec("taskkill /F /I
- 特别是针对循环或timer处理中需要在窗体控件显示数据时,因后台处理过度繁忙而出现没刷新或者假死现象时,可以使用Application.Do
- 使用Collections.sort对中文进行排序使用collections.sort(List list, Comparator <
- springboot 配置服务代理有时候,我们可能有下边这样的需求:即,针对于分布式服务,我们会有多种业务接口服务,但是服务器上可能只要求开
- logback-classic 使用testCompile的打包今天使用gradle打包的时候logback-classic一直打包不进去。
- 我就废话不多说了,大家还是直接看代码吧~private LineRenderer line;//画线line = this.gameObje
- 因为在Action的execute方法声明时就抛出了Exception异常,所以我们无需再execute方法中捕捉异常,仅需在struts.