SpringBoot中怎么在运行时动态添加数据源-创新互联

SpringBoot中怎么在运行时动态添加数据源，相信很多没有经验的人对此束手无策，为此本文总结了问题出现的原因和解决方法，通过这篇文章希望你能解决这个问题。

创新互联服务项目包括长葛网站建设、长葛网站制作、长葛网页制作以及长葛网络营销策划等。多年来，我们专注于互联网行业，利用自身积累的技术优势、行业经验、深度合作伙伴关系等，向广大中小型企业、政府机构等提供互联网行业的解决方案，长葛网站推广取得了明显的社会效益与经济效益。目前，我们服务的客户以成都为中心已经辐射到长葛省份的部分城市，未来相信会继续扩大服务区域并继续获得客户的支持与信任！

一、多数据源应用场景：

1.配置文件配置多数据源，如默认数据源：master，数据源1：salve1...，运行时动态切换已配置的数据源（master、salve1互相切换）,无法在运行时动态添加配置文件中未配置的数据源。

2.配置一个默认数据源，运行时动态添加新数据源使用（本博客适用于此场景）

二、解决方案：

Spring提供了AbstractRoutingDataSource用于动态路由数据源，第一种场景继承AbstractRoutingDataSource类并覆写其protected abstract Object determineCurrentLookupKey()即可;

而第二种场景我们直接覆写protected DataSource determineTargetDataSource方法即可。原理可看下AbstractRoutingDataSource对应源码，比较简单，不做赘述。

直接上干货：

import com.fizz.utils.spring.SpringUtils;import org.springframework.jdbc.datasource.lookup.AbstractRoutingDataSource;import javax.sql.DataSource;public class DynamicDataSource extends AbstractRoutingDataSource { private static final ThreadLocal dataSource = ThreadLocal.withInitial(() -> (DataSource) SpringUtils.getBean("defaultDataSource")); public static void setDataSource(DataSource dataSource) { DynamicDataSource.dataSource.set(dataSource); } public static DataSource getDataSource() { return DynamicDataSource.dataSource.get(); } @Override protected Object determineCurrentLookupKey() { return null; } @Override protected DataSource determineTargetDataSource() { return getDataSource(); } public static void clear() { DynamicDataSource.dataSource.remove(); }}

import com.alibaba.druid.spring.boot.autoconfigure.DruidDataSourceBuilder;import org.springframework.boot.context.properties.ConfigurationProperties;import org.springframework.context.annotation.Bean;import org.springframework.context.annotation.Configuration;import org.springframework.context.annotation.Primary;import javax.sql.DataSource;import java.util.HashMap;@Configurationpublic class DataSourceConfig { @Bean @ConfigurationProperties("spring.datasource.druid") public DataSource defaultDataSource() { return DruidDataSourceBuilder.create().build(); } @Bean @Primary public DynamicDataSource dataSource() { DynamicDataSource dynamicDataSource = new DynamicDataSource(); dynamicDataSource.setTargetDataSources(new HashMap<>()); return dynamicDataSource; }}

使用时直接调用DynamicDataSource.setDataSource(DataSource dataSource)方法即可，使用完后调用DynamicDataSource.clear()防止内存泄漏并重置默认数据源。

附上详细使用方法：

DruidDataSource druidDataSource = new DruidDataSource(); druidDataSource.setUrl("jdbc:mysql://localhost:3306/sys?characterEncoding=utf-8&useSSL=false&serverTimezone=UTC&useAffectedRows=true"); druidDataSource.setUsername("root"); druidDataSource.setPassword("root"); DynamicDataSource.setDataSource(druidDataSource); 此时数据源已切换到druidDataSource ，调用自己的业务方法即可。使用完后调用DynamicDataSource.clear();重置为默认数据源。

附上工具类SpringUtils ：

import lombok.Getter;import org.springframework.beans.BeansException;import org.springframework.context.ApplicationContext;import org.springframework.context.ApplicationContextAware;import org.springframework.stereotype.Component;@Componentpublic final class SpringUtils implements ApplicationContextAware { @Getter private static ApplicationContext applicationContext; @Override public void setApplicationContext(ApplicationContext applicationContext) throws BeansException { if (SpringUtils.applicationContext == null) { SpringUtils.applicationContext = applicationContext; } } public static T getBean(Class clazz) { return SpringUtils.applicationContext.getBean(clazz); } public static Object getBean(String name) { return SpringUtils.applicationContext.getBean(name); } public static String getProperty(String key) { return SpringUtils.applicationContext.getEnvironment().getProperty(key); }}

看完上述内容，你们掌握SpringBoot中怎么在运行时动态添加数据源的方法了吗？如果还想学到更多技能或想了解更多相关内容，欢迎关注创新互联行业资讯频道，感谢各位的阅读！

网页名称：SpringBoot中怎么在运行时动态添加数据源-创新互联
转载源于：http://cdxtjz.cn/article/ceesop.html

SpringBoot中怎么在运行时动态添加数据源-创新互联

其他资讯