SpringBoot中怎么切换主从数据源，相信很多没有经验的人对此束手无策，为此本文总结了问题出现的原因和解决方法，通过这篇文章希望你能解决这个问题。
网站建设哪家好，找创新互联！专注于网页设计、网站建设、微信开发、小程序开发、集团企业网站建设等服务项目。为回馈新老客户创新互联还提供了泰和免费建站欢迎大家使用！
借助spring的【org.springframework.jdbc.datasource.lookup.AbstractRoutingDataSource】这个抽象类实现，来进行·数据源的路由，并通过Aop 进行路由选择。
# dev server # 多数据源时，主数据源为 master spring.datasource.master.jdbc-url=jdbc:MySQL://localhost:3306/epoint?characterEncoding=utf8&allowMultiQueries=true&useSSL=false&autoReconnect=true&failOverReadOnly=false spring.datasource.master.username=test spring.datasource.master.password=test # dev server # 多数据源时，从数据源为 slave spring.datasource.slave.jdbc-url=jdbc:mysql://localhost:3306/epoint2?characterEncoding=utf8&allowMultiQueries=true&useSSL=false&autoReconnect=true&failOverReadOnly=false spring.datasource.slave.username=test spring.datasource.slave.password=test
spring boot ：error querying database. Cause: java.lang.IllegalArgumentException: dataSource or dataSourceClassName or jdbcUrl is required 配置多个数据源启动报错，error querying database. Cause: java.lang.IllegalArgumentException: dataSource or dataSourceClassName or jdbcUrl is required， 主要原因是在1.0 配置数据源的过程中主要是写成：spring.datasource.url 和spring.datasource.driverClassName。 而在2.0升级之后需要变更成：spring.datasource.jdbc-url和spring.datasource.driver-class-name即可解决！ 更改配置：spring.datasource.master.url -> spring.datasource.master.jdbc-url
重庆分公司
重庆分公司
/**
* describe:定义HandleDataSource类来获取当前线程的数据源类型
* current user Maochao.zhu
* current system 2020/9/15
*/
public class HandleDataSource {
public static final ThreadLocal holder = new ThreadLocal();
/**
* 绑定当前线程数据源
*
* @param datasource
*/
public static void putDataSource(String datasource) {
holder.set(datasource);
}
/**
* 获取当前线程的数据源
*
* @return
*/
public static String getDataSource() {
return holder.get();
}
} 注意：因为新加了数据库线程处理类，和原来存在的多线程处理类冲突，会造成现有程序“卡顿”或者“死机”，因此去除原来配置的定时任务多线程配置
/**
* describe:配置多线程定时器
* current user Maochao.zhu
* current system 2020/1/20
*/
@Configuration
@EnableScheduling
public class ScheduleConfig implements SchedulingConfigurer {
@Override
public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
Method[] methods = BatchProperties.Job.class.getMethods();
int defaultPoolSize = 3;
int corePoolSize = 0;
if (methods != null && methods.length > 0) {
for (Method method : methods) {
Scheduled annotation = method.getAnnotation(Scheduled.class);
if (annotation != null) {
corePoolSize++;
}
}
if (defaultPoolSize > corePoolSize)
corePoolSize = defaultPoolSize;
}
taskRegistrar.setScheduler(Executors.newScheduledThreadPool(corePoolSize));
}
}/**
* describe:定义路由数据源的实现类MyAbstractRoutingDataSource
* current user Maochao.zhu
* current system 2020/9/15
*/
public class MyAbstractRoutingDataSource extends AbstractRoutingDataSource {
private final Logger log = LoggerFactory.getLogger(this.getClass());
@Override
protected Object determineCurrentLookupKey() {
log.info("###请求的数据源：{}",HandleDataSource.getDataSource());
return HandleDataSource.getDataSource();//获取对应的数据源
}
}/**
* describe:配置数据源数据源和路由配置
* current user Maochao.zhu
* current system 2020/9/15
*/
@Configuration
public class DataSourceConfig {
//主数据源
@Bean()
@ConfigurationProperties(prefix = "spring.datasource.master")
public DataSource MasterDataSource() {
return DataSourceBuilder.create().build();
}
//从数据源
@Bean()
@ConfigurationProperties(prefix = "spring.datasource.slave")
public DataSource SlaveDataSource() {
return DataSourceBuilder.create().build();
}
/**
* 设置数据源路由，通过该类中的determineCurrentLookupKey决定使用哪个数据源
*/
@Bean
public AbstractRoutingDataSource routingDataSource() {
MyAbstractRoutingDataSource proxy = new MyAbstractRoutingDataSource();
Map targetDataSources = new HashMap<>(2);//存放对于数据源的映射
targetDataSources.put("master", MasterDataSource());
targetDataSources.put("slave", SlaveDataSource());
proxy.setDefaultTargetDataSource(MasterDataSource());
proxy.setTargetDataSources(targetDataSources);
return proxy;
}
@Bean(name = "SqlSessionFactory")
@Primary
public SqlSessionFactory MasterSqlSessionFactory(DataSource routingDataSource) throws Exception {
SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
bean.setDataSource(routingDataSource);//DataSource使用路由数据源
ResourcePatternResolver resolver = new PathMatchingResourcePatternResolver();
try {
bean.setMapperLocations(resolver.getResources("classpath*:mapper/**/*.xml"));
bean.setConfigLocation(resolver.getResource("classpath:mybatis-config.xml"));
return bean.getObject();
} catch (Exception e) {
e.printStackTrace();
throw new RuntimeException(e);
}
}
@Bean(name = "TransactionManager")
@Primary
public DataSourceTransactionManager testTransactionManager(DataSource routingDataSource) {
return new DataSourceTransactionManager(routingDataSource);
}
@Bean(name = "SqlSessionTemplate")
@Primary
public SqlSessionTemplate MasterSqlSessionTemplate(SqlSessionFactory sqlSessionFactory) throws Exception {
return new SqlSessionTemplate(sqlSessionFactory);
}
} 注意：配置路由设置后，原来的apache.shiro 权限读取不到问题，排查以后确定原因是在使用配置路由设置,原来在application.properties中配置的mybaits属性,将不起作用，因此需要新加一个配置文件(mybatis-config.xml),从中读取配置信息， 其中ShiroConfig配置类中新增注解支持
/**
* 开启Shiro的注解(如@RequiresRoles,@RequiresPermissions),需借助SpringAOP扫描使用Shiro注解的类,并在必要时进行安全逻辑验证
* 配置以下两个bean(DefaultAdvisorAutoProxyCreator和AuthorizationAttributeSourceAdvisor)即可实现此功能
* @return
*/
@Bean
@ConditionalOnMissingBean
public DefaultAdvisorAutoProxyCreator defaultAdvisorAutoProxyCreator(){
DefaultAdvisorAutoProxyCreator advisorAutoProxyCreator = new DefaultAdvisorAutoProxyCreator();
advisorAutoProxyCreator.setProxyTargetClass(true);
return advisorAutoProxyCreator;
}
/**
* 开启shiro aop注解支持.
* 使用代理方式;所以需要开启代码支持;
* @param securityManager
* @return
* */
@Bean
public AuthorizationAttributeSourceAdvisor authorizationAttributeSourceAdvisor(SecurityManager securityManager){
AuthorizationAttributeSourceAdvisor authorizationAttributeSourceAdvisor = new AuthorizationAttributeSourceAdvisor();
authorizationAttributeSourceAdvisor.setSecurityManager(securityManager);
return authorizationAttributeSourceAdvisor;
}
