SpringBoot中事务执行原理分析(一)

简介: SpringBoot中事务执行原理分析(一)

从本文开始我们开始分析事务执行原理,本文的环境是SpringBoot(+MybatisPlus),当然在SSM的环境下其本质也是一致的。


【1】两种环境下测试save

① 非事务环境下的save

如下所示,如果没有应用事务(比如事务注解或者xml配置或者编程式事务),那么通常在PreparedStatement执行后,数据就进入了数据库,即使下一行业务代码抛出了异常也不会导致回滚。

PreparedStatementHandler的update方法。

这里得到的PreparedStatement对象是个代理其真实对象中维护的connection的isAutoCommit=true,也就是自动提交。

s.execute();方法将会触发入库动作的执行,数据将会插入数据库。

插入完数据后依次返回,如下所示在SqlSessionInterceptor的invoke方法这里会执行sqlSession.commit(true);其最终会触发 transaction.commit();也就是提交事务。

② 有事务环境下的save

如下所示,我们在接口层给方法加上事务注解。

public interface SysAdviceService extends IService<SysAdvice> {
    @Transactional(rollbackFor = Exception.class)
    boolean testSave(SysAdvice sysAdvice);
}

这里得到的PreparedStatement对象是个代理其真实对象中维护的connection的isAutoCommit=false,也就是不自动提交

与上个环境不同的是当ps.execute();执行完,这里数据并没有插入。

在SqlSessionInterceptor的invoke方法中,这里也没有触发sqlSession.commit(true);

那么事务在什么时候提交的呢?数据在什么时候入库的呢?如下所示在TransactionAspectSupport的invokeWithinTransaction方法中commitTransactionAfterReturning(txInfo);将会执行事务提交将数据插入数据库。

670a4f7da6b4418bb8f0d53bca7e2de8.png

③ 事务环境下抛出异常

如下所示,我们在service方法中加入异常代码。

@Override
public boolean testSave(SysAdvice sysAdvice) {
    adviceMapper.insert(sysAdvice);
    System.out.println(1/0);
    return false;
}

如下所示,这里TransactionAspectSupport的invokeWithinTransaction方法将会抛出异常。那么将不会触发commitTransactionAfterReturning(txInfo);进行事务提交插入数据。

继续往下跟踪,TransactionAspectSupport(实际当前对象是其子类TransactionInterceptor)的completeTransactionAfterThrowing方法中我们能够看到这里触发了回滚。


从上面的实例中我们看到了TransactionAspectSupport的身影,在有事务环境下该类来触发提交事务或者回滚的动作。那么TransactionAspectSupport是什么,从哪里来?

【2】TransactionAspectSupport

TransactionAspectSupport是事务切面的基础类,事务切面比如TransactionInterceptor。实际上TransactionInterceptor确实为TransactionAspectSupport的子类。


这使得底层Spring事务基础设施可以轻松地用于实现任何切面系统的切面。子类负责按正确的顺序调用此类中的方法。这里 应用了策略设计模式。PlatformTransactionManager 或ReactiveTransactionManager 实现将执行实际的事务管理,而 TransactionAttributeSource(例如基于注解的事务)用于确定特定类或方法的事务定义。


我们继续看TransactionInterceptor。如下所示TransactionInterceptor继承自TransactionAspectSupport 实现了MethodInterceptor接口。

public class TransactionInterceptor extends TransactionAspectSupport implements MethodInterceptor, Serializable {
  //...
}

也就是说起在父类TransactionAspectSupport基础了,实现了MethodInterceptor接口,提供了invoke方法供其他地方调用。其实熟悉AOP的同学这里就能过联想到,实现了MethodInterceptor接口的大多被作为Advice使用。


如下所示当触发SysAdviceServiceImpl的testSave方法时,实际是触发了代理类然后交给了CglibAopProxy.DynamicAdvisedInterceptor的DynamicAdvisedInterceptor方法。

e0f2d5469dd645cc8e7cb9cdfcd5e2cb.png

如下所示最终会触发TransactionInterceptor的invoke方法。这里我们暂时跳过事务实现的详情,可以得出结论:SpringBoot下的事务执行原理是由代理实现的!

从前面我们也能够看到,在代理执行过程中,这里我们的advisor是BeanFactoryTransactionAttributeSourceAdvisor。


