SpringBoot中事务执行原理分析补充篇

简介: SpringBoot中事务执行原理分析补充篇

关联博文:

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

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

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

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

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

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

SpringBoot中事务执行原理分析补充篇

你认真研究过Spring中的@EnableTransactionManagement注解吗?



本文是对SpringBoot中事务执行原理分析(一)的补充说明,我们详细分析一下如何判断Advisor与我们的service是否匹配。

【1】几个核心类

在前文中我们提到了BeanFactoryTransactionAttributeSourceAdvisor,其包含了Advice用于对我们的service进行增强实现事务效果。

public class BeanFactoryTransactionAttributeSourceAdvisor extends AbstractBeanFactoryPointcutAdvisor {
  @Nullable
  private TransactionAttributeSource transactionAttributeSource;
  private final TransactionAttributeSourcePointcut pointcut = new TransactionAttributeSourcePointcut() {
    @Override
    @Nullable
    protected TransactionAttributeSource getTransactionAttributeSource() {
      return transactionAttributeSource;
    }
  };
  //...
} 
//ProxyTransactionManagementConfiguration中定义了advicetransactionInterceptor
@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;
}



TransactionAttributeSourcePointcut 就是我们AOP概念中的pointcut,用于判断类/方法是否匹配。如下所示其还设置了ClassFilter为TransactionAttributeSourceClassFilter用于类级别的判断。

abstract class TransactionAttributeSourcePointcut extends StaticMethodMatcherPointcut implements Serializable {
  protected TransactionAttributeSourcePointcut() {
    setClassFilter(new TransactionAttributeSourceClassFilter());
  }
//...
} 


TransactionAttributeSource其是一个策略接口被TransactionInterceptor使用来检测元数据信息。在本文这里其实际是AnnotationTransactionAttributeSource,这个在ProxyTransactionManagementConfiguration这个配置类中有定义。

@Bean
@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
public TransactionAttributeSource transactionAttributeSource() {
//空参构造,publicMethodsOnly默认为true
  return new AnnotationTransactionAttributeSource();
}


这里要特别注意publicMethodsOnly 属性与annotationParsers 属性。前者标明是否只允许public方法,后者则是注解解析器。

public AnnotationTransactionAttributeSource(boolean publicMethodsOnly) {
// 默认为true,表示只允许public方法
  this.publicMethodsOnly = publicMethodsOnly;
  if (jta12Present || ejb3Present) {
    this.annotationParsers = new LinkedHashSet<>(4);
    this.annotationParsers.add(new SpringTransactionAnnotationParser());
    if (jta12Present) {
      this.annotationParsers.add(new JtaTransactionAnnotationParser());
    }
    if (ejb3Present) {
      this.annotationParsers.add(new Ejb3TransactionAnnotationParser());
    }
  }
  else {
  //指定注解解析器
    this.annotationParsers = Collections.singleton(new SpringTransactionAnnotationParser());
  }
}


SpringTransactionAnnotationParser主要作用就是用来解析事务注解信息(@Transactional)。

【2】Advisor是如何匹配我们的service呢?

在AopUtils的findAdvisorsThatCanApply会对找到的Advisor进行逐一判断,鉴定其是否适用于我们的service。

如下所示在AopUtils的canApply方法中首先使用ClassFilter进行判断,然后获取到MethodMatcher 对class和method进行遍历循环判断。

public static boolean canApply(Pointcut pc, Class<?> targetClass, boolean hasIntroductions) {
  Assert.notNull(pc, "Pointcut must not be null");
  // 首先使用classFilter进行判断
  if (!pc.getClassFilter().matches(targetClass)) {
    return false;
  }
//获取到MethodMatcher 
  MethodMatcher methodMatcher = pc.getMethodMatcher();
  if (methodMatcher == MethodMatcher.TRUE) {
    // No need to iterate the methods if we're matching any method anyway...
    return true;
  }
//判断是否为引入方法匹配器
  IntroductionAwareMethodMatcher introductionAwareMethodMatcher = null;
  if (methodMatcher instanceof IntroductionAwareMethodMatcher) {
    introductionAwareMethodMatcher = (IntroductionAwareMethodMatcher) methodMatcher;
  }
//获取到目标类、超类
  Set<Class<?>> classes = new LinkedHashSet<>();
  if (!Proxy.isProxyClass(targetClass)) {
    classes.add(ClassUtils.getUserClass(targetClass));
  }
  classes.addAll(ClassUtils.getAllInterfacesForClassAsSet(targetClass));
//对目标类与超类的所有方法进行遍历、判断
  for (Class<?> clazz : classes) {
    Method[] methods = ReflectionUtils.getAllDeclaredMethods(clazz);
    for (Method method : methods) {
      if (introductionAwareMethodMatcher != null ?
          introductionAwareMethodMatcher.matches(method, targetClass, hasIntroductions) :
          methodMatcher.matches(method, targetClass)) {
        return true;
      }
    }
  }
  return false;
}


① 类级别的判断

也就是下面这句代码, 前面我们提到过TransactionAttributeSourcePointcut中的classFilter是TransactionAttributeSourceClassFilter

pc.getClassFilter().matches(targetClass)


其是TransactionAttributeSourcePointcut的成员内部类(非静态内部类),我们看下其matches方法:

@Override
public boolean matches(Class<?> clazz) {
  if (TransactionalProxy.class.isAssignableFrom(clazz) ||
      PlatformTransactionManager.class.isAssignableFrom(clazz) ||
      PersistenceExceptionTranslator.class.isAssignableFrom(clazz)) {
    return false;
  }
  TransactionAttributeSource tas = getTransactionAttributeSource();
  return (tas == null || tas.isCandidateClass(clazz));
}


