/**
 * @author: jiangjs
 * @description:
 * @date: 2023/7/27 11:21
 **/
public class DataSourceContextHolder {
    //Этот класс не предоставляет никаких локальных переменных. Эти переменные отличаются от своего обычного соответствия тем, что каждая нить обращается к нити (через методы get и set) и имеет свою собственную независимую копию инициализированной переменной.
    private static final ThreadLocal<String> DATASOURCE_HOLDER = new ThreadLocal<>();

    /**
     * Настроить источник данных
     * @param dataSourceName Имя источника данных
     */
    public static void setDataSource(String dataSourceName){
        DATASOURCE_HOLDER.set(dataSourceName);
    }

    /**
     * Получить текущий источник данных
     * @return Имя источника данных
     */
    public static String getDataSource(){
        return DATASOURCE_HOLDER.get();
    }

    /**
     * Удалить текущий источник данных
     */
    public static void removeDataSource(){
        DATASOURCE_HOLDER.remove();
    }

}

/**
 * @author: jiangjs
 * @description: Реализация динамических источников данных и маршрутизация к различным источникам данных в соответствии с AbstractRoutingDataSource.
 * @date: 2023/7/27 11:18
 **/
public class DynamicDataSource extends AbstractRoutingDataSource {

    public DynamicDataSource(DataSource defaultDataSource,Map<Object, Object> targetDataSources){
        super.setDefaultTargetDataSource(defaultDataSource);
        super.setTargetDataSources(targetDataSources);
    }

    @Override
    protected Object determineCurrentLookupKey() {
        return DataSourceContextHolder.getDataSource();
    }
}

#Настроить источник данных
spring:
  datasource:
    type: com.alibaba.druid.pool.DruidDataSource
    druid:
      master:
        url: jdbc:mysql://xxxxxx:3306/test1?characterEncoding=utf-8&allowMultiQueries=true&zeroDateTimeBehavior=convertToNull&useSSL=false
        username: root
        password: 123456
        driver-class-name: com.mysql.cj.jdbc.Driver
      slave:
        url: jdbc:mysql://xxxxx:3306/test2?characterEncoding=utf-8&allowMultiQueries=true&zeroDateTimeBehavior=convertToNull&useSSL=false
        username: root
        password: 123456
        driver-class-name: com.mysql.cj.jdbc.Driver
      initial-size: 15
      min-idle: 15
      max-active: 200
      max-wait: 60000
      time-between-eviction-runs-millis: 60000
      min-evictable-idle-time-millis: 300000
      validation-query: ""
      test-while-idle: true
      test-on-borrow: false
      test-on-return: false
      pool-prepared-statements: false
      connection-properties: false
/**
 * @author: jiangjs
 * @description: Настроить источник данных
 * @date: 2023/7/27 11:34
 **/
@Configuration
public class DateSourceConfig {

    @Bean
    @ConfigurationProperties("spring.datasource.druid.master")
    public DataSource masterDataSource(){
        return DruidDataSourceBuilder.create().build();
    }

    @Bean
    @ConfigurationProperties("spring.datasource.druid.slave")
    public DataSource slaveDataSource(){
        return DruidDataSourceBuilder.create().build();
    }

    @Bean(name = "dynamicDataSource")
    @Primary
    public DynamicDataSource createDynamicDataSource(){
        Map<Object,Object> dataSourceMap = new HashMap<>();
        DataSource defaultDataSource = masterDataSource();
        dataSourceMap.put("master",defaultDataSource);
        dataSourceMap.put("slave",slaveDataSource());
        return new DynamicDataSource(defaultDataSource,dataSourceMap);
    }

}

create table test_user(
  user_name varchar(255) not null comment 'имя пользователя'
)

insert into test_user (user_name) value ('master');

insert into test_user (user_name) value ('slave');

@GetMapping("/getData.do/{datasourceName}")
public String getMasterData(@PathVariable("datasourceName") String datasourceName){
    DataSourceContextHolder.setDataSource(datasourceName);
    TestUser testUser = testUserMapper.selectOne(null);
    DataSourceContextHolder.removeDataSource();
    return testUser.getUserName();
}

@SpringBootApplication(exclude = DataSourceAutoConfiguration.class)

/**
 * @author: jiangjs
 * @description:
 * @date: 2023/7/27 14:39
 **/
@Target({ElementType.METHOD,ElementType.TYPE})
@Retention(RetentionPolicy.RUNTIME)
@Documented
@Inherited
public @interface DS {
    String value() default "master";
}

@Aspect
@Component
@Slf4j
public class DSAspect {

    @Pointcut("@annotation(com.jiashn.dynamic_datasource.dynamic.aop.DS)")
    public void dynamicDataSource(){}

    @Around("dynamicDataSource()")
    public Object datasourceAround(ProceedingJoinPoint point) throws Throwable {
        MethodSignature signature = (MethodSignature)point.getSignature();
        Method method = signature.getMethod();
        DS ds = method.getAnnotation(DS.class);
        if (Objects.nonNull(ds)){
            DataSourceContextHolder.setDataSource(ds.value());
        }
        try {
            return point.proceed();
        } finally {
            DataSourceContextHolder.removeDataSource();
        }
    }
}

@GetMapping("/getMasterData.do")
public String getMasterData(){
    TestUser testUser = testUserMapper.selectOne(null);
    return testUser.getUserName();
}

@GetMapping("/getSlaveData.do")
@DS("slave")
public String getSlaveData(){
    TestUser testUser = testUserMapper.selectOne(null);
    return testUser.getUserName();
}