那么什么是BeanFactoryTransactionAttributeSourceAdvisor,什么时候实例化的,如何对本文这里的SysAdviceServiceImpl进行了代理包装?

【3】BeanFactoryTransactionAttributeSourceAdvisor

看到Advisor第一反应就该是增强器/顾问器,就要联想到AOP、切面、切入点、增强通知、代理。


BeanFactoryTransactionAttributeSourceAdvisor 由 TransactionAttributeSource 驱动,用于包含事务性方法的事务通知bean(比如你的方法上标注了@Transactional注解)。如下所示其继承自AbstractBeanFactoryPointcutAdvisor维护了transactionAttributeSource、pointcut 、advice等成员信息。

public class BeanFactoryTransactionAttributeSourceAdvisor extends AbstractBeanFactoryPointcutAdvisor {
  @Nullable
  private TransactionAttributeSource transactionAttributeSource;
  // 这个很有意思,是个final,且直接实例化赋值了
  private final TransactionAttributeSourcePointcut pointcut = new TransactionAttributeSourcePointcut() {
    @Override
    @Nullable
    protected TransactionAttributeSource getTransactionAttributeSource() {
      return transactionAttributeSource;
    }
  };
  //...
}

那么第一个问题,这个Advisor是在什么时候实例化的?

① BeanFactoryTransactionAttributeSourceAdvisor 的注册和实例化

如下所示,在配置类ProxyTransactionManagementConfiguration 中注册了BeanFactoryTransactionAttributeSourceAdvisor 、TransactionAttributeSource、以及TransactionInterceptor。并为transactionAdvisor设置advice属性,值为transactionInterceptor。

@Configuration(proxyBeanMethods = false)
public class ProxyTransactionManagementConfiguration extends AbstractTransactionManagementConfiguration {
  @Bean(name = TransactionManagementConfigUtils.TRANSACTION_ADVISOR_BEAN_NAME)
  @Role(BeanDefinition.ROLE_INFRASTRUCTURE)
  public BeanFactoryTransactionAttributeSourceAdvisor transactionAdvisor(
      TransactionAttributeSource transactionAttributeSource,
      TransactionInterceptor transactionInterceptor) {
    BeanFactoryTransactionAttributeSourceAdvisor advisor = new BeanFactoryTransactionAttributeSourceAdvisor();
    advisor.setTransactionAttributeSource(transactionAttributeSource);
    advisor.setAdvice(transactionInterceptor);
    if (this.enableTx != null) {
      advisor.setOrder(this.enableTx.<Integer>getNumber("order"));
    }
    return advisor;
  }
  @Bean
  @Role(BeanDefinition.ROLE_INFRASTRUCTURE)
  public TransactionAttributeSource transactionAttributeSource() {
    return new AnnotationTransactionAttributeSource();
  }
  @Bean
  @Role(BeanDefinition.ROLE_INFRASTRUCTURE)
  public TransactionInterceptor transactionInterceptor(
      TransactionAttributeSource transactionAttributeSource) {
    TransactionInterceptor interceptor = new TransactionInterceptor();
    interceptor.setTransactionAttributeSource(transactionAttributeSource);
    if (this.txManager != null) {
      interceptor.setTransactionManager(this.txManager);
    }
    return interceptor;
  }
}

bd75382414de471a97b7c53b85bd2f28.png

这个类总结来讲就是注册启用基于代理的注解驱动的事务管理所需的Spring基础结构bean。

那么第二个问题,ProxyTransactionManagementConfiguration 是如何注册实例化的?

② ProxyTransactionManagementConfiguration

如下所示,在TransactionManagementConfigurationSelectorselectImports方法中,“注册了”AutoProxyRegistrarProxyTransactionManagementConfiguration

public class TransactionManagementConfigurationSelector extends AdviceModeImportSelector<EnableTransactionManagement> {
// 注意这个selectImports方法哦 
  @Override
  protected String[] selectImports(AdviceMode adviceMode) {
    switch (adviceMode) {
      case PROXY:
        return new String[] {AutoProxyRegistrar.class.getName(),
            ProxyTransactionManagementConfiguration.class.getName()};
      case ASPECTJ:
        return new String[] {determineTransactionAspectClass()};
      default:
        return null;
    }
  }
  private String determineTransactionAspectClass() {
    return (ClassUtils.isPresent("javax.transaction.Transactional", getClass().getClassLoader()) ?
        TransactionManagementConfigUtils.JTA_TRANSACTION_ASPECT_CONFIGURATION_CLASS_NAME :
        TransactionManagementConfigUtils.TRANSACTION_ASPECT_CONFIGURATION_CLASS_NAME);
  }
}

