首页 > 其他分享 >SpringBoot2.x 事务

SpringBoot2.x 事务

时间:2022-11-19 15:22:08浏览次数:71  
标签:事务管理 事务 回滚 SpringBoot2 org import 异常

1.事务管理方式  

事务管理对于企业应用来说是至关重要的,即使出现异常情况,它也可以保证数据的一致性。

spring支持编程式事务管理和声明式事务管理两种方式。

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

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

  声明式事务管理也有两种常用的方式,一种是基于tx和aop名字空间的xml配置文件,另一种就是基于@Transactional注解。显然基于注解的方式更简单易用,更清爽。

2.@Transactional 是声明式事务管理 编程中使用的注解

1)访问权限

接口实现类或接口实现方法上,而不是接口类中。

2)访问权限

public 的方法才起作用。@Transactional 注解应该只被应用到 public 方法上,这是由 Spring AOP 的本质决定的。
系统设计:将标签放置在需要进行事务管理的方法上,而不是放在所有接口实现类上:只读的接口就不需要事务管理,由于配置了@Transactional就需要AOP拦截及事务的处理,可能影响系统性能。

3)使用说明

当作用于类上时,该类的所有 public 方法将都具有该类型的事务属性,同时,我们也可以在方法级别使用该标注来覆盖类级别的定义。

在项目中,@Transactional(rollbackFor=Exception.class),如果类加了这个注解,那么这个类里面的方法抛出异常,就会回滚,数据库里面的数据也会回滚。

在@Transactional注解中如果不配置rollbackFor属性,那么事物只会在遇到RuntimeException的时候才会回滚,加上rollbackFor=Exception.class,可以让事物在遇到非运行时异常时也回滚

错误使用:

1.接口中A、B两个方法,A无@Transactional标签,B有,上层通过A间接调用B,此时事务不生效。
 
2.接口中异常(运行时异常)被捕获而没有被抛出。
  默认配置下,spring 只有在抛出的异常为运行时 unchecked 异常时才回滚该事务,
  也就是抛出的异常为RuntimeException 的子类(Errors也会导致事务回滚),
  而抛出 checked 异常则不会导致事务回滚 。可通过 @Transactional rollbackFor进行配置。
 
3.多线程下事务管理因为线程不属于 spring 托管,故线程不能够默认使用 spring 的事务,
  也不能获取spring 注入的 bean 。
  在被 spring 声明式事务管理的方法内开启多线程,多线程内的方法不被事务控制。
  一个使用了@Transactional 的方法,如果方法内包含多线程的使用,方法内部出现异常,
  不会回滚线程中调用方法的事务。

@Transactional注解的全部属性详解

@Transactional属性

 
属性类型描述
value String 可选的限定描述符,指定使用的事务管理器
propagation enum: Propagation 可选的事务传播行为设置
isolation enum: Isolation 可选的事务隔离级别设置
readOnly boolean 读写或只读事务,默认读写
timeout int (in seconds granularity) 事务超时时间设置
rollbackFor Class对象数组,必须继承自Throwable 导致事务回滚的异常类数组
rollbackForClassName 类名数组,必须继承自Throwable 导致事务回滚的异常类名字数组
noRollbackFor Class对象数组,必须继承自Throwable 不会导致事务回滚的异常类数组
noRollbackForClassName 类名数组,必须继承自Throwable 不会导致事务回滚的异常类名字

3.全局事务配置

首先需要在启动类上加上事务开启注解@EnableTransactionManagement

@SpringBootApplication(scanBasePackages = "com.xxx")
@MapperScan("com.xxx.service.db.repository")
@EnableDiscoveryClient
@EnableFeignClients
@EnableTransactionManagement
public class CSServiceApplication {

    public static void main(String[] args) {
        SpringApplication.run(MthCmsServiceApplication.class, args);
    }

}

AOP依赖:

<dependency>  
      <groupId>org.springframework.boot</groupId>  
     <artifactId>spring-boot-starter-aop</artifactId>  
</dependency> 

全局事务管理配置如下,复制粘贴即用,但是得注意一点,增强的方法命名必须服从下面配置的规范:

package com.xxx.service.config;

import org.aspectj.lang.annotation.Aspect;
import org.springframework.aop.Advisor;
import org.springframework.aop.aspectj.AspectJExpressionPointcut;
import org.springframework.aop.support.DefaultPointcutAdvisor;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.transaction.TransactionDefinition;
import org.springframework.transaction.TransactionManager;
import org.springframework.transaction.interceptor.NameMatchTransactionAttributeSource;
import org.springframework.transaction.interceptor.RollbackRuleAttribute;
import org.springframework.transaction.interceptor.RuleBasedTransactionAttribute;
import org.springframework.transaction.interceptor.TransactionInterceptor;
import java.util.Collections;

/**
 * @description 全局事务管理
 */
@Aspect
@Configuration
public class CSTransactionConfig {

    private static final String AOP_POINTCUT_EXPRESSION = "execution(* com.xxx.service.web.service.*.*(..))";
    private static final String[] REQUIRED_RULE_TRANSACTION = {"insert*", "create*", "add*", "save*","modify*", "update*", "del*", "delete*"};
    private static final String[] READ_RULE_TRANSACTION = {"select*", "get*", "query*", "search*", "count*","detail*", "find*"};

    @Autowired
    private TransactionManager transactionManager;

