一、簡介
Druid是阿里開源的一個JDBC應用組件, 其包括三部分:
-
DruidDriver: 代理Driver,能夠提供基於Filter-Chain模式的插件體系。
-
DruidDataSource: 高效可管理的數據庫連接池。
-
SQLParser: 實用的SQL語法分析
通過Druid連接池中間件, 我們可以實現:
-
可以監控數據庫訪問性能,Druid內置提供了一個功能強大的StatFilter插件,能夠詳細統計SQL的執行性能,這對於線上分析數據庫訪問性能有幫助。
-
替換傳統的DBCP和C3P0連接池中間件。Druid提供了一個高效、功能強大、可擴展性好的數據庫連接池。
-
數據庫密碼加密。直接把數據庫密碼寫在配置文件中,容易導致安全問題。DruidDruiver和DruidDataSource都支持PasswordCallback。
-
SQL執行日志,Druid提供了不同的LogFilter,能夠支持Common-Logging、Log4j和JdkLog,你可以按需要選擇相應的LogFilter,監控你應用的數據庫訪問情況。
-
擴展JDBC,如果你要對JDBC層有編程的需求,可以通過Druid提供的Filter-Chain機制,很方便編寫JDBC層的擴展插件
<p>更多詳細信息參考官方文檔:<a href="https://github.com/alibaba/druid/wiki">https://github.com/alibaba/druid/wiki</a></p> </li>
Druid Spring Boot Starter 是阿里官方提供的 Spring Boot 插件,用於幫助在Spring Boot項目中輕松集成Druid數據庫連接池和監控。
更多資料參考:
Druid: https://github.com/alibaba/druid
Druid Spring Starter: https://github.com/alibaba/druid/tree/master/druid-spring-boot-starter
二、搭建demo
(1)創建項目
創建spring boot項目
(2)依賴
-
<?xml version="1.0" encoding="UTF-8"?>
-
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
-
xsi:schemaLocation=
"http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
-
<modelVersion>4.0.0
</modelVersion>
-
<parent>
-
<groupId>org.springframework.boot
</groupId>
-
<artifactId>spring-boot-starter-parent
</artifactId>
-
<version>2.1.7.RELEASE
</version>
-
<relativePath/>
<!-- lookup parent from repository -->
-
</parent>
-
<groupId>com.zzq
</groupId>
-
<artifactId>sping-data-monitor
</artifactId>
-
<version>0.0.1-SNAPSHOT
</version>
-
<name>sping-data-monitor
</name>
-
<description>Demo project for Spring Boot
</description>
-
-
<properties>
-
<project.build.sourceEncoding>UTF-8
</project.build.sourceEncoding>
-
<project.reporting.outputEncoding>UTF-8
</project.reporting.outputEncoding>
-
<java.version>1.8
</java.version>
-
</properties>
-
-
<dependencies>
-
<dependency>
-
<groupId>com.alibaba
</groupId>
-
<artifactId>druid
</artifactId>
-
<version>1.1.10
</version>
-
</dependency>
-
<!--修改MySQL驅動版本-->
-
<dependency>
-
<groupId>mysql
</groupId>
-
<artifactId>mysql-connector-java
</artifactId>
-
<version>5.1.47
</version>
-
<scope>runtime
</scope>
-
</dependency>
-
</dependencies>
-
<build>
-
<plugins>
-
<plugin>
-
<groupId>org.springframework.boot
</groupId>
-
<artifactId>spring-boot-maven-plugin
</artifactId>
-
</plugin>
-
</plugins>
-
</build>
-
-
</project>
(3)application.properties配置
-
application:
-
name: sping-data-monitor
# 暴露微服務名稱
-
#數據庫配置
-
# 驅動配置信息
-
spring.datasource.type=com.alibaba.druid.pool.DruidDataSource
-
spring.datasource.url=jdbc:mysql://localhost:3306/
test?useUnicode=
true&characterEncoding=UTF-8&useSSL=
false&zeroDateTimeBehavior=convertToNull
-
spring.datasource.username=root
-
spring.datasource.password=root
-
spring.datasource.driver-class-name=com.mysql.jdbc.Driver
-
-
# 連接池的配置信息
-
# 初始化大小,最小,最大
-
spring.datasource.initialSize=3
-
spring.datasource.minIdle=5
-
spring.datasource.maxActive=20
-
-
# 配置獲取連接等待超時的時間
-
spring.datasource.maxWait=30000
-
# 配置間隔多久才進行一次檢測,檢測需要關閉的空閑連接,單位是毫秒
-
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,並且指定每個連接上PSCache的大小
-
spring.datasource.poolPreparedStatements=
true
-
spring.datasource.maxPoolPreparedStatementPerConnectionSize=20
-
# 配置監控統計攔截的filters,去掉后監控界面sql無法統計,'wall'用於防火牆
-
spring.datasource.filters=
stat,wall
-
# 通過connectProperties屬性來打開mergeSql功能;慢SQL記錄
-
spring.datasource.connectionProperties=druid.stat.mergeSql=
true;druid.stat.slowSqlMillis=10000
-
(4)DruidDBConfig
-
package com.zzq.config;
-
-
import com.alibaba.druid.pool.DruidDataSource;
-
import org.slf4j.Logger;
-
import org.slf4j.LoggerFactory;
-
import org.springframework.beans.factory.
annotation.Value;
-
import org.springframework.context.
annotation.Bean;
-
import org.springframework.context.
annotation.Configuration;
-
import org.springframework.context.
annotation.Primary;
-
-
import javax.sql.DataSource;
-
import java.sql.SQLException;
-
-
-
@Configuration
-
public
class DruidDBConfig {
-
-
private Logger logger = LoggerFactory.getLogger(DruidDBConfig.
class);
-
-
@Value("${spring.datasource.url}")
-
private String dbUrl;
-
-
@Value("${spring.datasource.username}")
-
private String username;
-
-
@Value("${spring.datasource.password}")
-
private String password;
-
-
@Value("${spring.datasource.driver-class-name}")
-
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.poolPreparedStatements}")
-
private boolean poolPreparedStatements;
-
-
@Value("${spring.datasource.maxPoolPreparedStatementPerConnectionSize}")
-
private int maxPoolPreparedStatementPerConnectionSize;
-
-
@Value("${spring.datasource.filters}")
-
private String filters;
-
-
@Value("{spring.datasource.connectionProperties}")
-
private String connectionProperties;
-
-
/**
-
* @Bean 聲明,DataSource 對象為 Spring 容器所管理;
-
* @Primary 表示這里定義的DataSource將覆蓋其他來源的DataSource。
-
* StatFilter,用於統計監控信息。StatFilter的別名是stat。
-
* 統計SQL信息,合並統計。mergeStat是的MergeStatFilter縮寫。
-
* 通過 DataSource 的屬性<property name="filters" value="mergeStat" /> 或者
-
* connectProperties屬性來打開mergeSql功能 <property name="connectionProperties" value="druid.stat.mergeSql=true" />
-
* StatFilter屬性slowSqlMillis用來配置SQL慢的標准
-
*
-
* @return
-
*/
-
@Bean
-
@Primary
-
public DataSource dataSource() {
-
DruidDataSource datasource = new DruidDataSource();
-
datasource.setUrl(dbUrl);
-
datasource.setDriverClassName(driverClassName);
-
datasource.setUsername(username);
-
datasource.setPassword(password);
-
-
//configuration
-
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.setPoolPreparedStatements(poolPreparedStatements);
-
datasource.setMaxPoolPreparedStatementPerConnectionSize(maxPoolPreparedStatementPerConnectionSize);
-
try {
-
/**
-
* 設置StatFilter,用於統計監控信息。
-
* StatFilter的別名是stat
-
*
-
*/
-
datasource.setFilters(filters);
-
}
catch (SQLException e) {
-
logger.error(
"druid configuration initialization filter : {0}",e);
-
}
-
datasource.setConnectionProperties(connectionProperties);
-
-
return datasource;
-
}
-
-
}
(5)DruidStatFilter
-
package
com
.zzq
.filter;
-
-
import
com
.alibaba
.druid
.support
.http
.WebStatFilter;
-
-
import
javax
.servlet
.annotation
.WebFilter;
-
import
javax
.servlet
.annotation
.WebInitParam;
-
-
/**
-
* WebStatFilter用於采集web-jdbc關聯監控的數據。
-
* 屬性filterName聲明過濾器的名稱,可選
-
* 屬性urlPatterns指定要過濾 的URL模式,也可使用屬性value來聲明.(指定要過濾的URL模式是必選屬性)
-
*/
-
-
@
WebFilter(
-
urlPatterns =
"/sping-data-monitor/*",
-
initParams = {
-
@
WebInitParam(
name =
"exclusions",value =
"*.js,*.gif,*.jpg,*.png,*.css,*.ico,/druid/*")
-
}
-
)
-
public class DruidStatFilter extends WebStatFilter {
-
}
(6)DruidStatViewServlet
-
package com.zzq.servlet;
-
-
import com.alibaba.druid.support.http.StatViewServlet;
-
-
import javax.servlet.
annotation.WebInitParam;
-
import javax.servlet.
annotation.WebServlet;
-
-
/**
-
* StatViewServlet用於展示Druid的統計信息。
-
* 提供監控信息展示的html頁面
-
* 提供監控信息的JSON API
-
*
-
* 內置監控頁面的首頁是/druid/index.html
-
*
-
*/
-
-
/**
-
* @Webservlet
-
* 有兩個屬性可以用來表示Servlet的訪問路徑,分別是value和urlPatterns。value和urlPatterns都是數組形式,
-
* 表示我們可以把一個Servlet映射到多個訪問路徑,但是value和urlPatterns不能同時使用。
-
*
-
*/
-
@WebServlet(
-
urlPatterns = {"/druid/*"},//#監控地址,默認 /druid/*
-
initParams = {
-
@WebInitParam(name = "loginUsername", value = "admin"),
//#登錄用戶名
-
@WebInitParam(name = "loginPassword", value = "admin"),
//#登錄密碼
-
@WebInitParam(name = "resetEnable", value = "false"),
-
// @WebInitParam(name = "allow", value = "127.0.0.1") #IP 白名單
-
}
-
)
-
public
class DruidStatViewServlet extends StatViewServlet {
-
}
(7)啟動類
-
package com.zzq;
-
-
import org.springframework.boot.SpringApplication;
-
import org.springframework.boot.autoconfigure.SpringBootApplication;
-
import org.springframework.boot.web.servlet.ServletComponentScan;
-
-
@SpringBootApplication
-
@ServletComponentScan(basePackages = {
"com.zzq.**.servlet"})
-
public
class SpingDataMonitorApplication {
-
-
public static void main(String[] args) {
-
SpringApplication.run(SpingDataMonitorApplication.class, args);
-
}
-
-
}
(8)效果
http://localhost:8080/druid/login.html
用戶名/密碼 admin/admin