TransactionManagementConfigurationSelector是一个ImportSelector,在SpringBoot自动配置原理解析一文中我们分析过,在应用上下文刷新过程中,会使用ConfigurationClassPostProcessor扫描并注册我们的配置类(和相关类)。


如下所示,我们自定义的MybatisPlusConfig 标注了@EnableTransactionManagement注解。

@EnableTransactionManagement
@MapperScan({"com.recommend.mapper"})
@Configuration
public class MybatisPlusConfig {
  //...
}

而@EnableTransactionManagement注解注解导入了TransactionManagementConfigurationSelector,其selectImports又引入了AutoProxyRegistrar和ProxyTransactionManagementConfiguration。

64027e7ca2db4936940d3a5d25a2a51a.png

而在处理ProxyTransactionManagementConfiguration的过程中又会注入注册了BeanFactoryTransactionAttributeSourceAdvisor 、TransactionAttributeSource、以及TransactionInterceptor。并为transactionAdvisor设置advice属性,值为transactionInterceptor。

这些Bean在ConfigurationClassPostProcessor中都会被注册了BeanDefinition,并在Spring中refresh分析之finishBeanFactoryInitialization方法详解被实例化。

③ 如何为我们的service进行代理包装?

其实换个说法就是如何为bean创建代理,这个具体过程我们在Spring AOP中如何为Bean创建代理?有过详细分析。我们这里简单看下如何为service包装代理。


如下所示,这里同样来到了AbstractAutoProxyCreator尝试为SysAdviceServiceImpl对象创建代理。

image.png

在wrapIfNecessary方法中会尝试获取当前bean的"拦截器"(没错,从业务概念上讲我们可以称之为拦截器),如果specificInterceptors不为空,则为当前bean实例创建代理。


如下所示,这里我们获取到了BeanFactoryTransactionAttributeSourceAdvisor,那么将会为我们的bean创建代理。

这里需要说明一点,首先从容器中获取到Advisor后,还会多进一步筛选。判断当前Advisor与目标类是否匹配。以BeanFactoryTransactionAttributeSourceAdvisor为例,这里会判断方法是否为public、方法上(当前类或者接口层)是否有事务注解信息。


关于Advisor与service匹配更多信息可以参考博文:SpringBoot中事务执行原理分析补充篇544e73da8a0846ccb6d0302d8674ee0a.png

在DefaultAopProxyFactory的createAopProxy方法中会进行判断决定是JdkDynamicAopProxy还是ObjenesisCglibAopProxy。本文这里TargetClass是实际的class com.recommend.service.impl.SysAdviceServiceImpl,将会触发cglib代理。1fb4df983e7b40869f6278f698c5a556.png

这里我们得到的代理对象如下所示:

④ 为什么是CGLIB代理?

在SSM环境下,如果我们定义了@EnableAspectJAutoProxy(proxyTargetClass = false),那么对于我们实现了接口的service来讲是触发JDK动态代理的。但是在SpringBoot 2.2.4.RELEASE版本下,由于AOP的自动配置,其强制将proxyTargetClass 设置为了true。


当我们尝试进行代理时,我们拿到的AnnotationAwareAspectJAutoProxyCreator对象中,proxyTargetClass 属性是true。也就是说假设在主启动类配置了@EnableAspectJAutoProxy(proxyTargetClass = false),SpringBoot会忽略你的false配置。


关于这个原理,可以参考AopAutoConfiguration,这个配置类中的CglibAutoProxyConfiguration默认采用proxyTargetClass = true效果。

ffaaa6a6f2d043e59c601734a98de925.png


