广告位联系
返回顶部
分享到

Spring中的Transactional属性的介绍

java 来源:转载 作者:秩名 发布时间:2021-05-20 19:34:15 人浏览
摘要

一、Transactional 声明式事务管理建立在AOP之上的。其本质是对方法前后进行拦截,然后在目标方法开始之前创建或者加入一个事务,在执行完目标方法之后根据执行情况提交或者回滚事务。 简而言之,@Transactional注解在代码执行出错的时候能够进行事务的回滚

一、Transactional

声明式事务管理建立在AOP之上的。其本质是对方法前后进行拦截,然后在目标方法开始之前创建或者加入一个事务,在执行完目标方法之后根据执行情况提交或者回滚事务。

简而言之,@Transactional注解在代码执行出错的时候能够进行事务的回滚。

在这里插入图片描述

二、使用说明

在这里插入图片描述

  • 在启动类上添加@EnableTransactionManagement注解。
  • 用于类上时,该类的所有 public 方法将都具有该类型的事务属性,同时,我们也可以在方法级别使用该标注来覆盖类级别的定义。
  • 在项目中,@Transactional(rollbackFor=Exception.class),如果类加了这个注解,那么这个类里面的方法抛出异常,就会回滚,数据库里面的数据也会回滚。
  • 在@Transactional注解中如果不配置rollbackFor属性,那么事物只会在遇到RuntimeException的时候才会回滚,加上rollbackFor=Exception.class,可以让事物在遇到非运行时异常时也回滚。

而至于什么是运行时异常(RuntimeException),什么是非运行时异常,可通过下图所示理解(图片截取网络)

在这里插入图片描述

三、注解失效问题

正常情况下,只要在方法上添加@Transactional注解就完事了,但是需要注意的是,虽然使用简单,但是如果不合理地使用注解,还是会存在注解失效的问题。

@Transactional 应用在非 public 修饰的方法上

事务拦截器在目标方法执行前后进行拦截,内部会调用方法来获取Transactional 注解的事务配置信息,调用前会检查目标方法的修饰符是否为 public,不是 public则不会获取@Transactional 的属性配置信息。

@Transactional 注解属性 rollbackFor 设置错误

rollbackFor 可以指定能够触发事务回滚的异常类型。Spring默认抛出了未检查unchecked异常(继承自 RuntimeException 的异常)或者 Error才回滚事务;其他异常不会触发回滚事务。如果在事务中抛出其他类型的异常,但却期望 Spring 能够回滚事务,就需要指定rollbackFor属性。

同一个类中方法调用,导致@Transactional失效

开发中避免不了会对同一个类里面的方法调用,比如有一个类Test,它的一个方法A,A再调用本类的方法B(不论方法B是用public还是private修饰),但方法A没有声明注解事务,而B方法有。则外部调用方法A之后,方法B的事务是不会起作用的。这也是经常犯错误的一个地方。

那为啥会出现这种情况?其实这还是由于使用Spring AOP代理造成的,因为只有当事务方法被当前类以外的代码调用时,才会由Spring生成的代理对象来管理。

异常被你的 catch“吃了”导致@Transactional失效

如果你手动的catch捕获这个异常并进行处理,事务管理器会认为当前事务应该正常commit,就会导致注解失效,如果非要捕获且不失效,就必须在代码块内throw new Exception抛出异常。

数据库引擎不支持事务

开启事务的前提就是需要数据库的支持,我们一般使用的Mysql引擎时支持事务的,所以一般不会出现这种问题。

开启多线程任务时,事务管理会受到影响

因为线程不属于spring托管,故线程不能够默认使用spring的事务,也不能获取spring注入的bean在被spring声明式事务管理的方法内开启多线程,多线程内的方法不被事务控制。
如下代码,线程内调用insert方法,spring不会把insert方法加入事务就算在insert方法上加入@Transactional注解,也不起作用。

 
@Service
public class ServiceA { 
   
    @Transactional
    public void threadMethod(){ 
        this.insert(); 
         System.out.println("main insert is over"); 
        for(int a=0 ;a<3;a++){ 
            ThreadOperation threadOperation= new ThreadOperation();  
            Thread innerThread = new Thread(threadOperation); 
            innerThread.start(); 
        } 
    } 
   
    public  class ThreadOperation implements Runnable { 
        public ThreadOperation(){ 
        } 
        @Override
        public void run(){ 
            insert(); 
            System.out.println("thread insert is over"); 
        } 
    } 
   
    public void insert(){ 
   
    //do insert...... 
   
    } 
} 

如果把上面insert方法提出到新的类中,加入事务注解,就能成功的把insert方法加入到事务管理当中

@Service
public class ServiceA { 
   
@Autowired
private ServiceB serviceB; 
   
    @Transactional
    public void threadMethod(){ 
        this.insert(); 
        System.out.println("main insert is over"); 
        for(int a=0 ;a<3;a++){ 
            ThreadOperation threadOperation= new ThreadOperation();  
            Thread innerThread = new Thread(threadOperation); 
            innerThread.start(); 
        } 
    } 
   
    public  class ThreadOperation implements Runnable { 
        public ThreadOperation(){ 
        } 
        @Override
        public void run(){ 
            serviceB.insert(); 
            System.out.println("thread insert is over"); 
        } 
    } 
   
    public void insert(){ 
   
        //do insert...... 
   
    } 
} 
   
@Service
public class ServiceB { 
   
    @Transactional
    public void insert(){ 
   
        //do insert...... 
   
    } 
   
} 
 

