SpringBoot整合Druid並配置數據源監控

一、導入Maven依賴

<dependencies>
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <version>5.1.38</version>
        </dependency>

        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <version>1.18.8</version>
            <optional>true</optional>
        </dependency>

        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>druid-spring-boot-starter</artifactId>
            <version>1.1.21</version>
        </dependency>

        <dependency>
            <groupId>com.baomidou</groupId>
            <artifactId>mybatis-plus-boot-starter</artifactId>
            <version>3.1.0</version>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
            <version>2.1.5.RELEASE</version>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-autoconfigure</artifactId>
            <optional>true</optional>
            <version>2.1.5.RELEASE</version>
        </dependency>
    </dependencies>

 

二、配置文件

appliaction.yml內容為

spring:
  datasource:
    username: root
    password: 123456
    url: jdbc:mysql://192.169.1.21:3306/msg_his?serverTimezone=UTC
    driver-class-name: com.mysql.jdbc.Driver
    type: com.alibaba.druid.pool.DruidDataSource
    # 數據源其它配置
    initialSize: 5
    minIdle: 5
    maxActive: 20
    maxWait: 60000
    timeBetweenEvictionRunsMillis: 60000
    minEvictableIdleTimeMillis: 300000
    validationQuery: SELECT 1 FROM DUAL
    testWhileIdle: true
    testOnBorrow: false
    testOnReturn: false
    poolPreparedStatements: true
    #配置監控統計攔截的filters，去掉后監控界面sql無法統計，'wall'用於防火牆
    filters: stat,wall
    maxPoolPreparedStatementPerConnectionSize: 20
    useGlobalDataSourceStat: true
    connectionProperties: druid.stat.mergeSql=true;druid.stat.slowSqlMillis=500

這樣配置數據庫連接池參數是不生效的 ,因為我們的所有屬性都設置再spring.datasource下，而spring.datasource這些參數都在DataSourceProperties這個類所對應的，但是在DataSourceProperties這個配置下並沒有這些druid連接池參數。所以，我們做如下配置

package com.harara.druid.config;

import com.alibaba.druid.pool.DruidDataSource;import org.springframework.boot.context.properties.ConfigurationProperties;import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

import javax.sql.DataSource;/**
 * @author : harara
 * @version : 1.0
 * @date : 2020/6/16 16:59
 */
@Configuration
public class DruidConfig {

    @ConfigurationProperties(prefix = "spring.datasource")
    @Bean
    public DataSource druid(){
        return new DruidDataSource();
    }

}

 

三、配置Druid數據源監控

package com.harara.druid.config;

import com.alibaba.druid.pool.DruidDataSource;
import com.alibaba.druid.support.http.StatViewServlet;
import com.alibaba.druid.support.http.WebStatFilter;
import org.springframework.boot.context.properties.ConfigurationProperties;
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 javax.sql.DataSource;
import java.util.Arrays;
import java.util.HashMap;
import java.util.Map;

/**
 * @author : harara
 * @version : 1.0
 * @date : 2020/6/16 16:59
 */
@Configuration
public class DruidConfig {

    @ConfigurationProperties(prefix = "spring.datasource")
    @Bean
    public DataSource druid(){
        return new DruidDataSource();
    }

    /**
     * 配置Druid的監控
     * 配置一個監控管理后台的Servlet
     * @return
     */
    @Bean
    public ServletRegistrationBean druidStatViewServlet(){
        ServletRegistrationBean bean = new ServletRegistrationBean(new StatViewServlet(),"/druid/*");

        Map<String,String> initParam = new HashMap<String, String>();
        //允許登錄的用戶名
        initParam.put("loginUsername","admin");
        //允許登錄的密碼
        initParam.put("loginPassword","123456");
        //允許哪些ip地址訪問，不寫就是默認允許所有訪問
        initParam.put("allow","");
        //拒絕訪問ip名單
        initParam.put("deny","192.169.1.1");
        //添加初始化參數
        bean.setInitParameters(initParam);
        return bean;
    }

    /**
     * 配置一個web監控的filter
     * @return
     */
    @Bean
    public FilterRegistrationBean druidWebStatFilter(){
        FilterRegistrationBean bean = new FilterRegistrationBean();
        bean.setFilter(new WebStatFilter());
        //攔截哪些請求
        bean.setUrlPatterns(Arrays.asList("/*"));

        Map<String,String> initParam = new HashMap<String, String>();
        //排除攔截哪些請求
        initParam.put("exclusions","*.js,*.css,/druid/*");
        bean.setInitParameters(initParam);
        return bean;
  }

}

 

四、訪問監控頁面

輸入http://localhost:8080/druid訪問監控管理后台頁面

使用上面代碼中設置的賬號密碼進行登錄

 

 

 

五、發送請求執行sql測試

package com.harara.druid.controller;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

import java.util.List;
import java.util.Map;

/**
 * @author : harara
 * @version : 1.0
 * @date : 2020/6/17 9:32
 */
@RestController
public class UserController {

    @Autowired
    private JdbcTemplate jdbcTemplate;

    @GetMapping("/user")
    public List<Map<String, Object>> hello() {
        List<Map<String, Object>> lists = jdbcTemplate.queryForList("select host,user from mysql.user ", new Object[]{});
        return lists;
    }
}

請求 http://localhost:8080/user

 

六、SQL監控頁面顯示執行的sql

SQL監控頁面