Spring源码剖析之Transactional事务

本文涉及的产品
全局流量管理 GTM,标准版 1个月
云解析 DNS,旗舰版 1个月
公共DNS(含HTTPDNS解析),每月1000万次HTTP解析
简介: 我们知道使用@Transactional,要满足以下条件1、配置数据源 DataSource2、配置事务管理器 PlatformTransactionManager3、配置类上标识 @EnableTransactionManagement

准备

我们知道使用@Transactional,要满足以下条件

1、配置数据源 DataSource
2、配置事务管理器 PlatformTransactionManager
3、配置类上标识 @EnableTransactionManagement

@Configuration
@PropertySource(value = {"classpath:jdbc.properties"},encoding = "UTF-8")
public class TransactionalConfig {

    @Value("${jdbc.url}")
    private String url;
    @Value("${jdbc.username}")
    private String username;
    @Value("${jdbc.password}")
    private String password;
    @Value("${jdbc.driver}")
    private String driver;

    /**
     * 配置数据源
     * @return
     */
    @Bean
    public DataSource dataSource(){
        DruidDataSource druidDataSource = new DruidDataSource();
        druidDataSource.setUrl(url);
        druidDataSource.setUsername(username);
        druidDataSource.setPassword(password);
        druidDataSource.setDriverClassName(driver);
        return druidDataSource;
    }

    /**
     * 配置事务管理器
     * @param dataSource
     * @return
     */
    @Bean
    public PlatformTransactionManager transactionManager(DataSource dataSource){
        DataSourceTransactionManager manager = new DataSourceTransactionManager();
        manager.setDataSource(dataSource);
        return manager;
    }


    /**
     * 配置jdbcTemplate
     * @param dataSource
     * @return
     */
    @Bean
    public JdbcTemplate jdbcTemplate(DataSource dataSource){
        JdbcTemplate jdbcTemplate = new JdbcTemplate();
        jdbcTemplate.setDataSource(dataSource);
        return jdbcTemplate;
    }

}
/**
 * 核心配置类
 */
@Configuration
@ComponentScan({"com.xiaoxu"})
@EnableAspectJAutoProxy(exposeProxy = true)   // 开启Spring对注解AOP的支持
@EnableTransactionManagement  // 开启Spring对注解事务支持
public class ApplicationContextConfiguration {

}

@Transactional剖析

1、 配置类上的注解@EnableTransactionManagement ,通过@Import 引入TransactionManagementConfigurationSelector 向容器中导入组件,一个是AutoProxyRegistrar和 ProxyTransactionManagementConfiguration

在这里插入图片描述

2、AutoProxyRegistrar 本质上是ImportBeanDefinitonRegistar,BeanDefinitionRegistar的主要作用在于加载默认定义的BeanDefintion。

他的调用时机是 容器refresh中的 invokeBeanFactoryPostProcessor中执行,这个方法主要是通过ConfigurationClassPostProcessor 处理核心配置类,解析配置类上的注解,例如@ComponentScan,@Import实现组件扫描并注册到IOC容器中。

在解析@Import完后找到了AutoProxyRegistrar,实例化 AutoProxyRegistrar(注意:并非所有组件都会放入一级缓存,只有需要才放入),调用 registerBeanDefinitions,向容器中注入一个组件AspectJAutoProxyCreator,该组件主要实现对对象进行代理

在这里插入图片描述

如果有必要注册AutoProxyCreator
在这里插入图片描述

注册AspectjAutoProxyCreator,该组件主要实现对对象进行代理
在这里插入图片描述

而且 这个组件不就是 @EnbaleAspectJAutoProxy注解,向容器中注册的组件嘛。

也就是说,AutoProxyRegister和AspectJAutoProxyRegistrar 本质一样,都是向容器中注入组件AspectjAutoProxyCreator,实现对目标对象生成代理

在这里插入图片描述
在这里插入图片描述

3、ProxyTransactionManagementConfiguration 事务管理配置类

ProxyTransactionManagementConfiguration是一个配置类,注入了三个组件

1、transactionAdvisor 事务增强器,其中注入了事务属性解析器和事务拦截器
2、transactionAttributeSource事务属性解析器
3、transactionInterceptor 事务拦截器

@Configuration
public class ProxyTransactionManagementConfiguration extends AbstractTransactionManagementConfiguration {

    @Bean(name = TransactionManagementConfigUtils.TRANSACTION_ADVISOR_BEAN_NAME)
    @Role(BeanDefinition.ROLE_INFRASTRUCTURE)
    // 注入事务增强器
    public BeanFactoryTransactionAttributeSourceAdvisor transactionAdvisor() {
        // 事务增强器
        BeanFactoryTransactionAttributeSourceAdvisor advisor = new BeanFactoryTransactionAttributeSourceAdvisor();
        // 向事务增强中注入属性解析器TransactionAttributeSource
        advisor.setTransactionAttributeSource(transactionAttributeSource());
        // 向事务增强器中设置事务拦截器TransactionInterceptor
        advisor.setAdvice(transactionInterceptor());
        if (this.enableTx != null) {
            advisor.setOrder(this.enableTx.<Integer>getNumber("order"));
        }
        return advisor;
    }