另外,使用多线程事务的情况下,进行回滚,比较麻烦。thread的run方法,有个特别之处,它不会抛出异常,但异常会导致线程终止运行。

最麻烦的是,在线程中抛出的异常即使在主线程中使用try…catch也无法截获这非常糟糕,我们必须要“感知”到异常的发生。比如某个线程在处理重要的事务,当thread异常终止,我必须要收到异常的报告,才能回滚事务。这时可以使用线程的UncaughtExceptionHandler进行异常处理,UncaughtExceptionHandler名字意味着处理未捕获的异常。更明确的说,它处理未捕获的运行时异常。

如下代码:

线程出要使用
①处要抛出异常
②处要捕捉异常,并且要抛出RuntimeException
③处手动处理回滚逻辑

 
@Service
public class ServiceA { 
   
@Autowired
private ServiceB serviceB; 
   
    @Transactional
    public void threadMethod(){ 
        this.insert(); 
        System.out.println("main insert is over"); 
        for(int a=0 ;a<3;a++){ 
            ThreadOperation threadOperation= new ThreadOperation(); 
            Thread innerThread = new Thread(threadOperation); 
            innerThread.setUncaughtExceptionHandler(new Thread.UncaughtExceptionHandler() {  
               public void uncaughtException(Thread t, Throwable e) { 
                   try { 
                        serviceB.delete();③ 
                   } catch (Exception e1) { 
                       e1.printStackTrace(); 
                   } 
               } 
            }); 
            innerThread.start(); 
        } 
    } 
   
    public  class ThreadOperation implements Runnable { 
        public ThreadOperation(){ 
        } 
        @Override
        public void run(){ 
            try { 
               serviceB.insert(); 
           }catch (Exception ex){ ② 
            System.out.println(" Exception in run "); 
               throw new RuntimeException(); 
           } 
            System.out.println("thread insert is over"); 
        } 
    } 
   
    public void insert(){ 
   
        //do insert...... 
   
    } 
} 
   
@Service
public class ServiceB { 
   
    @Transactional
    public void insert() throws Exception{ ① 
   
    //do insert...... 
   
    } 
   
    @Transactional
    public void delete() throws Exception{  
   
        //do delete...... 
   
    } 
   
} 


版权声明 : 本文内容来源于互联网或用户自行发布贡献,该文观点仅代表原作者本人。本站仅提供信息存储空间服务和不拥有所有权,不承担相关法律责任。如发现本站有涉嫌抄袭侵权, 违法违规的内容, 请发送邮件至2530232025#qq.cn(#换@)举报,一经查实,本站将立刻删除。
原文链接 :
相关文章
  • SpringBoot自定义错误处理逻辑介绍

    SpringBoot自定义错误处理逻辑介绍
    1. 自定义错误页面 将自定义错误页面放在 templates 的 error 文件夹下,SpringBoot 精确匹配错误信息,使用 4xx.html 或者 5xx.html 页面可以打印错误
  • Java实现手写一个线程池的代码

    Java实现手写一个线程池的代码
    线程池技术想必大家都不陌生把,相信在平时的工作中没有少用,而且这也是面试频率非常高的一个知识点,那么大家知道它的实现原理和
  • Java实现断点续传功能的代码

    Java实现断点续传功能的代码
    题目实现:网络资源的断点续传功能。 二、解题思路 获取要下载的资源网址 显示网络资源的大小 上次读取到的字节位置以及未读取的字节
  • 你可知HashMap为什么是线程不安全的
    HashMap 的线程不安全 HashMap 的线程不安全主要体现在下面两个方面 在 jdk 1.7 中,当并发执行扩容操作时会造成环形链和数据丢失的情况 在
  • ArrayList的动态扩容机制的介绍

    ArrayList的动态扩容机制的介绍
    对于 ArrayList 的动态扩容机制想必大家都听说过,之前的文章中也谈到过,不过由于时间久远,早已忘却。 所以利用这篇文章做做笔记,加
  • JVM基础之字节码的增强技术介绍

    JVM基础之字节码的增强技术介绍
    字节码增强技术 在上文中,着重介绍了字节码的结构,这为我们了解字节码增强技术的实现打下了基础。字节码增强技术就是一类对现有字
  • Java中的字节码增强技术

    Java中的字节码增强技术
    1.字节码增强技术 字节码增强技术就是一类对现有字节码进行修改或者动态生成全新字节码文件的技术。 参考地址 2.常见技术 技术分类 类
  • Redis BloomFilter布隆过滤器原理与实现

    Redis BloomFilter布隆过滤器原理与实现
    Bloom Filter 概念 布隆过滤器(英语:Bloom Filter)是1970年由一个叫布隆的小伙子提出的。它实际上是一个很长的二进制向量和一系列随机映射
  • Java C++算法题解leetcode801使序列递增的最小交换次

    Java C++算法题解leetcode801使序列递增的最小交换次
    题目要求 思路:状态机DP 实现一:状态机 Java 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 class Solution { public int minSwap(int[] nums1, int[] nums2) { int n
  • Mybatis结果集映射与生命周期介绍

    Mybatis结果集映射与生命周期介绍
    一、ResultMap结果集映射 1、设计思想 对简单的语句做到零配置,对于复杂一点的语句,只需要描述语句之间的关系就行了 2、resultMap的应用场
  • 本站所有内容来源于互联网或用户自行发布,本站仅提供信息存储空间服务,不拥有版权,不承担法律责任。如有侵犯您的权益,请您联系站长处理!
  • Copyright © 2017-2022 F11.CN All Rights Reserved. F11站长开发者网 版权所有 | 苏ICP备2022031554号-1 | 51LA统计