SpringBoot運行時動態添加數據源

  • 2019 年 10 月 13 日
  • 筆記

此方案適用於解決springboot項目運行時動態添加數據源,非靜態切換多數據源!!!

一、多數據源應用場景:

1.配置文件配置多數據源,如默認數據源:master,數據源1:salve1…,運行時動態切換已配置的數據源(master、salve1互相切換),無法在運行時動態添加配置文件中未配置的數據源。

2.配置一個默認數據源,運行時動態添加新數據源使用(本博客適用於此場景)

二、解決方案:

Spring提供了AbstractRoutingDataSource用於動態路由數據源,第一種場景繼承AbstractRoutingDataSource類並覆寫其protected abstract Object determineCurrentLookupKey()即可;
而第二種場景我們直接覆寫protected DataSource determineTargetDataSource方法即可。原理可看下AbstractRoutingDataSource對應源碼,比較簡單,不做贅述。
直接上乾貨:

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();      }  }    @Configuration  public 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()防止內存泄漏並重置默認數據源。