spring多个事务管理器踩坑及解决_开发_开发者

多个事务管理器踩坑

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

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

案例

1、在项目中，我用到了A和B两个数据库，所www.devze.com以，此时就需要声明两个事务管理器，我们假设命名为：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，来获取事务管理器的，这是一个前提知识，需要知道

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

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.由于在android解析事务注解的时候，将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开发者_JAVA入门 = getTransactionManager();
		if (defaultTransactionManager == null) {
			// 获取默认的事务管理器
			defaultTransactionManager = this.transactionManagerCache.get(DEFAULT_TRANSACTION_MANAGER_KEY);
			if (defaultTransactionManager == null) {
				//由于我们没有指定，会从spring容器中按照类型获取，所以我们只需要往spring容器中注入一个事务管理器即可，springboot应用会默认注入一个事务管理器
				defaultTransactionManager = this.beanFactory.getBean(PlatformTrpythonansactionManager.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;

		prhttp://www.devze.comivate final TransactionManagerCustomizers transactionManagerCustomizers;

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

		@Bean
		@ConditionalOnMissingBean(PlapythontformTransactionManager.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了