spring事务原理和事务同步器使用简介-搜云库技术团队

如何启用事务支持

引入依赖

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

加入依赖之后，自动化配置类将自动配置启用事务的类对象

@Configuration
// 引入 spring-boot-starter-jdbc 之后，类路径才存在 PlatformTransactionManager，配置生效
@ConditionalOnClass(PlatformTransactionManager.class)
@AutoConfigureAfter({ JtaAutoConfiguration.class, HibernateJpaAutoConfiguration.class,
        DataSourceTransactionManagerAutoConfiguration.class, Neo4jDataAutoConfiguration.class })
@EnableConfigurationProperties(TransactionProperties.class)
public class TransactionAutoConfiguration {

    @Bean
    @ConditionalOnMissingBean
    public TransactionManagerCustomizers platformTransactionManagerCustomizers(
            ObjectProvider<PlatformTransactionManagerCustomizer<?>> customizers) {
        return new TransactionManagerCustomizers(customizers.orderedStream().collect(Collectors.toList()));
    }

    @Configuration
    @ConditionalOnSingleCandidate(PlatformTransactionManager.class)
    public static class TransactionTemplateConfiguration {

        private final PlatformTransactionManager transactionManager;

        public TransactionTemplateConfiguration(PlatformTransactionManager transactionManager) {
            this.transactionManager = transactionManager;
        }

        @Bean
        @ConditionalOnMissingBean(TransactionOperations.class)
        public TransactionTemplate transactionTemplate() {
            return new TransactionTemplate(this.transactionManager);
        }

    }

    @Configuration
    @ConditionalOnBean(PlatformTransactionManager.class)
    @ConditionalOnMissingBean(AbstractTransactionManagementConfiguration.class)
    public static class EnableTransactionManagementConfiguration {

        // 启用事务
        @Configuration
        @EnableTransactionManagement(proxyTargetClass = false)
        @ConditionalOnProperty(prefix = "spring.aop", name = "proxy-target-class", havingValue = "false",
                matchIfMissing = false)
        public static class JdkDynamicAutoProxyConfiguration {

        }

        // 启用事务。没有配置 spring.aop.proxy-target-class 时，默认使用的 proxyTargetClass = true。使用CGLIB来生成代理
        @Configuration
        @EnableTransactionManagement(proxyTargetClass = true)
        @ConditionalOnProperty(prefix = "spring.aop", name = "proxy-target-class", havingValue = "true",
                matchIfMissing = true)
        public static class CglibAutoProxyConfiguration {

        }

    }

}

配置加载

当引入依赖后，自动化配置类 TransactionAutoConfiguration 生效。其实现又将引入以下配置

AutoProxyRegistrar：ImportBeanDefinitionRegistrar 实现类，容器启动时回调其registerBeanDefinitions方法，以便引入更细化的配置
- InfrastructureAdvisorAutoProxyCreator 由于优先级比 AnnotationAwareAspectJAutoProxyCreator 低，因此并未生效
ProxyTransactionManagementConfiguration @Configuration标记的配置类
- BeanFactoryTransactionAttributeSourceAdvisor
  - 内部的pointvut属性为：TransactionAttributeSourcePointcut
- AnnotationTransactionAttributeSource 读取@Transactional属性值，暴露给 spring 事务框架
- TransactionInterceptor
- TransactionalEventListenerFactory

如何构造出带事务的代理类

BeanFactoryTransactionAttributeSourceAdvisor、AnnotationTransactionAttributeSource、TransactionInterceptor的类结构图。

首先要清楚几个概念：

ClassFilter、MethodMatcher 共同实现了「判断是否拦截方法」的能力
Pointcut，组合ClassFilter、MethodMatcher，用于识别是否对一个类方法进行增强
Advice，承载增强能力的标签类
Advisor，承载AOP中的advice、pointcut能力的类

构造流程时序

通过 AnnotationAwareAspectJAutoProxyCreator 进行代理对象的生成，其原理就是在进行IOC容器的初始化时，初始化bean都会回调 BeanPostProcessor.postProcessAfterInitialization 方法。也就是在这时进行代理对象的生成。

在生成过程中，会寻找 IOC 容器中的 Advisor，在启用事务控制之后，默认有 BeanFactoryTransactionAttributeSourceAdvisor ，将通过 ProxyFactory 创建代理对象：CglibAopProxy 或者 JdkDynamicAopProxy，代理对象的实现根据 spring.aop.proxy-target-class 属性和被代理类是否为接口来决定。默认情况下，使用CglibAopProxy。

切入事务管理的执行流程

事务回滚

事务提交

与事务管理流程相关的类：

TransactionAttribute – DelegatingTransactionAttribute
PlatformTransactionManager – DataSourceTransactionManager
TransactionStatus
TransactionInfo
ConnectionHolder

在整个事务管理的流程中，主要通过 TransactionInterceptor 根据异常与否来切入提交、回滚的功能。由DataSourceTransactionManager封装提交、回滚两个操作的门面接口供TransactionInterceptor调用，在 DataSourceTransactionManager 内部，其内部封装了 TransactionStatus，而TransactionStatus 包含着的TransactionObject可以通过其 ConnectionHolder 来获取当前所用连接对象，进而执行提交或回滚；

除此之外，spring 还提供了 TransactionSynchronization 作为事务同步器，在「提交前、回滚前、提交后、回滚后、执行回滚（或提交）完成」这几个时机进行同步器的回调。

用法如下

@Transactional(rollbackFor = Exception.class)
@Override
public Author save(Author author) {
    jdbcTemplate.update("insert into author(name) values (?)", author.getName());
    // 注册事务同步器，在事务提交后进行回调
    TransactionSynchronizationManager.registerSynchronization(new TransactionSynchronizationAdapter() {
        @Override
        public void afterCommit() {
            System.out.println("after commit...");
        }
    });
    return author;
}

spring事务原理和事务同步器使用简介