SpringBoot默认链接数据库的数据源是:org.apache.tomcat.jdbc.pool.DataSource,如果我们想换成阿里的Druid数据源,应该怎么集成呢?

Druid数据源依赖引入

1
2
3
4
5
6
<!--druid数据源-->
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>druid</artifactId>
<version>1.1.0</version>
</dependency>

注意:好多同学在这里应用了上面这个包,在sql监控页面上看不到SQL执行的记录等相关数据,这里我们必须引入下面的springboot的依赖包,然后重新编译启动项目,此时在进行sql操作后去再去sql监控页面,就可以看到druid监控SQL执行的记录等相关数据了。

1
2
3
4
5
6
<!--druid数据源-->
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>druid-spring-boot-starter</artifactId>
<version>1.1.1</version>
</dependency>

提示:虽然引入第一个包对于正常使用durid连接池功能上没问题,但是在druid的监控功能上会有些功能异常,比如sql监控功能

Druid数据源配置文件

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
spring.datasource.type=com.alibaba.druid.pool.DruidDataSource
spring.datasource.url=jdbc:mysql://localhost:3306/boot
spring.datasource.username=root
spring.datasource.password=admin
# 下面为连接池的补充设置,应用到上面所有数据源中
# 初始化大小,最小,最大
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,并且指定每个连接上PSCache的大小
spring.datasource.poolPreparedStatements=true
spring.datasource.maxPoolPreparedStatementPerConnectionSize=20
# 配置监控统计拦截的filters,去掉后监控界面sql无法统计,'wall'用于防火墙
spring.datasource.filters=stat,wall,log4j
# 通过connectProperties属性来打开mergeSql功能;慢SQL记录
spring.datasource.connectionProperties=druid.stat.mergeSql=true;druid.stat.slowSqlMillis=5000
# 合并多个DruidDataSource的监控数据
#spring.datasource.useGlobalDataSourceStat=true

Druid数据源监控统计配置

在程序中编写一个配置类,并且添加@Configuration注解,使能够被扫描到。

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
package com.maxbill.core.config.datasource;

import com.alibaba.druid.support.http.StatViewServlet;
import com.alibaba.druid.support.http.WebStatFilter;
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;

/**
* @功能 阿里druid数据源配置
* @作者 zuoshuai(MaxBill)
* @日期 2017/7/6
* @时间 13:50
* @备注 DruidConfig
*/
@Configuration
public class DruidConfig {

/**
* 注册DruidStatViewServle1
*/
@Bean
public ServletRegistrationBean DruidStatViewServle1() {
//org.springframework.boot.context.embedded.ServletRegistrationBean提供类的进行注册.
ServletRegistrationBean servletRegistrationBean = new ServletRegistrationBean(new StatViewServlet(), "/druid/*");
//Ip白名单
servletRegistrationBean.addInitParameter("allow", "127.0.0.1");
//IP黑名单(存在共同时,deny优先于allow)
servletRegistrationBean.addInitParameter("deny", "192.168.1.1");
//登录查看信息的账号密码
servletRegistrationBean.addInitParameter("loginUsername", "admin");
servletRegistrationBean.addInitParameter("loginPassword", "123456");
//是否能够重置数据
servletRegistrationBean.addInitParameter("resetEnable", "false");
return servletRegistrationBean;
}

/**
* 注册druidStatFilter
*/
@Bean
public FilterRegistrationBean druidStatFilter() {
FilterRegistrationBean filterRegistrationBean = new FilterRegistrationBean(new WebStatFilter());
//添加过滤规则
filterRegistrationBean.addUrlPatterns("/*");
//添加不需要忽略的格式信息.
filterRegistrationBean.addInitParameter("exclusions", "*.js,*.gif,*.jpg,*.png,*.css,/druid/*");
return filterRegistrationBean;
}

}

配置完成后,http://127.0.0.1:8080/druid/index.html即可打开监控登陆页面,登陆成功即可查看数据源的各种监控,sql监控和统计信息
注:还有一种方式是将配置文件的信息直接在硬编码在程序中,如果配置文件个代码中都做了配置,程序中的优先级高,配置文件中的失效。个人推荐在配置文件中配置,不在程序中硬编码。在程序中配置的方式(在上面的配置类注入数据源即可)如下:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
/**
* 注册dataSouce,推荐在配置文件中
*/
@Bean
public DataSource druidDataSource() {
DruidDataSource druidDataSource = new DruidDataSource();
druidDataSource.setDriverClassName("");
druidDataSource.setUrl("");
druidDataSource.setUsername("");
druidDataSource.setPassword("");
try {
druidDataSource.setFilters("stat, wall");
} catch (SQLException e) {
e.printStackTrace();
}
return druidDataSource;
}