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

 

 

 

 

 

簡單分享，完事！