目录
相关文章
|
20天前
|
Java Spring 容器
springboot @RequiredArgsConstructor @Lazy解决循环依赖的原理
【10月更文挑战第15天】在Spring Boot应用中,循环依赖是一个常见问题,当两个或多个Bean相互依赖时,会导致Spring容器陷入死循环。本文通过比较@RequiredArgsConstructor和@Lazy注解,探讨它们解决循环依赖的原理和优缺点。@RequiredArgsConstructor通过构造函数注入依赖,使代码更简洁;@Lazy则通过延迟Bean的初始化,打破创建顺序依赖。两者各有优势,需根据具体场景选择合适的方法。
38 4
|
4月前
|
Java 应用服务中间件 开发者
Java面试题:解释Spring Boot的优势及其自动配置原理
Java面试题:解释Spring Boot的优势及其自动配置原理
117 0
|
2月前
|
Java 应用服务中间件 API
Vertx高并发理论原理以及对比SpringBoot
Vertx 是一个基于 Netty 的响应式工具包,不同于传统框架如 Spring,它的侵入性较小,甚至可在 Spring Boot 中使用。响应式编程(Reactive Programming)基于事件模式,通过事件流触发任务执行,其核心在于事件流 Stream。相比多线程异步,响应式编程能以更少线程完成更多任务,减少内存消耗与上下文切换开销,提高 CPU 利用率。Vertx 适用于高并发系统,如 IM 系统、高性能中间件及需要较少服务器支持大规模 WEB 应用的场景。随着 JDK 21 引入协程,未来 Tomcat 也将优化支持更高并发,降低响应式框架的必要性。
Vertx高并发理论原理以及对比SpringBoot
|
26天前
|
Java BI API
spring boot 整合 itextpdf 导出 PDF,写入大文本,写入HTML代码,分析当下导出PDF的几个工具
这篇文章介绍了如何在Spring Boot项目中整合iTextPDF库来导出PDF文件,包括写入大文本和HTML代码,并分析了几种常用的Java PDF导出工具。
286 0
spring boot 整合 itextpdf 导出 PDF,写入大文本,写入HTML代码,分析当下导出PDF的几个工具
|
1月前
|
XML Java 应用服务中间件
【Spring】运行Spring Boot项目,请求响应流程分析以及404和500报错
【Spring】运行Spring Boot项目,请求响应流程分析以及404和500报错
137 2
|
2月前
|
Java 开发者 数据格式
【Java笔记+踩坑】SpringBoot基础4——原理篇
bean的8种加载方式,自动配置原理、自定义starter开发、SpringBoot程序启动流程解析
【Java笔记+踩坑】SpringBoot基础4——原理篇
|
3月前
|
安全 Java API
SpringBoot + 事务钩子函数,打造高效支付系统!
【8月更文挑战第9天】在当今快速发展的数字支付时代,构建一个稳定、高效且安全的支付系统是企业数字化转型的关键一步。SpringBoot以其简洁的配置、快速的开发速度以及强大的生态支持,成为了构建支付系统的热门选择。而结合事务钩子函数(Transaction Hooks),则能进一步确保支付流程的完整性、一致性和可维护性。以下,我将分享如何利用SpringBoot与事务钩子函数来打造高效支付系统的技术实践。
97 15
SpringBoot + 事务钩子函数,打造高效支付系统!
|
4月前
|
Java Spring 容器
Spring Boot 启动源码解析结合Spring Bean生命周期分析
Spring Boot 启动源码解析结合Spring Bean生命周期分析
101 11
|
4月前
|
SQL Java 数据库连接
springboot~mybatis-pagehelper原理与使用
【7月更文挑战第15天】MyBatis-PageHelper是用于MyBatis的分页插件,基于MyBatis的拦截器机制实现。它通过在SQL执行前动态修改SQL语句添加LIMIT子句以支持分页。使用时需在`pom.xml`添加依赖并配置方言等参数。示例代码: PageHelper.startPage(2, 10); List&lt;User&gt; users = userMapper.getAllUsers(); PageInfo&lt;User&gt; pageInfo = new PageInfo&lt;&gt;(users); 这使得分页查询变得简单且能获取总记录数等信息。
|
4月前
|
JavaScript Java 测试技术
基于SpringBoot+Vue的高质量升学分析系统的详细设计和实现(源码+lw+部署文档+讲解等)
基于SpringBoot+Vue的高质量升学分析系统的详细设计和实现(源码+lw+部署文档+讲解等)
32 0