Springboot集成druid多数据源，监控数据源

1.引入jar包

<!-- https://mvnrepository.com/artifact/com.alibaba/druid-spring-boot-starter -->
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>druid-spring-boot-starter</artifactId>
<version>1.1.21</version>
</dependency>

2.在application.properties中添加数据源（其中ql/ql1为数据源名称，可以自定义，可配置多个）

spring.datasource.druid.ql.type=com.alibaba.druid.pool.DruidDataSource
spring.datasource.druid.ql.driver-class-name=com.mysql.jdbc.Driver
spring.datasource.druid.ql.url =jdbc:mysql://127.0.0.1/ql?Unicode=true&characterEncoding=UTF-8
spring.datasource.druid.ql.username=root
spring.datasource.druid.ql.password=root
 
spring.datasource.druid.ql.initialSize=5
spring.datasource.druid.ql.minIdle=5
spring.datasource.druid.ql.maxActive=20
spring.datasource.druid.ql.maxWait=60000
spring.datasource.druid.ql.timeBetweenEvictionRunsMillis=60000
spring.datasource.druid.ql.minEvictableIdleTimeMillis=300000
spring.datasource.druid.ql.validationQuery=SELECT 1 
spring.datasource.druid.ql.testWhileIdle=true
spring.datasource.druid.ql.testOnBorrow=false
spring.datasource.druid.ql.testOnReturn=false
spring.datasource.druid.ql.poolPreparedStatements=true
spring.datasource.druid.ql.maxPoolPreparedStatementPerConnectionSize=20
spring.datasource.druid.ql.filters=stat,wall,slf4j


spring.datasource.druid.ql.type=com.alibaba.druid.pool.DruidDataSource
spring.datasource.druid.ql.driver-class-name=com.mysql.jdbc.Driver
spring.datasource.druid.ql.url =jdbc:mysql://127.0.0.1/ql?Unicode=true&characterEncoding=UTF-8
spring.datasource.druid.ql.username=root
spring.datasource.druid.ql.password=root
 
spring.datasource.druid.ql1.initialSize=5
spring.datasource.druid.ql1.minIdle=5
spring.datasource.druid.ql1.maxActive=20
spring.datasource.druid.ql1.maxWait=60000
spring.datasource.druid.q1.timeBetweenEvictionRunsMillis=60000
spring.datasource.druid.ql1.minEvictableIdleTimeMillis=300000
spring.datasource.druid.ql1.validationQuery=SELECT 1 
spring.datasource.druid.ql1.testWhileIdle=true
spring.datasource.druid.ql1.testOnBorrow=false
spring.datasource.druid.ql1.testOnReturn=false
spring.datasource.druid.ql1.poolPreparedStatements=true
spring.datasource.druid.ql1.maxPoolPreparedStatementPerConnectionSize=20
spring.datasource.druid.ql1.filters=stat,wall,slf4j

3.配置动态数据源 DynamicDataSource.java，初始化数据源

import org.springframework.jdbc.datasource.lookup.AbstractRoutingDataSource;

import javax.sql.DataSource;
import java.util.Map;

/**
 * 动态数据源
 * @author zy
 * @date 2020-05-20
 */
public class DynamicDataSource extends AbstractRoutingDataSource {
    private static final ThreadLocal<String> contextHolder = new ThreadLocal<>();

    /**
     * 配置DataSource, defaultTargetDataSource为主数据库
     */
    public DynamicDataSource(DataSource defaultTargetDataSource, Map<Object, Object> targetDataSources) {
        super.setDefaultTargetDataSource(defaultTargetDataSource);
        super.setTargetDataSources(targetDataSources);
        super.afterPropertiesSet();
    }

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

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

    public static String getDataSource() {
        return contextHolder.get();
    }

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

}

4.多数据源配置 

DataSourceAspect.java(配置切面)

import java.lang.reflect.Method;

import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.Around;
import org.aspectj.lang.annotation.Aspect;
import org.aspectj.lang.annotation.Pointcut;
import org.aspectj.lang.reflect.MethodSignature;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.core.Ordered;
import org.springframework.stereotype.Component;

/**
 * 数据源AOP切面处理
 * @author zy
 * @date 2020-05-20
 */
@Aspect
@Component
public class DataSourceAspect implements Ordered {
    protected Logger logger = LoggerFactory.getLogger(getClass());

    /**
     * 切点: 所有配置 DataSource 注解的方法
     */
    @Pointcut("@annotation(com.ql.config.DataSource)")
    public void dataSourcePointCut() {}

    @Around("dataSourcePointCut()")
    public Object around(ProceedingJoinPoint point) throws Throwable {
        MethodSignature signature = (MethodSignature) point.getSignature();
        Method method = signature.getMethod();
        DataSource ds = method.getAnnotation(DataSource.class);
        // 通过判断 DataSource 中的值来判断当前方法应用哪个数据源
        DynamicDataSource.setDataSource(ds.value());
        System.out.println("当前数据源: " + ds.value());
        logger.debug("set datasource is " + ds.value());
        try {
            return point.proceed();
        } finally {
            DynamicDataSource.clearDataSource();
            logger.debug("clean datasource");
        }
    }

