Spring中的事务拦截器顺序如何控制详解

 更新时间:2024年01月25日 08:54:55   作者:小明的学习圈子  
这篇文章主要介绍了Spring中的事务拦截器顺序如何控制详解,那么spring事务拦截器的顺序如何控制呢,若我们自己也添加了一些拦截器,此时事务拦截器和自定义拦截器共存的时候,他们的顺序是怎么执行的?如何手动来控制他们的顺序,需要的朋友可以参考下

1、前言

咱们知道 Spring 事务是通过aop的方式添加了一个事务拦截器,事务拦截器会拦截目标方法的执行,在方法执行前后添加了事务控制。

那么spring事务拦截器的顺序如何控制呢,若我们自己也添加了一些拦截器,此时事务拦截器和自定义拦截器共存的时候,他们的顺序是怎么执行的?如何手动来控制他们的顺序??

可能有些朋友会问,控制他们的顺序,这个功能有什么用呢?为什么要学这个

学会了这些,你可以实现很多牛逼的功能,比如

1、读写分离

2、通用幂等框架

3、分布式事务框架

对这些有兴趣么?那么咱们继续。

2、事务拦截器顺序设置

@EnableTransactionManagement 注解有个 order属性,默认值是Integer.MAX_VALUE,用来指定事务拦截器的顺序,值越小,拦截器的优先级越高,如:

@EnableTransactionManagement(order = 2)

下面来看案例。

3、案例

我们自定义2个拦截器:一个放在事务拦截器之前执行,一个放在事务拦截器之后执行

拦截器顺序
TransactionInterceptorBefore1
@EnableTransactionManagement 事务拦截器2
TransactionInterceptorAfter3

3.1、准备sql

DROP DATABASE IF EXISTS javacode2018;
CREATE DATABASE if NOT EXISTS javacode2018;

USE javacode2018;
DROP TABLE IF EXISTS t_user;
CREATE TABLE t_user(
  id int PRIMARY KEY AUTO_INCREMENT,
  name varchar(256) NOT NULL DEFAULT '' COMMENT '姓名'
);

3.2、Spring配置类MainConfig10

@1:开启了事务管理功能,并且设置了事务拦截器的顺序是2,spring事务拦截器完整类名是

org.springframework.transaction.interceptor.TransactionInterceptor

@2:开启aop功能

package com.javacode2018.tx.demo10;

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.ComponentScan;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.EnableAspectJAutoProxy;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;
import org.springframework.transaction.PlatformTransactionManager;
import org.springframework.transaction.annotation.EnableTransactionManagement;

import javax.sql.DataSource;

@Configuration //说明当前类是一个配置类
@ComponentScan //开启bean自动扫描注册功能
@EnableTransactionManagement(order = 2) //@1:设置事务拦截器的顺序是2
@EnableAspectJAutoProxy // @2:开启@Aspect Aop功能
public class MainConfig10 {
    @Bean
    public DataSource dataSource() {
        org.apache.tomcat.jdbc.pool.DataSource dataSource = new org.apache.tomcat.jdbc.pool.DataSource();
        dataSource.setDriverClassName("com.mysql.jdbc.Driver");
        dataSource.setUrl("jdbc:mysql://localhost:3306/javacode2018?characterEncoding=UTF-8");
        dataSource.setUsername("root");
        dataSource.setPassword("root123");
        dataSource.setInitialSize(5);
        return dataSource;
    }

    //定义一个jdbcTemplate
    @Bean
    public JdbcTemplate jdbcTemplate(DataSource dataSource) {
        return new JdbcTemplate(dataSource);
    }

    //定义事务管理器transactionManager
    @Bean
    public PlatformTransactionManager transactionManager(DataSource dataSource) {
        return new DataSourceTransactionManager(dataSource);
    }
}

3.3、定义一个有事务的Service类

addUser方法上面添加了@Transactional注解,表示使用spring来管理事务,方法内部向db中插入了一条数据,为了方便分析结果,方法内部输出了2行日志

package com.javacode2018.tx.demo10;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Component;
import org.springframework.transaction.annotation.Transactional;
@Component
public class UserService {
    @Autowired
    private JdbcTemplate jdbcTemplate;
    @Transactional
    public void addUser() {
        System.out.println("--------UserService.addUser start");
        this.jdbcTemplate.update("insert into t_user(name) VALUES (?)", "张三");
        System.out.println("--------UserService.addUser end");
    }
}

3.4、自定义第1个拦截器,放在事务拦截器之前执行

下面通过Aspect的方式定义了一个拦截器,顺序通过**@Order(1)设置的是1**,那么这个拦截器会在事务拦截器之前执行。

package com.javacode2018.tx.demo10;
import org.aopalliance.intercept.Joinpoint;
import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.Around;
import org.aspectj.lang.annotation.Aspect;
import org.aspectj.lang.annotation.Pointcut;
import org.springframework.core.annotation.Order;
import org.springframework.stereotype.Component;
@Component
@Aspect
@Order(1) //@1
public class TransactionInterceptorBefore {
    @Pointcut("execution(* com.javacode2018.tx.demo10.UserService.*(..))")
    public void pointcut() {
    }
    @Around("pointcut()")
    public Object tsBefore(ProceedingJoinPoint joinPoint) throws Throwable {
        System.out.println("--------before start!!!");
        Object result = joinPoint.proceed();
        System.out.println("--------before end!!!");
        return result;
    }
} 

3.5、自定义第2个拦截器,放在事务拦截器后面执行

