一、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......  
   
    }  
   
}  

到此这篇关于详解spring中的transactional属性的文章就介绍到这了,更多相关transactional属性详解内容请搜索www.887551.com以前的文章或继续浏览下面的相关文章希望大家以后多多支持www.887551.com!