开心一笑: 会买水果的狗狗

    关注微信公众号

    QQ群:831045818

    app下载

    当前位置:首页> java > 技术文档 > 正文
    SpringBoot 事物
    发布时间:2024-02-07 11:16:16 浏览次数:

    事务,就是一组操作数据库的动作集合。事务是现代数据库理论中的核心概念之一。如果一组处理步骤或者全部发生或者一步也不执行,我们称该组处理步骤为一个事务。当所有的步骤像一个操作一样被完整地执行,我们称该事务被提交。由于其中的一部分或多步执行失败,导致没有步骤被提交,则事务必须回滚到最初的系统状态。

    事务特点

    • 原子性:一个事务中所有对数据库的操作是一个不可分割的操作序列,要么全做要么全不做

    • 一致性:数据不会因为事务的执行而遭到破坏

    • 隔离性:一个事务的执行,不受其他事务的干扰,即并发执行的事务之间互不干扰

    • 持久性:一个事务一旦提交,它对数据库的改变就是永久的。

    事务实现机制

    Spring 为事务管理提供了丰富的功能支持。Spring 事务管理分为编码式和声明式的两种方式。

    • 编程式事务管理:编程式事务管理使用TransactionTemplate或者直接使用底层的PlatformTransactionManager。对于编程式事务管理,spring推荐使用TransactionTemplate。

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

    声明式事务管理不需要入侵代码,更快捷而且简单,推荐使用。

    声明式事务有两种方式:

    • 一种是在配置文件(xml)中做相关的事务规则声明(因为很少用本文不讲解)

    • 另一种是基于@Transactional注解的方式。注释配置是目前流行的使用方式,推荐使用。

    在应用系统调用声明了@Transactional的目标方法时,Spring Framework默认使用 AOP 代理,在代码运行时生成一个代理对象,根据@Transactional的属性配置信息,这个代理对象决定该声明@Transactional的目标方法是否由拦截器TransactionInterceptor来使用拦截,在TransactionInterceptor拦截时,会在目标方法开始执行之前创建并加入事务,并执行目标方法的逻辑,最后根据执行情况是否出现异常,利用抽象事务管理器AbstractPlatformTransactionManager操作数据源DataSource提交或回滚事务。

    Spring AOP 代理有CglibAopProxy和JdkDynamicAopProxy两种,以CglibAopProxy为例,对于CglibAopProxy,需要调用其内部类的DynamicAdvisedInterceptor的intercept方法。对于JdkDynamicAopProxy,需要调用其 invoke 方法。

    开启事务 注解@Transactional的使用 注解@Transactional常用配置    Propagation的属性(事务的传播行为)

    例如:@Transactional(propagation=Propagation.NOT_SUPPORTED,readOnly=true)

     事务5种隔离级别

    例如:@Transactional(isolation = Isolation.READ_COMMITTED)

     使用注意事项(防止事务失效)

    1.在具体的类(或类的方法)上使用@Transactional注解,而不要使用在类所要实现的任何接口上。

    2.@Transactional注解应该只被应用在public修饰的方法上。 如果你在protected、private或者package-visible的方法上使用 该注解,它也不会报错(IDEA会有提示), 但事务并没有生效。

    3.被外部调用的公共方法A有两个进行了数据操作的子方法B和子方法C的事务注解说明:

    • 被外部调用的公共方法A未声明事务@Transactional,子方法B和C若是其他类的方法且各自声明事务,则事务由子方法B和C各自控制

    • 被外部调用的公共方法A未声明事务@Transactional,子方法B和C若是本类的方法,则无论子方法B和C是否声明事务,事务均不会生效

    • 被外部调用的公共方法A声明事务@Transactional,无论子方法B和C是不是本类的方法,无论子方法B和C是否声明事务,事务均由公共方法A控制

    • 被外部调用的公共方法A声明事务@Transactional,子方法运行异常,但运行异常被子方法自己 try-catch 处理了,则事务回滚是不会生效的!

    如果想要事务回滚生效,需要将子方法的事务控制交给调用的方法来处理:

    • 方案1:子方法中不用 try-catch 处理运行异常

    • 方案2:子方法的catch里面将运行异常抛出【 throw new RuntimeException();】

    4.默认情况下,Spring会对unchecked异常进行事务回滚,也就是默认对RuntimeException()异常或是其子类进行事务回滚。如果是checked异常则不回滚,例如空指针异常、算数异常等会被回滚;文件读写、网络问题Spring就没法回滚。

    若想对所有异常(包括自定义异常)都起作用,注解上面需配置异常类型:@Transactional(rollbackFor = Exception.class

    5.数据库要支持事务,如果是mysql,要使用innodb引擎,myisam不支持事务

    6.事务@Transactional由spring控制时,它会在抛出异常的时候进行回滚。如果自己使用try-catch捕获处理了,是不生效的。如果想事务生效可以进行手动回滚或者在catch里面将异常抛出【throw new RuntimeException();】

    方案一:手动抛出运行时异常(缺陷是不能在catch代码块自定义返回值)

    try{
    ....
    }catch(Exceptione){
    logger.error("",e);
    thrownewRuntimeException(e);
    }

    方案二:手动进行回滚【TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();】

    try{
    ...
    }catch(Exceptione){
    log.error("fail",e);
    TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
    returnfalse;
    }

    @Transactional可以放在Controller下面直接起作用,看到网上好多同学说要放到@Component下面或者@Service下面,经过试验,可以不用放在这两个下面也起作用。

    @Transactional引入包问题,它有两个包:

    importjavax.transaction.Transactional;
    //和
    importorg.springframework.transaction.annotation.Transactional;//推荐

    这两个都可以用,对比了一下他们两个的方法和属性,发现后面的比前面的强大。建议使用后面的。

    使用场景 自动回滚

    直接抛出,不try/catch

    @Override
    @Transactional(rollbackFor=Exception.class)
    publicObjectsubmitOrder()throwsException{
    success();
    //假如exception这个操作数据库的方法会抛出异常,方法success()对数据库的操作会回滚。
    exception();
    returnApiReturnUtil.success();
    }

    手动回滚

    进行try/catch,回滚并抛出

    @Override
    @Transactional(rollbackFor=Exception.class)
    publicObjectsubmitOrder(){
    success();
    try{
    exception();
    }catch(Exceptione){
    e.printStackTrace();
    //手动回滚事务
    TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
    returnApiReturnUtil.error();
    }
    returnApiReturnUtil.success();
    }

    回滚部分异常

    使用【Object savePoint = TransactionAspectSupport.currentTransactionStatus().createSavepoint();】设置回滚点。

    使用【TransactionAspectSupport.currentTransactionStatus().rollbackToSavepoint(savePoint);】回滚到savePoint。

    @Override
    @Transactional(rollbackFor=Exception.class)
    publicObjectsubmitOrder(){
    success();
    //只回滚以下异常,
    ObjectsavePoint=TransactionAspectSupport.currentTransactionStatus().createSavepoint();
    try{
    exception();
    }catch(Exceptione){
    e.printStackTrace();
    //手工回滚事务
    TransactionAspectSupport.currentTransactionStatus().rollbackToSavepoint(savePoint);
    returnApiReturnUtil.error();
    }
    returnApiReturnUtil.success();
    }

    手动创建、提交、回滚事务

    PlatformTransactionManager这个接口中定义了三个方法getTransaction创建事务,commit 提交事务,rollback 回滚事务。它的实现类是AbstractPlatformTransactionManager。

    @Autowired
    priDataSourceTransactionManagerdataSourceTransactionManager;
    @Autowired
    TransactionDefinitiontransactionDefinition;
    
    //手动创建事务
    TransactionStatustransactionStatus=dataSourceTransactionManager.getTransaction(transactionDefinition);
    
    //手动提交事务
    dataSourceTransactionManager.commit(transactionStatus);
    
    //手动回滚事务。(最好是放在catch里面,防止程序异常而事务一直卡在哪里未提交)
    dataSourceTransactionManager.rollback(transactionStatus);

    事务失效不回滚的原因及解决方案 异常被捕获导致事务失效

    在spring boot 中,使用事务非常简单,直接在方法上面加入@Transactional就可以实现。

    @GetMapping("delete")
    @ResponseBody
    @Transactional
    publicvoiddelete(@RequestParam("id")intid){
    try{
    //deletecountry
    this.repository.delete(id);
    if(id==1){
    throwException("测试事务");
    }
    //deletecity
    this.repository.deleteByCountryId(id);
    }catch(Exceptione){
    logger.error("deletefalse:"+e.getMessage());
    }
    }

    发现事务不回滚,即this.repository.delete(id);成功把数据删除了。

    原因:

    默认spring事务只在发生未被捕获的RuntimeException时才回滚。

    spring aop 异常捕获原理:被拦截的方法需显式抛出异常,并不能经任何处理,这样aop代理才能捕获到方法的异常,才能进行回滚,默认情况下aop只捕获RuntimeException的异常,但可以通过配置来捕获特定的异常并回滚。

    换句话说在service的方法中不使用 try catch 或者在 catch 中最后加上throw new RuntimeExcetpion()抛出运行异常,这样程序异常时才能被aop捕获进而回滚。

    解决方案:

    org.springframeworkspring-aspects4.3.2.RELEASEorg.aspectjaspectjrt1.8.9org.codehaus.mojoaspectj-maven-plugin1.9trueorg.springframeworkspring-aspectscompiletest-compile

    解决方案

    方案1、在类上(或者最外层的公共方法)加事务

    @Service
    @Slf4j
    publicclassMyTransactional{
    
    //最外层公共方法。自动回滚事务方式,insertOrder()方法报错后事务回滚,且线程中止,后续逻辑无法执行
    @Transactional
    publicvoidtest1(){
    this.insertOrder();
    System.out.println("11111111111111111");
    }
    
    //最外层公共方法。手动回滚事务方式,insertOrder()方法报错后事务回滚,可以继续执行后续逻辑
    @Transactional
    publicvoidtest2(){
    try{
    insertOrder();
    }catch(Exceptione){
    log.error("faildto...",e);
    //手动回滚事务
    TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
    //其他操作
    }
    //其他操作
    }
    
    //进行数据库操作的方法(private或public均可)
    privatevoidinsertOrder(){
    //insertloginfo
    //insertOrder
    //updateAccount
    }
    }

    方案 2、使用AspectJ取代 Spring AOP 代理

    上面的两个问题@Transactional注解只应用到 public 方法和自调用问题,是由于使用 Spring AOP 代理造成的。为解决这两个问题,可以使用 AspectJ 取代 Spring AOP 代理。

    需要将下面的 AspectJ 信息添加到 xml 配置信息中。

    AspectJ 的 xml 配置信息


    同时在 Maven 的 pom 文件中加入spring-aspects和aspectjrt的dependency以及aspectj-maven-plugin。

    AspectJ 的 pom 配置信息

    • 方案1:例如service层处理事务,那么service中的方法中不做异常捕获,或者在catch语句中最后增加throw new RuntimeException();语句,以便让aop捕获异常再去回滚,并且在service的上层要继续捕获这个异常。

    • 方案2:在service层方法的catch语句中进行手动回滚,这样上层就无需去处理异常。

    @GetMapping("delete")
    @ResponseBody
    @Transactional
    publicObjectdelete(@RequestParam("id")intid){
    if(id<1){
    returnnewMessageBean(101,"parameterwrong:id="+id);
    }
    try{
    //deletecountry
    this.countryRepository.delete(id);
    //deletecity
    this.cityRepository.deleteByCountryId(id);
    returnnewMessageBean(200,"deletesuccess");
    }catch(Exceptione){
    logger.error("deletefalse:"+e.getMessage());
    //手动回滚
    TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
    returnnewMessageBean(101,"deletefalse");
    }
    }

    自调用导致事务失效 问题描述及原因

    在 Spring 的 AOP 代理下,只有目标方法由外部调用,目标方法才由 Spring 生成的代理对象来管理,否则会造成自调用问题。

    若同一类中的 没有@Transactional注解的方法 内部调用 有@Transactional注解的方法,有@Transactional注解的方法的事务被忽略,不会发生回滚。见 示例代码展示。

    自调用问题示例:

    @Service
    publicclassOrderService{
    
    privatevoidinsert(){
    insertOrder();
    }
    
    @Transactional
    publicvoidinsertOrder(){
    //insertloginfo
    //insertOrder
    //updateAccount
    }
    }
    
    //insertOrder()尽管有@Transactional注解,但它被内部方法insert()调用,事务被忽略,出现异常事务不会发生回滚,并且会报错类似于:org.springframework.transaction.NoTransactionException:Notransactionaspect-managedTransactionStatusinscope(翻译:没有Transaction无法回滚事务。自调用导致@Transactional失效。)

    自调用失效原因:

    spring里事务是用注解配置的,当一个方法没有接口,单单只是一个内部方法时,事务的注解是不起作用的,需要回滚时就会报错。

    出现这个问题的根本原因是:

    @Transactional 的实现原理是AOP,AOP的实现原理是动态代理,而自调用时并不存在代理对象的调用,也就不会产生基于AOP 的事务回滚操作

    虽然可以直接从容器中获取代理对象,但这样有侵入之嫌,不推荐。

    org.springframeworkspring-aspects4.3.2.RELEASEorg.aspectjaspectjrt1.8.9org.codehaus.mojoaspectj-maven-plugin1.9trueorg.springframeworkspring-aspectscompiletest-compile

    其他 事务提交方式

    默认情况下,数据库处于自动提交模式。每一条语句处于一个单独的事务中,在这条语句执行完毕时,如果执行成功则隐式的提交事务,如果执行失败则隐式的回滚事务。

    对于正常的事务管理,是一组相关的操作处于一个事务之中,因此必须关闭数据库的自动提交模式。不过,这个我们不用担心,spring 会将底层连接的【自动提交特性】设置为 false 。

    也就是在使用 spring 进行事务管理的时候,spring 会将【是否自动提交】设置为false,等价于JDBC中的connection.setAutoCommit(false);,在执行完之后在进行提交connection.commit();。

    事务回滚规则

    指示spring事务管理器回滚一个事务的推荐方法是在当前事务的上下文内抛出异常。spring事务管理器会捕捉任何未处理的异常,然后依据规则决定是否回滚抛出异常的事务。

    默认配置下,spring只有在抛出的异常为运行时unchecked异常时才回滚该事务,也就是抛出的异常为RuntimeException的子类(Errors也会导致事务回滚),而抛出checked异常则不会导致事务回滚。

    可以明确的配置在抛出那些异常时回滚事务,包括checked异常。也可以明确定义那些异常抛出时不回滚事务。

    事务并发会产生的问题    第一类丢失更新

    在没有事务隔离的情况下,两个事务都同时更新一行数据,但是第二个事务却中途失败退出, 导致对数据的两个修改都失效了。

    例如:

    张三的工资为5000,事务A中获取工资为5000,事务B获取工资为5000,汇入100,并提交数据库,工资变为5100;

    随后,事务A发生异常,回滚了,恢复张三的工资为5000,这样就导致事务B的更新丢失了。

    脏读

    脏读就是指当一个事务正在访问数据,并且对数据进行了修改,而这种修改还没有提交到数据库中,这时,另外一个事务也访问这个数据,然后使用了这个数据。

    例如:

    张三的工资为5000,事务A中把他的工资改为8000,但事务A尚未提交。

    与此同时,事务B正在读取张三的工资,读取到张三的工资为8000。

    随后,事务A发生异常,回滚了事务,张三的工资又回滚为5000。

    最后,事务B读取到的张三工资为8000的数据即为脏数据,事务B做了一次脏读。

    不可重复读

    是指在一个事务内,多次读同一数据。在这个事务还没有结束时,另外一个事务也访问该同一数据。那么,在第一个事务中的两次读数据之间,由于第二个事务的修改,那么第一个事务两次读到的的数据可能是不一样的。这样就发生了在一个事务内两次读到的数据是不一样的,因此称为是不可重复读。

    例如:

    在事务A中,读取到张三的工资为5000,操作没有完成,事务还没提交。

    与此同时,事务B把张三的工资改为8000,并提交了事务。

    随后,在事务A中,再次读取张三的工资,此时工资变为8000。在一个事务中前后两次读取的结果并不致,导致了不可重复读。

    第二类丢失更新

    不可重复读的特例。

    有两个并发事务同时读取同一行数据,然后其中一个对它进行修改提交,而另一个也进行了修改提交。这就会造成第一次写操作失效。

    例如:

    在事务A中,读取到张三的存款为5000,操作没有完成,事务还没提交。

    与此同时,事务B存入1000,把张三的存款改为6000,并提交了事务。

    随后,在事务A中,存储500,把张三的存款改为5500,并提交了事务,这样事务A的更新覆盖了事务B的更新。

    关注"都市百货" 了解南陵

    微信咨询wanglf2r(不拉群 发广告者勿加)

    0
    0
    上一篇:Spring工具类 上一篇:windows 远程执行

    评论已有0

    提交评论

    热门评论

    南陵新闻
    公示公告
    常用查询
    风光南陵
    走出南陵
    友情链接