Spring Bootはどのように運転時にデータソースを動的に追加しますか?
このプログラムは、springbootプロジェクトの実行時にデータソースを動的に追加し、非静的に多データソースを切り替えるために適用されます。
一、マルチデータソースの応用シーン:
1.設定ファイルは、デフォルトのデータソース:master、データソース1:salve 1…、運転時に設定されているデータソースを動的に切り替えることができません。運転時にはプロファイルに設定されていないデータソースを動的に追加することができません。
2.デフォルトのデータソースを設定し、実行時に新しいデータソースを動的に追加して使用する(このブログはこのシーンに適用する)
二、解決案:
SpringはAbstractroutingDataSourceを提供しています。第一のシーンはAbstractRoutingDataSourceの種類を継承して、そのprotected abstract Object determinerentLook upKeyを上書きすればいいです。
第二のシーンは直接プロテックスDataSource determineTarget DataSource方法を書いてもいいです。原理はAbstractRoutingDataSource対応のソースコードを見ることができます。比較的簡単で、無駄な説明はしません。
直接に乾物に行く:
詳細な使い方を添付します。
一、マルチデータソースの応用シーン:
1.設定ファイルは、デフォルトのデータソース:master、データソース1:salve 1…、運転時に設定されているデータソースを動的に切り替えることができません。運転時にはプロファイルに設定されていないデータソースを動的に追加することができません。
2.デフォルトのデータソースを設定し、実行時に新しいデータソースを動的に追加して使用する(このブログはこのシーンに適用する)
二、解決案:
SpringはAbstractroutingDataSourceを提供しています。第一のシーンはAbstractRoutingDataSourceの種類を継承して、そのprotected abstract Object determinerentLook upKeyを上書きすればいいです。
第二のシーンは直接プロテックスDataSource determineTarget DataSource方法を書いてもいいです。原理は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;
@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.set 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(); 。
ツール類のSprigUtilsを添付します。
import lombok.Getter;
import org.springframework.beans.BeansException;
import org.springframework.context.ApplicationContext;
import org.springframework.context.ApplicationContextAware;
import org.springframework.stereotype.Component;
@Component
public 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);
}
}
以上が本文の全部です。皆さんの勉強に役に立つように、私たちを応援してください。