    @Bean
    @Role(BeanDefinition.ROLE_INFRASTRUCTURE)
    // 注入事务属性解析器transactionAttributeSource
    public TransactionAttributeSource transactionAttributeSource() {
        return new AnnotationTransactionAttributeSource();
    }

    @Bean
    @Role(BeanDefinition.ROLE_INFRASTRUCTURE)
    // 注入事务拦截器transactionInterceptor
    public TransactionInterceptor transactionInterceptor() {
        TransactionInterceptor interceptor = new TransactionInterceptor();
        interceptor.setTransactionAttributeSource(transactionAttributeSource());
        if (this.txManager != null) {
            interceptor.setTransactionManager(this.txManager);
        }
        return interceptor;
    }

}

4、transactionAttributeSource 事务属性解析器,实现对@Transactional的解析

创建事务属性解析器

在这里插入图片描述

决定事务属性解析器,来解析@Transactional

在这里插入图片描述

通过指定的事务解析器,解析事务注解

在这里插入图片描述

5、TransactionInterceptor 事务拦截器,实现对@Transactional事务方法拦截调用,如果需要调用,则调用,不需要则调用,如果没有事务,那么创建事务,并且从数据库连接池中获取连接,通过ThreadLocal放入当前线程中,并设置AutoCommit为false,然后执行目标方法,如果出现异常,进行回滚,最后提交事务

在这里插入图片描述

@Nullable
    protected Object invokeWithinTransaction(Method method, @Nullable Class<?> targetClass,
            final InvocationCallback invocation) throws Throwable {

        
        // 获取事务属性解析器
        TransactionAttributeSource tas = getTransactionAttributeSource();
        final TransactionAttribute txAttr = (tas != null ? tas.getTransactionAttribute(method, targetClass) : null);
        // 获取事务管理器
        final PlatformTransactionManager tm = determineTransactionManager(txAttr);
        final String joinpointIdentification = methodIdentification(method, targetClass, txAttr);

        if (txAttr == null || !(tm instanceof CallbackPreferringPlatformTransactionManager)) {
            // 如果没有事务就创建事务,创建的事务,会从数据库连接池中获取连接,通过ThreadLoacl放入当前线程中,并设置connect.setAutoCommit= false
            TransactionInfo txInfo = createTransactionIfNecessary(tm, txAttr, joinpointIdentification);
            Object retVal = null;
            try {
                // 调用目标方法
                retVal = invocation.proceedWithInvocation();
            }
            catch (Throwable ex) {
                // 如果目标方法抛异常,那么进行回滚
                completeTransactionAfterThrowing(txInfo, ex);
                throw ex;
            }
            finally {
                cleanupTransactionInfo(txInfo);
            }
            // 如果目标方法正常运行,提交事务
            commitTransactionAfterReturning(txInfo);
            return retVal;
        }
    }

总结

1、容器refresh时,调用invokeBeanFactoryPostProcessor,创建并调用ConfigurationClassPostProcessor解析核心配置类

2、通过解析核心配置类上的@EnableTransactionManagement,调用importSelect实例类中方法,将容器中注入两个重要组件 AutoProxyRegister (自动代理注册器) 和 TransactionManagementConfiguration 事务配置类

3、AutoProxyRegsiter 向容器中注入 ApsectjAutoProxyCreator ,切面自动代理创建器实现 对目标类代理
TransactionManagementConfiguration 事务管理配置类,向容器中注入三个组件

  • 事务属性解析器 TransactionAttributeSource,实现对@Transactional 注解解析
  • 事务拦截器 TransactionInterceptor 实现事务方法拦截
  • 事务增强器,分别注入了属性解析器和拦截器

4、实例化所有BeanPostProcessor包括(AspectAutoProxyCreator)

5、对BeanDefinitionMap中剩余的所有单例Bean,进行实例化 --》 属性赋值,依赖注入 --》 XXXAware --》BeanPostProcessor before --》 bean init
--》AspectAutoProxyCreator 中对需要代理的Bean 进行代理(通过获取当前Bean的所匹配的拦截器/advisor来判断是否需要代理)

6、创建完代理对象后,将原对象,增强方法/拦截器 设置到代理对象中,将代理对象放入一级缓存

7、代理对象调用目标方法,实际上走到了对应的拦截器,拦截器判断当前方法是否是@Transactional的方法,如果是,那么创建事务,从数据库连接池中获取连接,通过ThreadLocal将conn设置到当前线程中,开启事务,设置autoCommit为false

