解析spring事务管理@Transactional为什么要添加rollbackFor=Exception.class

作者:卖柴火的小伙子 时间:2021-09-03 17:07:41 

spring中事务处理原理

    利用aop生成代理对象执行带有Transactional事务注解的方法业务逻辑.项目启动过程中会生成代理对象并将Transactional注解中的属性进行解析加载处理.在方法执行过程中如果出现异常,会根据注解配置决定是进入到事务回滚处理还是事务提交处理逻辑中,事务回滚处理逻辑中最终还是基于数据库的事务回滚处理.

异常的分类

解析spring事务管理@Transactional为什么要添加rollbackFor=Exception.class

案例说明

    以自定义异常为例说明一下@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

标签:spring,事务,@Transactional
0
投稿

猜你喜欢

  • C语言字符串操作总结大全(超详细)

    2023-07-06 15:14:56
  • 学习Java HashMap,看这篇就够了

    2023-11-11 11:18:56
  • SpringBoot+Nacos+Kafka微服务流编排的简单实现

    2023-03-21 10:34:53
  • Java如何跳过https的ssl证书验证详解

    2023-08-24 11:34:56
  • springsecurity 企业微信登入的实现示例

    2023-06-16 16:39:35
  • Android Flutter实现搜索的三种方式详解

    2023-07-10 18:00:49
  • Java super关键字的使用详解

    2021-11-30 13:40:43
  • 一文详解Reactor模型与实现示例

    2023-11-13 12:22:09
  • Java中线程的等待与唤醒_动力节点Java学院整理

    2023-07-17 04:03:05
  • 解决mybatis-generator生成器添加类注释方法无效的问题

    2023-12-05 06:34:57
  • Java中ArrayList集合的常用方法大全

    2023-09-01 15:23:30
  • SpringBoot如何使用RateLimiter通过AOP方式进行限流

    2023-09-16 18:18:44
  • Spring Boot启动过程(四)之Spring Boot内嵌Tomcat启动

    2023-09-21 00:16:18
  • Maven管理SpringBoot Profile详解

    2022-03-20 09:57:45
  • SpringBoot整合之SpringBoot整合MongoDB的详细步骤

    2023-11-25 09:55:37
  • IP查询系统的异步回调案例

    2023-11-10 18:22:24
  • 浅谈Java中向上造型向下造型和接口回调中的问题

    2023-11-09 13:51:46
  • Java SpringBoot自动装配原理详解

    2022-09-08 01:15:09
  • SpringBoot应用jar包启动原理详解

    2022-07-08 09:45:48
  • Java 中如何使用 stream 流

    2021-10-09 01:13:37
  • asp之家 软件编程 m.aspxhome.com