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