这个拦截器的order是3,会在事务拦截器后面执行。

package com.javacode2018.tx.demo10;
import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.Around;
import org.aspectj.lang.annotation.Aspect;
import org.aspectj.lang.annotation.Pointcut;
import org.springframework.core.annotation.Order;
import org.springframework.stereotype.Component;
@Component
@Aspect
@Order(2)
public class TransactionInterceptorAfter {
    @Pointcut("execution(* com.javacode2018.tx.demo10.UserService.*(..))")
    public void pointcut() {
    }
    @Around("pointcut()")
    public Object tsAfter(ProceedingJoinPoint joinPoint) throws Throwable {
        System.out.println("--------after start!!!");
        Object result = joinPoint.proceed();
        System.out.println("--------after end!!!");
        return result;
    }
}

3.6、添加测试类

package com.javacode2018.tx.demo10;
import org.junit.Before;
import org.junit.Test;
import org.springframework.context.annotation.AnnotationConfigApplicationContext;
import org.springframework.jdbc.core.JdbcTemplate;
public class Demo10Test {
    private UserService userService;
    private JdbcTemplate jdbcTemplate;
    @Before
    public void before() {
        AnnotationConfigApplicationContext context = new AnnotationConfigApplicationContext(MainConfig10.class);
        userService = context.getBean(UserService.class);
        this.jdbcTemplate = context.getBean("jdbcTemplate", JdbcTemplate.class);
        jdbcTemplate.update("truncate table t_user");
    }
    @Test
    public void test1() {
        this.userService.addUser();
    }
}

运行test1输出:

--------before start!!!
--------after start!!!
--------UserService.addUser start
--------UserService.addUser end
--------after end!!!
--------before end!!!

结果和上图中一致,大家可以在3个拦截器中设置一下断点,调试一下可以看到更详细的信息,可加深理解。

4、总结

今天的内容算是比较简单的,重点要掌握如何设置事务拦截器的顺序,@EnableTransactionManagement 有个 order属性,默认值是Integer.MAX_VALUE,用来指定事务拦截器的顺序,值越小,拦截器的优先级越高。

后面我们会通过这个功能实现读写分离,通用幂等性的功能。

到此这篇关于Spring中的事务拦截器顺序如何控制详解的文章就介绍到这了,更多相关Spring事务拦截器顺序内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!

相关文章

  • Java中如何计算一段程序的运行时间

    Java中如何计算一段程序的运行时间

    这篇文章主要介绍了Java中如何计算一段程序的运行时间问题,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2023-03-03
  • SpringBootWeb 入门了解 Swagger 的具体使用

    SpringBootWeb 入门了解 Swagger 的具体使用

    这篇文章主要介绍了SpringBootWeb 入门了解 Swagger 的具体使用,Swagger 框架可以根据已经实现的方法或者类,通过页面的方式直观清晰的查看或者进行测试该方法,需要的朋友可以参考下
    2024-08-08
  • 详解时间轮TimeWheel的工作原理

    详解时间轮TimeWheel的工作原理

    时间轮(TimeWheel)作为一种高效率的计时器实现方案,在1987年发表的论文Hashed and Hierarchical Timing Wheels中被首次提出。本文主要来聊聊它的工作原理,感兴趣的可以了解一下
    2023-02-02
  • http协议进阶之Transfer-Encoding和HttpCore实现详解

    http协议进阶之Transfer-Encoding和HttpCore实现详解

    这篇文章主要给大家介绍了http协议之Transfer-Encoding和HttpCore实现的相关资料,文中介绍的非常详细,相信对大家具有一定的参考价值,需要的朋友们下面来一起看看吧。
    2017-04-04
  • Java使用Lua实现动态扩展和脚本自动升级

    Java使用Lua实现动态扩展和脚本自动升级

    Lua是一种轻量级的脚本语言,常用于游戏开发和嵌入式系统中,这篇文章主要介绍了Java如何调用Lua实现动态扩展和脚本自动升级,感兴趣的可以学习下
    2023-08-08
  • java如何获取yml配置文件工具类

    java如何获取yml配置文件工具类

    本文介绍了java获取yml配置文件的工具类引入pom文件的方法,首先,创建一个与工具类同名的类,然后将工具类的代码复制到新创建的类中,运行后输出:0*/1***?完成操作,此方法简单易行,适合初学者使用
    2024-10-10
  • 新手必备的IDEA常用设置总结

    新手必备的IDEA常用设置总结

    今天给大家总结了一些IDEA的常用设置,文中有非常详细的图文介绍,对正在学习使用IDEA的小伙伴们很有帮助,需要的朋友可以参考下
    2021-05-05
  • Java截取url参数的方法

    Java截取url参数的方法

    本文给大家带来了java截取url参数,url值得方法,代码简单易懂,非常不错,具有参考借鉴价值,感兴趣的朋友一起学习吧
    2016-08-08
  • SpringBoot如何统一配置bean的别名

    SpringBoot如何统一配置bean的别名

    这篇文章主要介绍了SpringBoot如何统一配置bean的别名,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2019-11-11
  • Java通用BouncyCastle实现的DES3加密的方法

    Java通用BouncyCastle实现的DES3加密的方法

    这篇文章主要介绍了Java通用BouncyCastle实现的DES3加密的方法,本文给大家介绍的非常详细,对大家的学习或工作,具有一定的参考借鉴价值,需要的朋友可以参考下
    2020-12-12

最新评论