作者 | 罗晓峥
来源 | urlify.cn/M3qu6r
1.Druid简介
java程序很大一部分要操作数据库,为了提高性能操作数据库的时候,又不得不使用数据库连接池
Druid是阿里巴巴开源平台上一个数据库连接池实现,结合了C3P0、DBCP等DB池的优点,同时加入了日志监控
Druid可以很好的监控DB池连接和SQL的执行情况,天生就是针对监控而生的DB连接池
Druid已经在阿里巴巴部署了超过600个应用,经过一年多生产环境大规模部署的严苛考验。
Spring Boot 2.0以上默认使用Hikari数据源,可以说Hikari与Druid都是当前java web上最优秀的数据源
springboot如何集成Druid数据源,如何实现数据库监控?
Github地址:https://github.com/alibaba/druid/
2.配置数据源
1.添加Druid数据源依赖
com.alibaba druid 1.1.21
2.切换数据源,之前springboot 2.0以上默认使用com.zaxxer.hikari.HikariDataSource数据源,但可以通过spring.datasource.type指定数据源。
spring: datasource: password: root username: root #serverTimezone=UTC解决时区的报错 url: jdbc:mysql://localhost:3306/springboot?serverTimezone=UTC&useUnicode=true&characterEncoding=utf-8 driver-class-name: com.mysql.cj.jdbc.Driver #自定义数据源 type: com.alibaba.druid.pool.DruidDataSource
3.数据源切换后,在测试类中注入DataSource,获取到它输出来看是否切换成功
@SpringBootTestclass SpringbootstudyApplicationTests { //DI注入数据源 @Autowired DataSource dataSource; @Test void contextLoads() throws SQLException { //看一下默认数据源 System.out.println(dataSource.getClass()); //获取连接 Connection connection = dataSource.getConnection(); System.out.println(connection); //关闭连接 connection.close(); }}
4.切换成功,切换成功后就可以设置数据源连接初始化大小,最大连接数,等待时间,最小连接数等设置项;可查看源码
spring: datasource: password: root username: root #serverTimezone=UTC解决时区的报错 url: jdbc:mysql://localhost:3306/springboot?serverTimezone=UTC&useUnicode=true&characterEncoding=utf-8 driver-class-name: com.mysql.cj.jdbc.Driver #自定义数据源 type: com.alibaba.druid.pool.DruidDataSource #springboot默认是不注入这些属性值的,需要自己绑定 #druid 数据源专有配置 initial-size: 5 minIdle: 5 maxActive: 20 maxwait: 60000 timeBetweenEvictionRunsMillis: 60000 minEvictableIdleTimeMillis: 300000 validationQuery: SELECT 1 FROM DUAL testWhileIdle: true testOnBorrow: false testOnReturn: false poolPrepaerdStatements: true #配置监控同级拦截的filters,stat:监控统计、logj4:日志记录、wall:防御sql注入 #如果允许时报错 java.lang.ClassNotFoundException:org.apache.log4j.Priority #则导入log4j依赖即可,Maven地址:https://mvnrepository.com/artifact/log4j/log4j filters: stat,wall,log4j maxPoolPreparedStatementPerCConnectionSize: 20 userGlobalDataSourceStat: true connectionProperties: druid.stat.mergeSql=true;druid.stat.slowSqlMillis=500
5.导入Log4j的依赖
log4j log4j 1.2.17
6.现在需要我们自己为DruidDataSource绑定全局配置文件中的参数,再添加到容器中,而不再使用springboot自动生成;
我们需要自己添加DruidDataSource组件到容器中,并绑定属性
package com.dz.config;import com.alibaba.druid.pool.DruidDataSource;import org.springframework.boot.context.properties.ConfigurationProperties;import org.springframework.context.annotation.Bean;import org.springframework.context.annotation.Configuration;import javax.sql.DataSource;import javax.xml.crypto.Data;@Configurationpublic class DruidConfig { //将自定义的Druid数据源添加到容器中,不在让springboot自动创建 //绑定全局配置文件中的druid数据源属性到com.alibaba.druid.pool.DruidDataSource从而让他们生效 //@ConfigurationProperties(prefix = "spring.datasource")作用就是将全局配置文件中 //前缀为springdatasource的属性值注入到com.alibaba.druid.pool.DruidDataSource的同名参数中 @ConfigurationProperties(prefix = "spring.datasource") @Bean public DataSource druidDataSource(){ return new DruidDataSource(); }}
7.去测试类中测试,看是否成功
@SpringBootTestclass SpringbootstudyApplicationTests { //DI注入数据源 @Autowired DataSource dataSource; @Test void contextLoads() throws SQLException { //看一下默认数据源 System.out.println(dataSource.getClass()); //获取连接 Connection connection = dataSource.getConnection(); System.out.println(connection); DruidDataSource druidDataSource = (DruidDataSource) dataSource; System.out.println("druidDataSource 数据源最大连接数"+druidDataSource.getMaxActive()); System.out.println("druidDataSource 数据源初始化连接数"+druidDataSource.getInitialSize()); //关闭连接 connection.close(); }}
输出结果:可见配置参数已经生效
3.配置Druid数据源监控
Druid数据源具有监控的功能,并提供一个web界面方便用户用户查看,类似安装路由器时,提供一个默认的web页面。
第一步需要设置Druid的后台管理页面,比如登录账号,密码等
配置后台管理
//配置Druid监控管理后台的servlet //内置Servlet容器时没有web.xml文件,所以使用springboot的注册servlet的方式 @Bean public ServletRegistrationBean statViewServlet(){ ServletRegistrationBean bean = new ServletRegistrationBean(new StatViewServlet(), "/druid/*"); //这些参数可以在com.alibaba.druid.support.http.StatViewServlet的父类com.alibaba.druid.support.http.ResourceServlet 中找到 Map initParams = new HashMap<>(); initParams.put("loginUsername","admin");//后台管理界面的登录账号 initParams.put("loginPassword","123456");//后台管理界面的登录密码 //后台允许谁可以访问 //initParams.put("allow","localhost");//表示只有本机可以访问 initParams.put("allow","");//为空或者为null时,表示允许所有访问 //deny:Druid后台拒绝访问谁 initParams.put("dz","192.168.1.20");//表示禁止此ip访问 //设置初始化参数 bean.setInitParameters(initParams); return bean; }
配置完毕后,访问:http://localhost:8080/druid/login.html
进入之后
配置Druid web监控filter过滤器
//配置Druid监控 之 web监控的filter //webStatFiler:用于配置web和Druid数据源之间的管理关联监控统计 @Bean public FilterRegistrationBean webStatFilter(){ FilterRegistrationBean bean = new FilterRegistrationBean(); bean.setFilter(new WebStatFilter()); //exclusions:设置哪些请求进行过滤排除掉,从而不进行统计 Map initParams = new HashMap<>(); initParams.put("exclusions","*.js,*.css,/druid/*,/jdbc/*"); //"/*" 表示过滤所有请求 bean.setUrlPatterns(Arrays.asList("/*")); return bean; }
平时在工作中,按需求进行配置即可,主要用作监控。