    @Override
    public int getOrder() {
        return 1;
    }
}

DataSource.java(自定义注解，默认为ql)

import java.lang.annotation.Documented;
import java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;

/**
 * 多数据源注解
 * @author zy
 * @date 2020-05-20
 */
@Documented
@Target({ElementType.METHOD})
@Retention(RetentionPolicy.RUNTIME)
public @interface DataSource {
    String value() default DataSourceNames.QL;
}

DynamicDataSourceConfig.java(数据源切换类)

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;
import java.util.Map;

/**
 * 配置多数据源
 * @author zy
 * @date 2020-05-20
 */
@Configuration
public class DynamicDataSourceConfig {
    
    /**
     * 创建 DataSource Bean
     * */
    
    @Bean
    @ConfigurationProperties("spring.datasource.druid.ql")
    public DataSource qlDataSource(){
        DataSource dataSource = DruidDataSourceBuilder.create().build();
        return dataSource;
    }

    @Bean
    @ConfigurationProperties("spring.datasource.druid.ql1")
    public DataSource ql1DataSource(){
        DataSource dataSource = DruidDataSourceBuilder.create().build();
        return dataSource;
    }
    
    
    /**
     * 如果还有数据源,在这继续添加 DataSource Bean
     * */
    
    @Bean
    @Primary
    public DynamicDataSource dataSource(
            DataSource qlDataSource,
            DataSource ql1DataSource) {
        Map<Object, Object> targetDataSources = new HashMap<>(6);
        targetDataSources.put(DataSourceNames.QL, qlDataSource);
        targetDataSources.put(DataSourceNames.QL1, dmsDataSource);
);
        // 还有数据源,在targetDataSources中继续添加
        System.out.println("DataSources:" + targetDataSources);
        return new DynamicDataSource(qlDataSource, targetDataSources);
    }
}

5.修改启动类中的数据源

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration;
import org.springframework.context.annotation.Import;

import com.xxl.job.qingling.config.DynamicDataSourceConfig;

/**
 * @author zy
 * 2019-12-23 09:14:46
 */
/**
 * 动态数据源配置,需要将自有的配置依赖(DynamicDataSourceConfig),将原有的依赖去除(DataSourceAutoConfiguration)
 * @author geYang
 * @date 2018-05-15
 */
@Import({DynamicDataSourceConfig.class})
@SpringBootApplication(exclude = {DataSourceAutoConfiguration.class})
public class XxlJobExecutorApplication {

    public static void main(String[] args) {
        SpringApplication.run(XxlJobExecutorApplication.class, args);
    }

}

6.配置druid监控

import javax.servlet.annotation.WebFilter;

import org.springframework.boot.web.servlet.FilterRegistrationBean;
import org.springframework.boot.web.servlet.ServletRegistrationBean;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

import com.alibaba.druid.support.http.StatViewServlet;
import com.alibaba.druid.support.http.WebStatFilter;

//这样的方式不需要在启动类头上添加注解：@ServletComponentScan
@Configuration
public class DruidConfiguration {
 
    /**
     * 注册一个StatViewServlet
     * @return
     */
    @Bean
    public ServletRegistrationBean DruidStatViewServle(){
 
       //org.springframework.boot.context.embedded.ServletRegistrationBean提供类的进行注册.
       ServletRegistrationBean servletRegistrationBean = new ServletRegistrationBean(new StatViewServlet(),"/druid/*");
 
       //添加初始化参数：initParams
 
       //白名单：
       servletRegistrationBean.addInitParameter("allow","");
 
       //IP黑名单 (存在共同时，deny优先于allow) : 如果满足deny的话提示:Sorry, you are not permitted to view this page.
       servletRegistrationBean.addInitParameter("deny","");
 
       //登录查看信息的账号密码.
       servletRegistrationBean.addInitParameter("loginUsername","admin");
       servletRegistrationBean.addInitParameter("loginPassword","123456");
 
       //是否能够重置数据.
       servletRegistrationBean.addInitParameter("resetEnable","false");
       return servletRegistrationBean;
    }
 
    /**
     * 注册一个：filterRegistrationBean
     * @return
     */
    @Bean
    public FilterRegistrationBean druidStatFilter(){
       FilterRegistrationBean filterRegistrationBean = new FilterRegistrationBean(new WebStatFilter());
 
       //添加过滤规则.
       filterRegistrationBean.addUrlPatterns("/*");
 
       //添加不需要忽略的格式信息.
       filterRegistrationBean.addInitParameter("exclusions","*.js,*.gif,*.jpg,*.png,*.css,*.ico,/druid/*");
 
       return filterRegistrationBean;
    }
    
}

7.效果图

启动图：

 

 界面访问：http://ip:port/projectname/druid/login.html

 

 

 

 

 

简单分享，完事！