简介:
Druid是阿里巴巴开源的数据库连接池,号称是Java语言中最好的数据库连接池,能够提供强大的监控和扩展功能。
GitHub地址:https://github.com/alibaba/druid。
优点
- 可以监控数据库访问性能,Druid内置提供了一个功能强大的
StatFilter
插件,能够详细统计SQL的执行性能,这对于线上分析数据库访问性能有帮助。 - 替换DBCP和C3P0,Druid提供了一个高效、功能强大、可扩展性好的数据库连接池。
- 数据库密码加密。直接把数据库密码写在配置文件中,这是不好的行为,容易导致安全问题。DruidDriver和DruidDataSource都支持PasswordCallback。
-
SQL执行日志,Druid提供了不同的
LogFilter
,能够支持Common-Logging、Log4j和JdkLog,你可以按需要选择相应的LogFilter,监控你应用的数据库访问情况。 - 扩展JDBC,如果你要对JDBC层有编程的需求,可以通过Druid提供的Filter-Chain机制,很方便编写JDBC层的扩展插件。
Demo例子
新建项目
引入依赖
Druid 0.1.18
之后版本都发布到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>
配置数据源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识别驱动类名,如果连接的数据库非常见数据库,配置属性driverClassName
# ==============================
# Druid 数据源专用配置
# ==============================
# 初始化大小,最小,最大
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.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
# 配置监控统计拦截的filters,去掉后监控界面sql无法统计,'wall'用于防火墙
spring.datasource.filters=stat,wall,log4j
# 通过connectProperties属性来打开mergeSql功能;慢SQL记录
# 合并多个DruidDataSource的监控数据
#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
# ==============================
#配置指明在程序启动的时候要删除并且创建实体类对应的表。这个参数很危险,
#因为他会把对应的表删除掉然后重建。所以千万不要在生成环境中使用。只有在测试环境中,一开始初始化数据库结构的时候才能使用一次。
#过后使用update
#spring.jpa.hibernate.ddl-auto=create
spring.jpa.hibernate.ddl-auto=update
# 配置在日志中打印出执行的 SQL 语句信息。
#spring.jpa.show-sql=true
#默认的存储引擎切换为 InnoDB
spring.jpa.database-platform=org.hibernate.dialect.MySQL57InnoDBDialect
暂时关闭Security
在Application
启动类上(或者任意@Configure
配置类上)增加如下注解:
@EnableAutoConfiguration(exclude = {
org.springframework.boot.autoconfigure.security.servlet.SecurityAutoConfiguration.class
})
数据源配置DruidConfig
类:
在Spring中使用Druid数据源非常简单方便,只需要创建一个DruidDataSource
类型的数据源并将其纳入到Spring容器中进行管理即可。
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,用于统计监控信息。StatFilter的别名是stat。
* 统计SQL信息,合并统计。mergeStat是的MergeStatFilter缩写。
* 通过 DataSource 的属性<property name="filters" value="mergeStat" /> 或者
* connectProperties属性来打开mergeSql功能 <property name="connectionProperties" value="druid.stat.mergeSql=true" />
* StatFilter属性slowSqlMillis用来配置SQL慢的标准
* 解决 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 {
/**
* 设置StatFilter,用于统计监控信息。
* StatFilter的别名是stat
*
*/
datasource.setFilters(filters);
} catch (SQLException e) {
System.err.println("druid configuration initialization filter: " + e);
}
datasource.setConnectionProperties(connectionProperties);
return datasource;
}
}
配置Druid监控统计功能
基于Druid的Filter-Chain
扩展机制,Druid提供了3个非常有用的具有监控统计功能的Filter:
-
StatFilter
用于统计监控信息; -
WallFilter
基于SQL语义分析来实现防御SQL注入攻击; -
LogFilter
用于输出JDBC执行的日志。
如果在项目中需要使用Druid提供的这些监控统计功能,可以通过以下两种途径进行配置。
①方式一
基于Servlet
注解的配置
对于使用Servlet 3.0的项目,在启动类上加上注解
@ServletComponentScan 启用Servlet自动扫描,
并在自定义的‘DruidStatViewServlet’/‘DruidStatFilter ’上分别加上注解@WebServlet/@WebFilter使其能够被自动发现。
DruidStatViewServlet
package com.wg.securitydemo.config;
/*
* druid数据源状态监控.
*/
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优先于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关联监控的数据。
* 属性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进行注册,
Servlet使用ServletRegistrationBean进行注册,
Filter使用FilterRegistrationBean进行注册。
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优先于allow)
servletRegistrationBean.addInitParameter("deny", "192.168.1.10");
// 控制台管理用户
servletRegistrationBean.addInitParameter("loginUsername", "root");
servletRegistrationBean.addInitParameter("loginPassword", "123");
// 是否能够重置数据 禁用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.数据库表建立成功
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