也就是说如果是TransactionalProxy、PlatformTransactionManager或者PersistenceExceptionTranslator,直接返回false。否则判断TransactionAttributeSource 是否为null或者TransactionAttributeSource的isCandidateClass方法是否为true。


如下所示,其将会遍历持有的TransactionAnnotationParser ,触发其isCandidateClass方法。

//AnnotationTransactionAttributeSource#isCandidateClass
@Override
public boolean isCandidateClass(Class<?> targetClass) {
  for (TransactionAnnotationParser parser : this.annotationParsers) {
    if (parser.isCandidateClass(targetClass)) {
      return true;
    }
  }
  return false;
}


本文我们只有一个SpringTransactionAnnotationParser,我们继续看SpringTransactionAnnotationParser解析器的isCandidateClass方法。

@Override
public boolean isCandidateClass(Class<?> targetClass) {
  return AnnotationUtils.isCandidateClass(targetClass, Transactional.class);
}


其只是触发了AnnotationUtils的isCandidateClass方法,如下所示可以说基本对我们的service来说都返回true。

public static boolean isCandidateClass(Class<?> clazz, String annotationName) {
//如果注解名称以java.开头,直接返回true
  if (annotationName.startsWith("java.")) {
    return true;
  }
  //如果clazz.getName以java.开头或者是Ordered类型
  if (AnnotationsScanner.hasPlainJavaAnnotationsOnly(clazz)) {
    return false;
  }
  //直接返回true
  return true;
}

② 方法级别的判断

OK,我们往下再看方法级别如何判断。这里触发的是TransactionAttributeSourcePointcut的matches方法。其获取到TransactionAttributeSource ,如果tas为null或者使用tas获取到的事务属性信息不为null,则返回true。

@Override
public boolean matches(Method method, Class<?> targetClass) {
  TransactionAttributeSource tas = getTransactionAttributeSource();
  return (tas == null || tas.getTransactionAttribute(method, targetClass) != null);
}

如下图所示,AbstractFallbackTransactionAttributeSource的computeTransactionAttribute

方法中首先会根据publicMethodsOnly属性和方法的修饰符进行判断,如果非public则直接返回null(默认情况下publicMethodsOnly=true)。

然后将会从当前类进行级联查找方法上的事务注解信息,也就是说你的service如果实现了接口,那么在接口的方法上添加@Transactional(rollbackFor = Exception.class)也是OK的。

如何获取方法上的注解信息呢,这里就用到了SpringTransactionAnnotationParser,其将会级联检索方法上的事务注解。获取到的事务注解信息如下所示:

8eb1b64b120543abbfa76f51dfee5c7f.png


确定了Advisor与我们的service匹配后,就可以为我们的service创建代理进行实现事务增强了。

目录
相关文章
|
2天前
|
Java 应用服务中间件 Spring
解析Spring Boot自动装配的原理与机制
解析Spring Boot自动装配的原理与机制
13 4
|
16天前
|
缓存 Java 开发者
SpringBoot自动装配原理
SpringBoot自动装配原理
16 1
|
1月前
|
存储 缓存 Java
SpringBoot 整合多数据源的事务问题
多数据源实现、切面的优先级问题(Order注解)、事务的传播特性(Propagation类)
|
1月前
|
Java 开发者 Spring
springboot @RequiredArgsConstructor @Lazy解决循环依赖的原理
【5月更文挑战第16天】在Spring Boot中,@RequiredArgsConstructor 和 @Lazy 是两个有用的注解,它们分别用于简化构造函数的生成和控制Bean的加载时间。下面详细解析这两个注解的概念、优缺点以及在实际应用中的示例。
67 1
|
1月前
|
XML Java 开发者
springboot 启动原理、启动过程、启动机制的介绍
【5月更文挑战第13天】Spring Boot 是一种基于 Java 的框架,用于创建独立的、生产级别的 Spring 应用程序。它的主要目标是简化 Spring 应用的初始搭建和开发过程,同时提供一系列大型项目常见的非功能性特征(如嵌入式服务器、安全性、度量、健康检查和外部化配置)。
38 3
|
21天前
|
JavaScript Java 测试技术
基于SpringBoot+Vue+uniapp的《数据库系统原理》课程平台的详细设计和实现(源码+lw+部署文档+讲解等)
基于SpringBoot+Vue+uniapp的《数据库系统原理》课程平台的详细设计和实现(源码+lw+部署文档+讲解等)
|
23天前
|
JavaScript Java 测试技术
基于SpringBoot+Vue+uniapp的自习室预订座位管理分析与实现的详细设计和实现(源码+lw+部署文档+讲解等)
基于SpringBoot+Vue+uniapp的自习室预订座位管理分析与实现的详细设计和实现(源码+lw+部署文档+讲解等)
|
1月前
|
JSON Java Maven
Javaweb之SpringBootWeb案例之 SpringBoot原理的详细解析
Javaweb之SpringBootWeb案例之 SpringBoot原理的详细解析
49 0
Javaweb之SpringBootWeb案例之 SpringBoot原理的详细解析
|
1月前
|
Java Spring 容器
SpringBoot自动装配原理之@Import注解解析
SpringBoot自动装配原理之@Import注解解析
60 0
|
1月前
|
Java 容器 Spring
Springboot自动配置原理
Springboot自动配置原理