    @Bean
    public TransactionInterceptor txAdvice() {
        RuleBasedTransactionAttribute REQUIRED = new RuleBasedTransactionAttribute();
        REQUIRED.setRollbackRules(Collections.singletonList(new RollbackRuleAttribute(Exception.class)));
        REQUIRED.setIsolationLevel(TransactionDefinition.ISOLATION_READ_COMMITTED);
        REQUIRED.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRED);
        RuleBasedTransactionAttribute READONLY = new RuleBasedTransactionAttribute();
        READONLY.setRollbackRules(Collections.singletonList(new RollbackRuleAttribute(Exception.class)));
        READONLY.setIsolationLevel(TransactionDefinition.ISOLATION_READ_COMMITTED);
        READONLY.setPropagationBehavior(TransactionDefinition.PROPAGATION_SUPPORTS);
        READONLY.setReadOnly(true);
        NameMatchTransactionAttributeSource source = new NameMatchTransactionAttributeSource();

        for (String s : REQUIRED_RULE_TRANSACTION) {
            source.addTransactionalMethod(s, REQUIRED);
        }

        for (String s : READ_RULE_TRANSACTION) {
            source.addTransactionalMethod(s, READONLY);
        }

        return new TransactionInterceptor(transactionManager, source);
    }

    @Bean
    public Advisor txAdviceAdvisor(TransactionInterceptor txAdvice) {
        AspectJExpressionPointcut pointcut = new AspectJExpressionPointcut();
        pointcut.setExpression(AOP_POINTCUT_EXPRESSION);
        return new DefaultPointcutAdvisor(pointcut, txAdvice);
    }
}

总结:
1、首先在使用事务之前,要在启动类里面引入注解 @EnableTransactionManagement
2、使用全局事务的时候,方法命名一定要在上述规范中,切勿出现奇葩命名

4.异常

如下图所示,我们都知道Exception分为运行时异常RuntimeException和非运行时异常

error是一定会回滚的

 

 

 

如果不对运行时异常进行处理,那么出现运行时异常之后,要么是线程中止,要么是主程序终止。 
如果不想终止,则必须捕获所有的运行时异常,决不让这个处理线程退出。队列里面出现异常数据了,正常的处理应该是把异常数据舍弃,然后记录日志。不应该由于异常数据而影响下面对正常数据的处理。

非运行时异常是RuntimeException以外的异常,类型上都属于Exception类及其子类。如IOException、SQLException等以及用户自定义的Exception异常。对于这种异常,JAVA编译器强制要求我们必需对出现的这些异常进行catch并处理,否则程序就不能编译通过。所以,面对这种异常不管我们是否愿意,只能自己去写一大堆catch块去处理可能的异常。

 

 

标签:事务管理,事务,回滚,SpringBoot2,org,import,异常
From: https://www.cnblogs.com/mihutao/p/16906198.html

相关文章

  • Spring 事务传播行为
    事务传播行为指当事务方法被另外一个事务方法调用时,必须指定事务应该如何传播,例如,方法可能继续在当前事务中执行,也可以开启一个新的事务,在自己的事务中执行。声明式事务......
  • 如何快速优化事务性(OLTP)SQL Server性能?
    如我们所知,事务性(OLTP)SQLServer是很大部分医疗机构会选择的数据库之一,使用频率很高,发生卡、慢的机率也随之增加,那我们如何快速的对它进行性能优化呢?下面我们将利用几个重......
  • Spring —— 事务角色&&事务属性
    事务角色事务管理员:发起事务方,在Spring中通常指代业务层开启事务的方法事务协调员:加入事务方,在Spring中通常指代数据层方法,也可以是业务层方法      事务属性......
  • 事务回滚情况实战
    一、前置知识1、Java异常中,Throwable是最顶层的父类,有Error和Exception两个子类2、Exception分为运行时异常(RuntimeException及其子类)和非运行时异常(Exception子类中,......
  • Spring —— 事务简介
    Spring事务简介事务作用:在数据层保障一系列的数据库操作同成功同失败Spring事务作用:在数据层或业务层保障一系列的数据库操作同成功同失败 小案例     ......
  • 一次分布式锁与数据库事务的纠缠
    有一个需要保证并发安全性的方法,考虑到锁的粒度与分布式要求,选择了基于Redis的分布式锁。需要保证并发安全性的原因是该方法会并发操作数据库某表中的数据。......
  • Spring中手动控制事务
    在spring中大部分时候使用的是声明式事务,也就是@Transaction注解,但在某些特殊情况下也需要手动控制事务的开启/提交/回滚。工具类封装:1@Component2pu......
  • 1、Spring事务失效的几种原因
    Spring事务失效的几种原因1、Bean没有被Spring管理,即类上没有加入@Service、@Component等注解。2、方法没有使用public修饰加@Transactional注解的方法必须用public关键......
  • 学习springboot2的第7天(2021-12-06)43-视图解析-Thymeleaf初体验
    学习springboot2的第7天(2021-12-06)43-视图解析-Thymeleaf初体验视图解析:指的就是springboot在处理完请求之后想要跳转到某个页面的过程。springboot默认不支持JSP,需要引入第......
  • 12.Seata:Spring Cloud Alibaba分布式事务组件(非常详细)
    随着业务的不断发展,单体架构已经无法满足我们的需求,分布式微服务架构逐渐成为大型互联网平台的首选,但所有使用分布式微服务架构的应用都必须面临一个十分棘手的问题,那就是......