spring多个事务管理器踩坑及解决

软件发布|下载排行|最新软件

当前位置:首页IT学院IT技术

spring多个事务管理器踩坑及解决

小小少年_   2022-11-22 我要评论

多个事务管理器踩坑

在项目中使用了两个事务管理器,因为项目中设计到两个数据库的操作,所以就声明了两个事务管理器;

但是在使用@Transactional注解的时候,没有手动指定事务要使用哪个,就有可能会导致事务不生效

案例

1、在项目中,我用到了A和B两个数据库,所以,此时就需要声明两个事务管理器,我们假设命名为:ATransactionManager和BTransactionManager(这两个事务管理器,分别对应着A和B两个数据库就)

2、在使用的时候,如果当前方法中,都是对A数据库的表进行操作,那就需要在@Transactional注解的value属性上指定ATransactional

这里的aDataSource和bDataSource都是根据a和b两个数据库生成的,只需要在配置类中,加上这几行代码,spring在启动的时候,就会把这两个事务管理器放入到spring容器中

@Bean
public PlatformTransactionManager aTransactionManager() {
    return new DataSourceTransactionManager(aDataSource());
}

@Bean
public PlatformTransactionManager bTransactionManager() {
    return new DataSourceTransactionManager(bDataSource());
}

配置就完成了,这里,就和添加一个普通的bean对象是一样的,都会放到spring容器中

我遇到的问题是

我在一个方法上加了事务注解,但是没有指定value,实际上,这个接口中是要去操作a数据库的三张表,但是发现接口中事务回滚的时候,并没有把其他三张表的数据都回滚,debug看代码,也确实去执行了回滚的操作,最后发现是没有指定aTransactionManager的原因

源码解析

我们都知道,事务的源码,在

org.springframework.transaction.interceptor.TransactionInterceptor#invoke
    org.springframework.transaction.interceptor.TransactionAspectSupport#invokeWithinTransaction
    
final TransactionAttribute txAttr = (tas != null ? tas.getTransactionAttribute(method, targetClass) : null);
//根据事务属性获取获取事务管理器,这里一般是 DataSourceTransactionManager,我们也可以自己去指定事务管理器
final PlatformTransactionManager tm = determineTransactionManager(txAttr);    

在这个方法中,有两行代码,是需要关注的,上面一行,是根据当前的方法名,获取对应的事务注解信息,这里有一个前置的知识点,需要说明:在spring初始化的过程中,会对方法或者类上对的事务注解进行解析,解析之后,会存到内存中,其中

org.springframework.transaction.annotation.SpringTransactionAnnotationParser#parseTransactionAnnotation(org.springframework.core.annotation.AnnotationAttributes)

在这个方法中,会解析@Transactional注解,并将解析到的配置信息,存储到RuleBasedTransactionAttribute这个bean中,存储到这个bean的qualifier字段上,所以,事务拦截器在解析的时候,是根据这个qualifier字段的value,来获取事务管理器的,这是一个前提知识,需要知道

determineTransactionManager()

我们着重来看这个方法:

/**
 * 这个方法,是来获取事务管理器的,如果我们有自己指定,就可以在使用@Transactional注解的时候,通过value,指定我们要使用的事务管理器
 * Determine the specific transaction manager to use for the given transaction.
 */
@Nullable
protected PlatformTransactionManager determineTransactionManager(@Nullable TransactionAttribute txAttr) {
	// Do not attempt to lookup tx manager if no tx attributes are set
	if (txAttr == null || this.beanFactory == null) {
		return getTransactionManager();
	}

	// 1.由于在解析事务注解的时候,将value,放到了qualifier属性上,所以要这样获取,我们只需要知道,这里的qualifier就是事务注解中的value对应的值
	String qualifier = txAttr.getQualifier();
	// 2.如果在@Transaction的value指定事务管理器,会执行这里,其实就是从spring容器中获取指定的事务管理器
	if (StringUtils.hasText(qualifier)) {
		return determineQualifiedTransactionManager(this.beanFactory, qualifier);
	}
	// 3.
	else if (StringUtils.hasText(this.transactionManagerBeanName)) {
		return determineQualifiedTransactionManager(this.beanFactory, this.transactionManagerBeanName);
	}
	else {
		// 4.先判断是否有指定事务管理器,如果没有,就获取默认的
		PlatformTransactionManager defaultTransactionManager = getTransactionManager();
		if (defaultTransactionManager == null) {
			// 获取默认的事务管理器
			defaultTransactionManager = this.transactionManagerCache.get(DEFAULT_TRANSACTION_MANAGER_KEY);
			if (defaultTransactionManager == null) {
				//由于我们没有指定,会从spring容器中按照类型获取,所以我们只需要往spring容器中注入一个事务管理器即可,springboot应用会默认注入一个事务管理器
				defaultTransactionManager = this.beanFactory.getBean(PlatformTransactionManager.class);
				this.transactionManagerCache.putIfAbsent(
						DEFAULT_TRANSACTION_MANAGER_KEY, defaultTransactionManager);
			}
		}
		return defaultTransactionManager;
	}
}