/**
 * @author: jiangjs
 * @description: объект источника данных
 * @date: 2023/7/27 15:55
 **/
@Data
@Accessors(chain = true)
public class DataSourceEntity {

    /**
     * база данныхадрес     */
    private String url;
    /**
     * база данныхимя пользователя     */
    private String userName;
    /**
     * пароль
     */
    private String passWord;
    /**
     * база данныхводить машину     */
    private String driverClassName;
    /**
     * база данныеkey, который сохраняет ключ на карте
     */
    private String key;
}

/**
 * @author: jiangjs
 * @description: Реализация динамических источников данных и маршрутизация к различным источникам данных в соответствии с AbstractRoutingDataSource.
 * @date: 2023/7/27 11:18
 **/
@Slf4j
public class DynamicDataSource extends AbstractRoutingDataSource {

    private final Map<Object,Object> targetDataSourceMap;

    public DynamicDataSource(DataSource defaultDataSource,Map<Object, Object> targetDataSources){
        super.setDefaultTargetDataSource(defaultDataSource);
        super.setTargetDataSources(targetDataSources);
        this.targetDataSourceMap = targetDataSources;
    }

    @Override
    protected Object determineCurrentLookupKey() {
        return DataSourceContextHolder.getDataSource();
    }

    /**
     * Добавить информацию об источнике данных
     * @param dataSources объект источника данныхсобирать     * @return Вернуться, чтобы добавить результаты
     */
    public void createDataSource(List<DataSourceEntity> dataSources){
        try {
            if (CollectionUtils.isNotEmpty(dataSources)){
                for (DataSourceEntity ds : dataSources) {
                    //проверятьбаза данных Является ли это возможнымсоединять                    Class.forName(ds.getDriverClassName());
                    DriverManager.getConnection(ds.getUrl(),ds.getUserName(),ds.getPassWord());
                    //Определяем источник данных
                    DruidDataSource dataSource = new DruidDataSource();
                    BeanUtils.copyProperties(ds,dataSource);
                    //При подаче заявки на соединение выполните validationQuery, чтобы проверить, действительно ли соединение. Рекомендуется, чтобы Конфигурация имела значение TRUE, чтобы полученное соединение не было недоступным.
                    dataSource.setTestOnBorrow(true);
                    //Рекомендуется указать значение «Конфигурация» true, что не влияет на производительность и обеспечивает безопасность.
                    //Обнаружение при подаче заявки на соединение. Если время простоя превышает timeBetweenEvictionRunsMillis, выполните validationQuery, чтобы проверить, действительно ли соединение.
                    dataSource.setTestWhileIdle(true);
                    //SQL используется для определения допустимости соединения, требованием является оператор запроса.
                    dataSource.setValidationQuery("select 1 ");
                    dataSource.init();
                    this.targetDataSourceMap.put(ds.getKey(),dataSource);
                }
                super.setTargetDataSources(this.targetDataSourceMap);
                // Поместите объединенную информацию в TargetDataSources в управление разрешенными источниками данных.
                super.afterPropertiesSet();
                return Boolean.TRUE;
            }
        }catch (ClassNotFoundException | SQLException e) {
            log.error("---Ошибка программы---:{}", e.getMessage());
        }
        return Boolean.FALSE;
    }

    /**
     * Проверьте, существует ли источник данных
     * @param key Ключ, сохраненный в источнике данных
     * @return Возвращаемый результат: true: существует, false: не существует.
     */
    public boolean existsDataSource(String key){
        return Objects.nonNull(this.targetDataSourceMap.get(key));
    }
}

create table test_db_info(
    id int auto_increment primary key not null comment 'Идентификатор первичного ключа',
    url varchar(255) not null comment 'база данныхURL',
    username varchar(255) not null comment 'имя пользователя',
    password varchar(255) not null comment 'пароль',
    driver_class_name varchar(255) not null comment 'база данныхводить машину'    name varchar(255) not null comment 'база данныхимя'
)

insert into test_db_info(url, username, password,driver_class_name, name)
value ('jdbc:mysql://xxxxx:3306/test2?characterEncoding=utf-8&allowMultiQueries=true&zeroDateTimeBehavior=convertToNull&useSSL=false',
       'root','123456','com.mysql.cj.jdbc.Driver','add_slave')

/**
 * @author: jiangjs
 * @description:
 * @date: 2023/7/27 16:56
 **/
@Component
public class LoadDataSourceRunner implements CommandLineRunner {
    @Resource
    private DynamicDataSource dynamicDataSource;
    @Resource
    private TestDbInfoMapper testDbInfoMapper;
    @Override
    public void run(String... args) throws Exception {
        List<TestDbInfo> testDbInfos = testDbInfoMapper.selectList(null);
        if (CollectionUtils.isNotEmpty(testDbInfos)) {
            List<DataSourceEntity> ds = new ArrayList<>();
            for (TestDbInfo testDbInfo : testDbInfos) {
                DataSourceEntity sourceEntity = new DataSourceEntity();
                BeanUtils.copyProperties(testDbInfo,sourceEntity);
                sourceEntity.setKey(testDbInfo.getName());
                ds.add(sourceEntity);
            }
            dynamicDataSource.createDataSource(ds);
        }
    }
}

Содержимое включает основы Java.、JavaWeb、Оптимизация производительности MySQL、JVM、Замок、Миллионы одновременных、очередь сообщений、Высокопроизводительное кэширование、отражение、Принцип пружинного семейного ведра、микросервисы、Zookeeper... и другие технологические стеки!