1. 程式人生 > >spring boot + druid來進行資料庫加密及sql效能統計

spring boot + druid來進行資料庫加密及sql效能統計

springboot專案就不多說了。druid也不多說了,網上一搜就有介紹。

我理解簡單說:

druid替換了spring boot的c3p0和DBCP連線池。

druid提供了視覺化介面進行sql效能等相關統計。

druid提供了資料庫密碼加密處理。

如何使用:

1,引入依賴:

		<dependency>
			<groupId>com.alibaba</groupId>
			<artifactId>druid</artifactId>
			<version>1.1.5</version>
		</dependency>

2,配置檔案配置:

######################################################
###Mysql及資料連線池配置,使用druid替換原有連線池
######################################################
#druid驅動配置
spring.datasource.type=com.alibaba.druid.pool.DruidDataSource
#資料庫連結,myql5.7之後需要SSL加密連結 這裡配置編碼及開啟SSL
spring.datasource.url = jdbc:mysql://127.0.0.1:3306/mydb?characterEncoding=utf8&useSSL=true
#資料庫使用者名稱
spring.datasource.username = root
#使用druid加密資料庫密碼
spring.datasource.password = 加密後的pwd
#使用druid加密資料庫的公鑰
spring.datasource.publicKey=公鑰
#Mysql資料庫驅動
spring.datasource.driverClassName = com.mysql.jdbc.Driver
#連線池配置資訊,初始化連線數
spring.datasource.initialSize=5
#連線池配置資訊,最小連線數
spring.datasource.minIdle=5
#連線池配置資訊,最大連線數
spring.datasource.maxActive=20
# 配置獲取連線等待超時的時間
spring.datasource.maxWait=60000
# 配置間隔多久才進行一次檢測,檢測需要關閉的空閒連線,單位是毫秒
spring.datasource.timeBetweenEvictionRunsMillis=60000
# 配置一個連線在池中最小生存的時間,單位是毫秒
spring.datasource.minEvictableIdleTimeMillis=300000
#驗證資料庫是否連結
spring.datasource.validationQuery=SELECT 1 FROM DUAL
#當連結空閒時,是否測試連結可用性
spring.datasource.testWhileIdle=true
#當從連線池拿到連線時,是否測試連線的可用性
spring.datasource.testOnBorrow=false
#當連結歸還連線池時,是否測試連結可用性
spring.datasource.testOnReturn=false
# 控制PSCache(記憶體佔用優化,大幅度提升sql執行效能,支援oracle,db2,sql server,不支援mysql)
spring.datasource.poolPreparedStatements=false
#指定每個連線上PSCache的大小 
#spring.datasource.maxPoolPreparedStatementPerConnectionSize=20  
# 配置監控統計攔截的filters,去掉後監控介面sql無法統計,'wall'用於防火牆
spring.datasource.filters=config,stat,wall,log4j
# 通過connectProperties屬性來開啟mergeSql功能;慢SQL記錄
spring.datasource.connectionProperties=druid.stat.mergeSql=true;druid.stat.slowSqlMillis=5000;config.decrpt=true;
spring.datasource.logSlowSql=true

3,配置druid配置類

package com.wm.springboot.conf;

import com.alibaba.druid.filter.config.ConfigTools;
import com.alibaba.druid.pool.DruidDataSource;
import com.alibaba.druid.support.http.StatViewServlet;
import com.alibaba.druid.support.http.WebStatFilter;

import lombok.extern.slf4j.Slf4j;

import org.springframework.beans.factory.annotation.Value;
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.sql.SQLException;

/**
 * Druid配置類
 * 1、可以監控資料庫訪問效能,內建了外掛:StatFilter,能夠詳細統計SQL執行效能,用於線上分析資料庫訪問效能。
 * 2、替換DBCP、C3P0資料庫連線池,提供了一個高效穩定的擴充套件效能好的資料庫連線池DruidDataSource。
 * 3、資料庫加密,DruidDriuiver和DruidDataSource都支援PasswordCallback。
 * 4、SQL執行日誌。
 * 5、擴充套件JDBC,如果你要對JDBC層有程式設計的需求,可以通過Druid提供的Filter-Chain機制,很方便編寫JDBC層的擴充套件外掛
 * Druid是一個阿里開源的資料庫連線池框架,有視覺化介面。
 * http://localhost:8080/druid/login.html
 * 可以檢視sql訪問速度等等很多資訊,感覺還是比較有用的。整合進來試試
 * @author maybe
 */
@Configuration
@Slf4j
public class DruidConfig {

	//使用@value注入配置檔案中資訊
    @Value("${spring.datasource.url}")
    private String dbUrl;

    @Value("${spring.datasource.username}")
    private String username;

