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> 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> T getBean(Class<T> 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中怎么在運行時動態添加數據源的方法了嗎？如果還想學到更多技能或想了解更多相關內容，歡迎關注億速云行業資訊頻道，感謝各位的閱讀！