8、调用目标方法,目标方法执行过程中,获取的connetion,也是从当前线程中获取的

9、遇见异常进行回滚

10、事务提交

相关文章
|
24天前
|
监控 Java 应用服务中间件
高级java面试---spring.factories文件的解析源码API机制
【11月更文挑战第20天】Spring Boot是一个用于快速构建基于Spring框架的应用程序的开源框架。它通过自动配置、起步依赖和内嵌服务器等特性,极大地简化了Spring应用的开发和部署过程。本文将深入探讨Spring Boot的背景历史、业务场景、功能点以及底层原理,并通过Java代码手写模拟Spring Boot的启动过程,特别是spring.factories文件的解析源码API机制。
64 2
|
9天前
|
缓存 安全 Java
Spring高手之路26——全方位掌握事务监听器
本文深入探讨了Spring事务监听器的设计与实现,包括通过TransactionSynchronization接口和@TransactionalEventListener注解实现事务监听器的方法,并通过实例详细展示了如何在事务生命周期的不同阶段执行自定义逻辑,提供了实际应用场景中的最佳实践。
33 2
Spring高手之路26——全方位掌握事务监听器
|
8天前
|
存储 缓存 Java
Spring面试必问:手写Spring IoC 循环依赖底层源码剖析
在Spring框架中,IoC(Inversion of Control,控制反转)是一个核心概念,它允许容器管理对象的生命周期和依赖关系。然而,在实际应用中,我们可能会遇到对象间的循环依赖问题。本文将深入探讨Spring如何解决IoC中的循环依赖问题,并通过手写源码的方式,让你对其底层原理有一个全新的认识。
24 2
|
11天前
|
Java 关系型数据库 数据库
京东面试:聊聊Spring事务?Spring事务的10种失效场景?加入型传播和嵌套型传播有什么区别?
45岁老架构师尼恩分享了Spring事务的核心知识点,包括事务的两种管理方式(编程式和声明式)、@Transactional注解的五大属性(transactionManager、propagation、isolation、timeout、readOnly、rollbackFor)、事务的七种传播行为、事务隔离级别及其与数据库隔离级别的关系,以及Spring事务的10种失效场景。尼恩还强调了面试中如何给出高质量答案,推荐阅读《尼恩Java面试宝典PDF》以提升面试表现。更多技术资料可在公众号【技术自由圈】获取。
|
1月前
|
Java 开发者 Spring
Spring高手之路24——事务类型及传播行为实战指南
本篇文章深入探讨了Spring中的事务管理,特别是事务传播行为(如REQUIRES_NEW和NESTED)的应用与区别。通过详实的示例和优化的时序图,全面解析如何在实际项目中使用这些高级事务控制技巧,以提升开发者的Spring事务管理能力。
46 1
Spring高手之路24——事务类型及传播行为实战指南
|
15天前
|
JavaScript Java 关系型数据库
Spring事务失效的8种场景
本文总结了使用 @Transactional 注解时事务可能失效的几种情况,包括数据库引擎不支持事务、类未被 Spring 管理、方法非 public、自身调用、未配置事务管理器、设置为不支持事务、异常未抛出及异常类型不匹配等。针对这些情况,文章提供了相应的解决建议,帮助开发者排查和解决事务不生效的问题。
|
1月前
|
前端开发 Java 开发者
Spring生态学习路径与源码深度探讨
【11月更文挑战第13天】Spring框架作为Java企业级开发中的核心框架,其丰富的生态系统和强大的功能吸引了无数开发者的关注。学习Spring生态不仅仅是掌握Spring Framework本身,更需要深入理解其周边组件和工具,以及源码的底层实现逻辑。本文将从Spring生态的学习路径入手,详细探讨如何系统地学习Spring,并深入解析各个重点的底层实现逻辑。
54 9
|
26天前
|
XML Java 数据库连接
Spring中的事务是如何实现的
Spring中的事务管理机制通过一系列强大的功能和灵活的配置选项,为开发者提供了高效且可靠的事务处理手段。无论是通过注解还是AOP配置,Spring都能轻松实现复杂的事务管理需求。掌握这些工具和最佳实践,能
39 3
|
7月前
|
Java 关系型数据库 数据库连接
Spring源码解析--深入Spring事务原理
本文将带领大家领略Spring事务的风采,Spring事务是我们在日常开发中经常会遇到的,也是各种大小面试中的高频题,希望通过本文,能让大家对Spring事务有个深入的了解,无论开发还是面试,都不会让Spring事务成为拦路虎。
103 1
|
2月前
|
Java Spring
Spring底层架构源码解析(三)
Spring底层架构源码解析(三)
135 5