    @Value("${spring.datasource.password}")
    private String password;
    
    @Value("${spring.datasource.publicKey}")
    private String publicKey;

    @Value("${spring.datasource.driverClassName}")
    private String driverClassName;

    @Value("${spring.datasource.initialSize}")
    private int initialSize;

    @Value("${spring.datasource.minIdle}")
    private int minIdle;

    @Value("${spring.datasource.maxActive}")
    private int maxActive;

    @Value("${spring.datasource.maxWait}")
    private int maxWait;

    @Value("${spring.datasource.timeBetweenEvictionRunsMillis}")
    private int timeBetweenEvictionRunsMillis;

    @Value("${spring.datasource.minEvictableIdleTimeMillis}")
    private int minEvictableIdleTimeMillis;

    @Value("${spring.datasource.validationQuery}")
    private String validationQuery;

    @Value("${spring.datasource.testWhileIdle}")
    private boolean testWhileIdle;

    @Value("${spring.datasource.testOnBorrow}")
    private boolean testOnBorrow;

    @Value("${spring.datasource.testOnReturn}")
    private boolean testOnReturn;

    @Value("${spring.datasource.filters}")
    private String filters;

    @Value("${spring.datasource.logSlowSql}")
    private String logSlowSql;
    
    @Value("${spring.datasource.connectionProperties}")
    private String connectionProperties;

    @Bean
    public ServletRegistrationBean druidServlet() throws Exception {
        ServletRegistrationBean reg = new ServletRegistrationBean();
        reg.setServlet(new StatViewServlet());
        reg.addUrlMappings("/druid/*");//配置訪問URL
        reg.addInitParameter("loginUsername", username);  //配置使用者名稱,這裡使用資料庫賬號。
        reg.addInitParameter("loginPassword", ConfigTools.decrypt(publicKey,password));  //配置使用者名稱,這裡使用資料庫密碼
        reg.addInitParameter("logSlowSql", logSlowSql);   //是否啟用慢sql
        return reg;
    }

    @Bean
    public FilterRegistrationBean filterRegistrationBean() {
        FilterRegistrationBean filterRegistrationBean = new FilterRegistrationBean();
        filterRegistrationBean.setFilter(new WebStatFilter());
        filterRegistrationBean.addUrlPatterns("/*");
        filterRegistrationBean.addInitParameter("exclusions", "*.js,*.gif,*.jpg,*.png,*.css,*.ico,/druid/*");  //配置那些資源不被攔截
        filterRegistrationBean.addInitParameter("profileEnable", "true");
        return filterRegistrationBean;
    }

    /**
     * 這個應該是資料庫連線池配置
     * @return
     * @throws Exception 
     */
    @Bean
    public DataSource druidDataSource() throws Exception {
        DruidDataSource datasource = new DruidDataSource();
        datasource.setUrl(dbUrl);
        datasource.setUsername(username);
        datasource.setPassword(ConfigTools.decrypt(publicKey,password));
        datasource.setDriverClassName(driverClassName);
        datasource.setInitialSize(initialSize);
        datasource.setMinIdle(minIdle);
        datasource.setMaxActive(maxActive);
        datasource.setMaxWait(maxWait);
        datasource.setTimeBetweenEvictionRunsMillis(timeBetweenEvictionRunsMillis);
        datasource.setMinEvictableIdleTimeMillis(minEvictableIdleTimeMillis);
        datasource.setValidationQuery(validationQuery);
        datasource.setTestWhileIdle(testWhileIdle);
        datasource.setTestOnBorrow(testOnBorrow);
        datasource.setTestOnReturn(testOnReturn);
        datasource.setConnectionProperties(connectionProperties);
        try {
            datasource.setFilters(filters);
        } catch (SQLException e) {
            log.error("druid configuration initialization filter:{}",e);
        }
        return datasource;
    }

}

一定要注意:這裡密碼是使用@value註解從配置檔案中取出來的。這時候你已經在配置檔案中使用了加密後的pwd串,所以在java中配置druid時,要講publickey和pwd都寫入使用解密方法

ConfigTools.decrypt(publicKey,password)
去進行解密才可以使用。

那麼現在spring boot整合druid已經完成了。只差將密碼加密並且寫入配置檔案即可。

druid進行資料庫密碼加密:

1,找到druid的相關jar包

這裡我是用的是

2,進行加密

進行cmd找到該jar包所在目錄,執行:

java -cp druid-1.1.5.jar com.alibaba.druid.filter.config.ConfigTools password

得到:

    1,privateKey  私鑰,進行加密時的key

    2,publickey  公鑰,進行解密時的key

    3,password  加密後的密碼 

將password和publickey填入配置檔案中即可完成。