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;
    }
 
}
View Code

開啟監控功能
開啟Druid的監控功能,可以在應用運行的過程中,通過監控提供的多維度數據來分析使用數據庫的情況;

通過配置ServletRegistrationBean:可以添加白名單、IP黑名單、控制台管理用戶、是否能夠重置數據等。

配置FilterRegistrationBean可以添加過濾規則、忽略過濾的格式

開啟監控功能之后,可以訪問:http:localhost/druid/index.html打來控制台,輸入設定的用戶名和密碼登錄,在控制台中,可以實時的查看數據庫連接池的狀態,每一個被執行的SQL語句使用的情況和花費的時間,並發數量等,以及一個URI請求的次數,時間和並發數量等情況;

這就為我們分析一個應用系統中訪問數據庫的情況和性能提供了可靠地、詳細的原始數據,可以在一些基礎的細節上修改和優化一個應用訪問數據庫的設計;

一定要注意:這里密碼是使用@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填入配置文件中即可完成。

 

 

參考文章:

https://blog.csdn.net/qq_34083066/article/details/80620886

 


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM