0
点赞
收藏
分享

微信扫一扫

Spring声明式事务控制源码深度剖析

有点d伤 2022-01-05 阅读 75

声明式事务很⽅便,尤其纯注解模式,仅仅⼏个注解就能控制事务了

思考:这些注解都做了什么?好神奇!

@EnableTransactionManagement @Transactional

一. @EnableTransactionManagement

@Target(ElementType.TYPE)
@Retention(RetentionPolicy.RUNTIME)
@Documented
@Import(TransactionManagementConfigurationSelector.class)
public @interface EnableTransactionManagement {

@EnableTransactionManagement 注解使⽤ @Import 标签引⼊了

TransactionManagementConfifigurationSelector 类,这个类⼜向容器中导⼊了两个重要的组件

 二. 加载事务控制组件

AutoProxyRegistrar

AutoProxyRegistrar 类的 registerBeanDefifinitions ⽅法中⼜注册了⼀个组件

 进⼊ AopConfifigUtils.registerAutoProxyCreatorIfNecessary ⽅法

 

发现最终,注册了⼀个叫做 InfrastructureAdvisorAutoProxyCreator Bean ,⽽这个类是

AbstractAutoProxyCreator 的⼦类,实现了 SmartInstantiationAwareBeanPostProcessor 接⼝

public class InfrastructureAdvisorAutoProxyCreator extends
AbstractAdvisorAutoProxyCreator
public abstract class AbstractAdvisorAutoProxyCreator extends
AbstractAutoProxyCreator
public abstract class AbstractAutoProxyCreator extends
ProxyProcessorSupport
 implements SmartInstantiationAwareBeanPostProcessor, BeanFactoryAware

继承体系结构图如下

 

它实现了 SmartInstantiationAwareBeanPostProcessor ,说明这是⼀个后置处理器,⽽且跟

spring AOP 开启 @EnableAspectJAutoProxy 时注册的 AnnotationAwareAspectJProxyCreator

现的是同⼀个接⼝,所以说,声明式事务是 springAOP 思想的⼀种应⽤

ProxyTransactionManagementConfifiguration 组件

@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;
	}

ProxyTransactionManagementConfifiguration 是⼀个容器配置类,注册了⼀个组件

transactionAdvisor ,称为事务增强器,然后在这个事务增强器中⼜注⼊了两个属性:

transactionAttributeSource ,即属性解析器 transactionAttributeSource 和 事务拦截器

transactionInterceptor

属性解析器 AnnotationTransactionAttributeSource 部分源码如下

 

属性解析器有⼀个成员变量是 annotationParsers ,是⼀个集合,可以添加多种注解解析器

(TransactionAnnotationParser) ,我们关注 Spring 的注解解析器,部分源码如下

 

属性解析器的作⽤之⼀就是⽤来解析 @Transaction 注解

TransactionInterceptor 事务拦截器,部分源码如下

 上述组件如何关联起来的?

事务拦截器实现了 MethodInterceptor 接⼝,追溯⼀下上⾯提到的

InfrastructureAdvisorAutoProxyCreator 后置处理器,它会在代理对象执⾏⽬标⽅法的时候

获取其拦截器链,⽽拦截器链就是这个 TransactionInterceptor ,这就把这两个组件联系起

来;

 

构造⽅法传⼊ PlatformTransactionManager( 事务管理器 ) TransactionAttributeSource(

性解析器 ) ,但是追溯⼀下上⾯贴的 ProxyTransactionManagementConfifiguration 的源码,

在注册事务拦截器的时候并没有调⽤这个带参构造⽅法,⽽是调⽤的⽆参构造⽅法,然后再

调⽤ set ⽅法注⼊这两个属性,效果⼀样。

invokeWithinTransaction ⽅法,部分源码如下(关注 1 2 3 4 标注处)

 

 

举报

相关推荐

0 条评论