这个方法,我认为,就是这篇博客所有的内容了,注释中的第一点和第二点我搞懂了,第二点如果点进去,就会发现,实际上,调用的就是beanFactory.getBean(name,type)这个方法,就是根据我们指定的事务管理器,从spring容器中获取我们想要使用的事务管理器

对于第三点,我还没有搞懂,只是看到是在org.springframework.transaction.interceptor.TransactionInterceptor#readObject中赋的值,所以先暂时跳过

对于第四点:其实简单来说,就是我们没有指定要使用的事务管理器,spring会帮助我们去当前spring容器中,根据类型(PlatformTransactionManager.class)获取一个默认的事务管理器,对于springboot应用来说,无需关心这一点,因为springboot帮助我们自动注入了一个事务管理器:DataSourceTransactionManager

所以,上面这个方法,就解释了,为什么,我在没有指定事务管理器的情况下,事务未生效

springboot自动注入的事务管理器

在spring自动注入的配置中,帮我们自动注入了这个一个类

org.springframework.boot.autoconfigure.jdbc.DataSourceTransactionManagerAutoConfiguration,\

@Configuration
@ConditionalOnClass({ JdbcTemplate.class, PlatformTransactionManager.class })
@AutoConfigureOrder(Ordered.LOWEST_PRECEDENCE)
@EnableConfigurationProperties(DataSourceProperties.class)
public class DataSourceTransactionManagerAutoConfiguration {

	@Configuration
	@ConditionalOnSingleCandidate(DataSource.class)
	static class DataSourceTransactionManagerConfiguration {

		private final DataSource dataSource;

		private final TransactionManagerCustomizers transactionManagerCustomizers;

		DataSourceTransactionManagerConfiguration(DataSource dataSource,
				ObjectProvider<TransactionManagerCustomizers> transactionManagerCustomizers) {
			this.dataSource = dataSource;
			this.transactionManagerCustomizers = transactionManagerCustomizers
					.getIfAvailable();
		}

		@Bean
		@ConditionalOnMissingBean(PlatformTransactionManager.class)
		public DataSourceTransactionManager transactionManager(
				DataSourceProperties properties) {
			// 根据DataSource,初始化一个DataSourceTransactionManager对象,然后return;所以,这里就会把初始化的事务管理器放到spring容器中
			DataSourceTransactionManager transactionManager = new DataSourceTransactionManager(
					this.dataSource);
			if (this.transactionManagerCustomizers != null) {
				this.transactionManagerCustomizers.customize(transactionManager);
			}
			return transactionManager;
		}
	}
}

在这个bean中,就注入了一个事务管理器,但是有一个前提,就是@ConditionalOnSingleCandidate(DataSource.class),这个注解,百度了一下,大致的意思就是说如果当前容器中只有一个DataSource,才会执行下面注入的动作

所以,对于springboot应用,如果我们在项目中,只有一个DataSource,那spring会帮我们自动注入一个,在使用事务注解的时候,也就不需要去指定value了

未确认点

这里就是有一个点不太明白,在有多个数据源的情况下,springboot就不帮我们注入事务管理器了,但是我在debug的时候,发现,还是取的默认的事务管理器,也就是DataSourceTransactionalManager, 这个点没太搞懂原因,因为感觉和源码中自己理解的不太一样

结论

总之,在项目中有多个数据源的时候,在事务注解上,最好标明使用哪个事务管理器

以上为个人经验,希望能给大家一个参考,也希望大家多多支持。

Copyright 2022 版权所有 软件发布 访问手机版

声明:所有软件和文章来自软件开发商或者作者 如有异议 请与本站联系 联系我们