簡介:
Druid是阿里巴巴開源的數(shù)據(jù)庫連接池稿黍,號稱是Java語言中最好的數(shù)據(jù)庫連接池,能夠提供強(qiáng)大的監(jiān)控和擴(kuò)展功能慨蛙。
GitHub地址:https://github.com/alibaba/druid。
優(yōu)點
- 可以監(jiān)控數(shù)據(jù)庫訪問性能,Druid內(nèi)置提供了一個功能強(qiáng)大的
StatFilter
插件锚烦,能夠詳細(xì)統(tǒng)計SQL的執(zhí)行性能,這對于線上分析數(shù)據(jù)庫訪問性能有幫助帝雇。 - 替換DBCP和C3P0涮俄,Druid提供了一個高效、功能強(qiáng)大尸闸、可擴(kuò)展性好的數(shù)據(jù)庫連接池彻亲。
- 數(shù)據(jù)庫密碼加密孕锄。直接把數(shù)據(jù)庫密碼寫在配置文件中,這是不好的行為苞尝,容易導(dǎo)致安全問題畸肆。DruidDriver和DruidDataSource都支持PasswordCallback。
-
SQL執(zhí)行日志宙址,Druid提供了不同的
LogFilter
轴脐,能夠支持Common-Logging、Log4j和JdkLog抡砂,你可以按需要選擇相應(yīng)的LogFilter大咱,監(jiān)控你應(yīng)用的數(shù)據(jù)庫訪問情況。 - 擴(kuò)展JDBC注益,如果你要對JDBC層有編程的需求碴巾,可以通過Druid提供的Filter-Chain機(jī)制,很方便編寫JDBC層的擴(kuò)展插件丑搔。
Demo例子
新建項目
引入依賴
Druid 0.1.18
之后版本都發(fā)布到maven中央倉庫中厦瓢,所以你只需要在項目的pom.xml
中加上dependency就可以了。例如:
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>druid</artifactId>
<version>1.1.9</version>
</dependency>
添加log4j的依賴
<dependency>
<groupId>log4j</groupId>
<artifactId>log4j</artifactId>
<version>1.2.17</version>
</dependency>
配置數(shù)據(jù)源application.properties
server.port=8080
# ==============================
# MySQL connection config
# ==============================
spring.datasource.url=jdbc:mysql://localhost:3306/wenda?useUnicode=true&characeterEncoding=utf-8&serverTimezone=UTC
spring.datasource.username=root
spring.datasource.password=123456
#Druid會自動跟url識別驅(qū)動類名啤月,如果連接的數(shù)據(jù)庫非常見數(shù)據(jù)庫旷痕,配置屬性driverClassName
# ==============================
# Druid 數(shù)據(jù)源專用配置
# ==============================
# 初始化大小,最小顽冶,最大
spring.datasource.initialSize=3
spring.datasource.minIdle=5
spring.datasource.maxActive=20
# 配置獲取連接等待超時的時間
spring.datasource.maxWait=30000
# 配置間隔多久才進(jìn)行一次檢測欺抗,檢測需要關(guān)閉的空閑連接,單位是毫秒
spring.datasource.timeBetweenEvictionRunsMillis=60000
# 配置一個連接在池中最小生存的時間强重,單位是毫秒
spring.datasource.minEvictableIdleTimeMillis=300000
spring.datasource.maxEvictableIdleTimeMillis=900000
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
# 配置監(jiān)控統(tǒng)計攔截的filters,去掉后監(jiān)控界面sql無法統(tǒng)計间景,'wall'用于防火墻
spring.datasource.filters=stat,wall,log4j
# 通過connectProperties屬性來打開mergeSql功能佃声;慢SQL記錄
# 合并多個DruidDataSource的監(jiān)控數(shù)據(jù)
#spring.datasource.useGlobalDataSourceStat=true
# 通過connectProperties屬性來打開mergeSql功能;慢SQL記錄
spring.datasource.connectionProperties=druid.stat.mergeSql=true;druid.stat.slowSqlMillis=10000
# ==============================
# Thymeleaf configurations
# ==============================
spring.thymeleaf.mode=HTML
spring.thymeleaf.cache=false
spring.thymeleaf.servlet.content-type=text/html
spring.thymeleaf.encoding=UTF-8
# ==============================
# jpa configurations
# ==============================
#配置指明在程序啟動的時候要刪除并且創(chuàng)建實體類對應(yīng)的表倘要。這個參數(shù)很危險圾亏,
#因為他會把對應(yīng)的表刪除掉然后重建。所以千萬不要在生成環(huán)境中使用封拧。只有在測試環(huán)境中志鹃,一開始初始化數(shù)據(jù)庫結(jié)構(gòu)的時候才能使用一次。
#過后使用update
#spring.jpa.hibernate.ddl-auto=create
spring.jpa.hibernate.ddl-auto=update
# 配置在日志中打印出執(zhí)行的 SQL 語句信息泽西。
#spring.jpa.show-sql=true
#默認(rèn)的存儲引擎切換為 InnoDB
spring.jpa.database-platform=org.hibernate.dialect.MySQL57InnoDBDialect
暫時關(guān)閉Security
在Application
啟動類上(或者任意@Configure
配置類上)增加如下注解:
@EnableAutoConfiguration(exclude = {
org.springframework.boot.autoconfigure.security.servlet.SecurityAutoConfiguration.class
})
數(shù)據(jù)源配置DruidConfig
類:
在Spring中使用Druid數(shù)據(jù)源非常簡單方便曹铃,只需要創(chuàng)建一個DruidDataSource
類型的數(shù)據(jù)源并將其納入到Spring容器中進(jìn)行管理即可。
package com.wg.securitydemo.config;
import com.alibaba.druid.pool.DruidDataSource;
import org.springframework.context.annotation.Configuration;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Primary;
import javax.sql.DataSource;
import java.sql.SQLException;
@Configuration
public class DruidDBConfig {
@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.maxEvictableIdleTimeMillis}")
private int maxEvictableIdleTimeMillis;
@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秘血,用于統(tǒng)計監(jiān)控信息。StatFilter的別名是stat评甜。
* 統(tǒng)計SQL信息灰粮,合并統(tǒng)計。mergeStat是的MergeStatFilter縮寫忍坷。
* 通過 DataSource 的屬性<property name="filters" value="mergeStat" /> 或者
* connectProperties屬性來打開mergeSql功能 <property name="connectionProperties" value="druid.stat.mergeSql=true" />
* StatFilter屬性slowSqlMillis用來配置SQL慢的標(biāo)準(zhǔn)
* 解決 spring.datasource.filters=stat,wall,log4j 無法正常注冊
* @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.setMinEvictableIdleTimeMillis(maxEvictableIdleTimeMillis);
datasource.setValidationQuery(validationQuery);
datasource.setTestWhileIdle(testWhileIdle);
datasource.setTestOnBorrow(testOnBorrow);
datasource.setTestOnReturn(testOnReturn);
datasource.setPoolPreparedStatements(poolPreparedStatements);
datasource.setMaxPoolPreparedStatementPerConnectionSize(maxPoolPreparedStatementPerConnectionSize);
try {
/**
* 設(shè)置StatFilter粘舟,用于統(tǒng)計監(jiān)控信息。
* StatFilter的別名是stat
*
*/
datasource.setFilters(filters);
} catch (SQLException e) {
System.err.println("druid configuration initialization filter: " + e);
}
datasource.setConnectionProperties(connectionProperties);
return datasource;
}
}
配置Druid監(jiān)控統(tǒng)計功能
基于Druid的Filter-Chain
擴(kuò)展機(jī)制承匣,Druid提供了3個非常有用的具有監(jiān)控統(tǒng)計功能的Filter:
-
StatFilter
用于統(tǒng)計監(jiān)控信息蓖乘; -
WallFilter
基于SQL語義分析來實現(xiàn)防御SQL注入攻擊锤悄; -
LogFilter
用于輸出JDBC執(zhí)行的日志韧骗。
如果在項目中需要使用Druid提供的這些監(jiān)控統(tǒng)計功能,可以通過以下兩種途徑進(jìn)行配置零聚。
①方式一
基于Servlet
注解的配置
對于使用Servlet 3.0的項目袍暴,在啟動類上加上注解
@ServletComponentScan 啟用Servlet自動掃描,
并在自定義的‘DruidStatViewServlet’/‘DruidStatFilter ’上分別加上注解@WebServlet/@WebFilter使其能夠被自動發(fā)現(xiàn)隶症。
DruidStatViewServlet
package com.wg.securitydemo.config;
/*
* druid數(shù)據(jù)源狀態(tài)監(jiān)控.
*/
import com.alibaba.druid.support.http.StatViewServlet;
import javax.servlet.annotation.WebInitParam;
import javax.servlet.annotation.WebServlet;
@WebServlet(urlPatterns = "/druid/*",initParams = {
//IP白名單 沒有配置或者為空則允許所有訪問
@WebInitParam(name="allow",value = "127.0.0.1"),
// IP黑名單 存在共同時政模,deny優(yōu)先于allow
@WebInitParam(name = "deny", value = "192.168.1.10"),
// 用戶名
@WebInitParam(name = "loginUsername", value = "root"),
// 密碼
@WebInitParam(name = "loginPassword", value = "123"),
// 禁用HTML頁面上的“Reset All”功能
@WebInitParam(name = "resetEnable", value = "false")
})
public class DruidStatViewServlet extends StatViewServlet {
}
DruidStatFilter
package com.wg.securitydemo.config;
/*
* druid過濾器
* /**
* WebStatFilter用于采集web-jdbc關(guān)聯(lián)監(jiān)控的數(shù)據(jù)。
* 屬性filterName聲明過濾器的名稱,可選
* 屬性urlPatterns指定要過濾 的URL模式,也可使用屬性value來聲明.(指定要過濾的URL模式是必選屬性)
*/
import com.alibaba.druid.support.http.WebStatFilter;
import javax.servlet.annotation.WebFilter;
import javax.servlet.annotation.WebInitParam;
@WebFilter(filterName = "druidWebStatFilter",urlPatterns = "/*",initParams = {
// 忽略資源
@WebInitParam(name = "exclusions", value = "*.js,*.gif,*.jpg,*.bmp,*.png,*.css,*.ico,/druid/*")
})
public class DruidStatFilter extends WebStatFilter {
}
在啟動類加上@ServletComponentScan
②方式二
使用Spring的注解@Bean對自定義的Servlet或Filter進(jìn)行注冊蚂会,
Servlet使用ServletRegistrationBean進(jìn)行注冊淋样,
Filter使用FilterRegistrationBean進(jìn)行注冊。
package com.wg.securitydemo.config;
import com.alibaba.druid.support.http.StatViewServlet;
import com.alibaba.druid.support.http.WebStatFilter;
import org.springframework.boot.SpringBootConfiguration;
import org.springframework.boot.web.servlet.FilterRegistrationBean;
import org.springframework.boot.web.servlet.ServletRegistrationBean;
import org.springframework.context.annotation.Bean;
@SpringBootConfiguration
public class DruidMonitorConfig {
@Bean
public ServletRegistrationBean servletRegistrationBean() {
System.out.println("init Druid Monitor Servlet ...");
ServletRegistrationBean servletRegistrationBean = new ServletRegistrationBean(new StatViewServlet(),
"/druid/*");
// IP白名單
servletRegistrationBean.addInitParameter("allow", "127.0.0.1");
// IP黑名單(共同存在時胁住,deny優(yōu)先于allow)
servletRegistrationBean.addInitParameter("deny", "192.168.1.10");
// 控制臺管理用戶
servletRegistrationBean.addInitParameter("loginUsername", "root");
servletRegistrationBean.addInitParameter("loginPassword", "123");
// 是否能夠重置數(shù)據(jù) 禁用HTML頁面上的“Reset All”功能
servletRegistrationBean.addInitParameter("resetEnable", "false");
return servletRegistrationBean;
}
@Bean
public FilterRegistrationBean filterRegistrationBean() {
FilterRegistrationBean filterRegistrationBean = new FilterRegistrationBean(new WebStatFilter());
filterRegistrationBean.addUrlPatterns("/*");
filterRegistrationBean.addInitParameter("exclusions", "*.js,*.gif,*.jpg,*.png,*.css,*.ico,/druid/*");
return filterRegistrationBean;
}
}
- 這里我們注釋啟動類的
//@ServletComponentScan
采用第二種方式
配置JPA
新建下面4個文件
Student
package com.wg.securitydemo.model;
import javax.persistence.*;
@Entity
@Table(name = "student")
public class Student {
@Id
@GeneratedValue(strategy = GenerationType.IDENTITY)
private Long id;
private String name;
private String number;
public Student() {
}
public Long getId() {
return id;
}
public void setId(Long id) {
this.id = id;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public String getNumber() {
return number;
}
public void setNumber(String number) {
this.number = number;
}
@Override
public String toString() {
return "Student{" +
"id=" + id +
", name='" + name + '\'' +
", number='" + number + '\'' +
'}';
}
}
StudentDao
package com.wg.securitydemo.dao;
import com.wg.securitydemo.model.Student;
import org.springframework.data.repository.CrudRepository;
import org.springframework.stereotype.Repository;
@Repository
public interface StudentDao extends CrudRepository <Student,Long>{
}
StudentService
package com.wg.securitydemo.service;
import com.wg.securitydemo.dao.StudentDao;
import com.wg.securitydemo.model.Student;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.ArrayList;
@Service
public class StudentService {
@Autowired
StudentDao studentDao;
public Student AddOneStu(Student onestu){
return studentDao.save(onestu);
}
public Iterable<Student> ListStu(){
Iterable<Student> stulist = new ArrayList<>();
stulist = studentDao.findAll();
return stulist;
}
}
StudentController
package com.wg.securitydemo.controller;
import com.wg.securitydemo.model.Student;
import com.wg.securitydemo.service.StudentService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
@Controller
public class StudentController {
@Autowired
StudentService studentService;
@RequestMapping(value = "/add")
@ResponseBody
public Student Add(String stuname,String stunumber){
Student newstu = new Student();
newstu.setId(0L);
newstu.setName(stuname);
newstu.setNumber(stunumber);
studentService.AddOneStu(newstu);
return newstu;
}
@RequestMapping(value = "/list")
@ResponseBody
public Iterable<Student> List(){
return studentService.ListStu();
}
}
測試運行
1.運行成功
2.數(shù)據(jù)庫表建立成功
3.訪問
http://localhost:8080/add?stuname="小王"&stunumber="147852"
用來添加用戶,這里其實不用引號的
4.訪問http://localhost:8080/list
用來查看所有用戶
5.最后訪問
http://localhost:8080/druid/
賬戶密碼在這
大概就是下面這樣的圖
參考文章:https://blog.csdn.net/pengjunlee/article/details/80061797