springboot+druid多主多从读写分离负载均衡实现

实现多主多从读写分离负载均衡可以通过使用SpringBoot和Druid提供的相关功能实现。

首先，我们需要在SpringBoot中配置Druid数据源，如下所示：

@Configuration
public class DataSourceConfig {
    
    @Bean(name = "masterDataSource")
    @ConfigurationProperties(prefix = "spring.datasource.master")
    public DataSource masterDataSource() {
        return DruidDataSourceBuilder.create().build();
    }

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

    @Bean(name = "dynamicDataSource")
    public DataSource dynamicDataSource(@Qualifier("masterDataSource") DataSource masterDataSource,
                                         @Qualifier("slaveDataSource") DataSource slaveDataSource) {
        DynamicDataSource dynamicDataSource = new DynamicDataSource();
        Map<Object, Object> targetDataSources = new HashMap<>();
        targetDataSources.put(DynamicDataSourceEnum.MASTER.getName(), masterDataSource);
        targetDataSources.put(DynamicDataSourceEnum.SLAVE.getName(), slaveDataSource);
        dynamicDataSource.setTargetDataSources(targetDataSources);
        dynamicDataSource.setDefaultTargetDataSource(masterDataSource);
        return dynamicDataSource;
    }
}

在上述配置中，我们定义了两个数据源：masterDataSource和slaveDataSource，并且使用了DruidDataSourceBuilder来构建数据源。 这里的前缀为“spring.datasource.master”和“spring.datasource.slave”是在application.yml中配置的。

接下来，我们需要实现动态数据源路由的功能。使用ThreadLocal来存储数据源的key，然后根据key路由到对应的数据源。这里我们实现了一个DynamicDataSource继承AbstractRoutingDataSource，并且实现了determineCurrentLookupKey方法：

public class DynamicDataSource extends AbstractRoutingDataSource {

    private static final ThreadLocal<String> contextHolder = new ThreadLocal<>();

    public static void setDataSource(String dataSource) {
        contextHolder.set(dataSource);
    }

    @Override
    protected Object determineCurrentLookupKey() {
        return contextHolder.get();
    }

    public static void clearDataSource() {
        contextHolder.remove();
    }
}

接下来，我们可以使用AOP来实现在方法执行前根据注解的方式选择数据源，如下所示：

@Retention(RetentionPolicy.RUNTIME)
@Target({ElementType.METHOD})
public @interface DataSource {
    String value() default "";
}

@Aspect
@Component
public class DynamicDataSourceAspect {
    
    @Before("@annotation(dataSource)")
    public void switchDataSource(JoinPoint point, DataSource dataSource) {
        String value = dataSource.value();
        if (StringUtils.isEmpty(value)) {
            DynamicDataSource.setDataSource(DynamicDataSourceEnum.MASTER.getName());
        } else {
            DynamicDataSource.setDataSource(value);
        }
    }

    @After("@annotation(dataSource)")
    public void restoreDataSource(JoinPoint point, DataSource dataSource) {
        DynamicDataSource.clearDataSource();
    }
}

我们可以使用@DataSource注解来指定数据源，如果没有设置数据源，则默认使用master数据源。 通过AOP的方式，在方法执行前和执行后分别设置和清除数据源。

最后，我们可以使用Nginx等负载均衡工具来实现多实例的负载均衡，从而实现高可用性的数据库访问。