【SpringBoot】9、SpringBoot中利用AOP切面开启全局事务管理

在 JavaEE 的开发过程中，service 方法用于处理主要的业务逻辑，而业务逻辑的处理往往伴随着对数据库的多个操作，我们并不能保证业务逻辑可以完全正确地执行，我们需要在业务逻辑中加入事务管理，一旦程序出错，数据库可以回滚，保证数据的准确性

1、引入依赖文件

<dependency> <groupId>org.springframework</groupId> <artifactId>spring-aspects</artifactId> </dependency> 

2、创建 TransactionConfig.java 文件

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.PlatformTransactionManager; import org.springframework.transaction.TransactionDefinition; import org.springframework.transaction.interceptor.DefaultTransactionAttribute; import org.springframework.transaction.interceptor.NameMatchTransactionAttributeSource; import org.springframework.transaction.interceptor.TransactionInterceptor; / * @ClassName TransactionConfig * 事务管理配置，拦截service包下所有方法 * @Author Lizhou * @Date 2019-09-05 17:39:39 * @Version 1.0 / @Aspect @Configuration public class TransactionConfig { 
    / * 切面地址 */ private static final String AOP_POINTCUT_EXPRESSION = "execution(* com.lzzy.meet.service.*.*(..))"; / * 事务失效时间 */ private static final int TX_METHOD_TIMEOUT = 5; @Autowired private PlatformTransactionManager transactionManager; / * 事务配置 * * @return */ @Bean public TransactionInterceptor txAdvice() { 
    DefaultTransactionAttribute txAttr_REQUIRED = new DefaultTransactionAttribute(); / * PROPAGATION_REQUIRED:事务隔离性为 1 * 若当前存在事务，则加入该事务 * 如果当前没有事务，则创建一个新的事务，这是默认值 */ txAttr_REQUIRED.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRED); / * 设置事务失效时间，如果超过5秒，则回滚事务 */ txAttr_REQUIRED.setTimeout(TX_METHOD_TIMEOUT); DefaultTransactionAttribute txAttr_REQUIRED_READONLY = new DefaultTransactionAttribute(); / * transactiondefinition 定义事务的隔离级别； * PROPAGATION_NOT_SUPPORTED 事务传播级别5，以非事务运行，如果当前存在事务，则把当前事务挂起 */ txAttr_REQUIRED_READONLY.setPropagationBehavior(TransactionDefinition.PROPAGATION_NOT_SUPPORTED); / * 设置当前事务是否为只读事务 * true为只读 */ txAttr_REQUIRED_READONLY.setReadOnly(true); / * 事务管理规则，声明具备事务管理的方法名 */ NameMatchTransactionAttributeSource source = new NameMatchTransactionAttributeSource(); source.addTransactionalMethod("save*", txAttr_REQUIRED); source.addTransactionalMethod("add*", txAttr_REQUIRED); source.addTransactionalMethod("delete*", txAttr_REQUIRED); source.addTransactionalMethod("update*", txAttr_REQUIRED); source.addTransactionalMethod("get*", txAttr_REQUIRED_READONLY); source.addTransactionalMethod("query*", txAttr_REQUIRED_READONLY); source.addTransactionalMethod("find*", txAttr_REQUIRED_READONLY); source.addTransactionalMethod("list*", txAttr_REQUIRED_READONLY); source.addTransactionalMethod("count*", txAttr_REQUIRED_READONLY); return new TransactionInterceptor(transactionManager, source); } / * 利用AspectJExpressionPointcut设置切面=切点+通知（写成内部bean的方式） * * @return */ @Bean public Advisor txAdviceAdvisor() { 
    / * 声明切点的面 * 切面（Aspect）：切面就是通知和切入点的结合。 * 通知和切入点共同定义了关于切面的全部内容——它的功能、在何时和何地完成其功能 */ AspectJExpressionPointcut pointcut = new AspectJExpressionPointcut(); / * 声明和设置需要拦截的方法,用切点语言描写 */ pointcut.setExpression(AOP_POINTCUT_EXPRESSION); / * 设置切面=切点pointcut+通知TxAdvice */ return new DefaultPointcutAdvisor(pointcut, txAdvice()); } } 

3、解析

通过 @Aspect 定义一个切面，使用 @Configuration 声明当前类是一个配置类

我们业务逻辑一般都放在 service 层进行处理，所以我们定义的切入点为：com.lzzy.meet.service..(…)，即 service 下的所有方法

我们设置了事务失效时间为：5秒，超过五秒，则回滚事务，并定义了事务的隔离性和隔离级别，并声明该事务为只读

最后我们利用 AspectJExpressionPointcut 设置切面 = 切点 + 通知（写成内部bean的方式）

SpringBoot 中利用 AOP 切面开启全局事务管理就到这儿

如您在阅读中发现不足，欢迎留言！！！