SpringBoot集成Druid

93

介绍

  • Druid是阿里开源的连接池组件。
  • 内置监控页面

常见问题

基本配置参数

配置 缺省值 说明
name 配置这个属性的意义在于，如果存在多个数据源，监控的时候可以通过名字来区分开来。 如果没有配置，将会生成一个名字，格式是：“DataSource-” + System.identityHashCode(this)
jdbcUrl 连接数据库的url，不同数据库不一样。例如： mysql : jdbc:mysql://10.20.153.104:3306/druid2 oracle : jdbc:oracle:thin:@10.20.149.85:1521:ocnauto
username 连接数据库的用户名
password 连接数据库的密码。如果你不希望密码直接写在配置文件中，可以使用ConfigFilter。详细看这里：https://github.com/alibaba/druid/wiki/%E4%BD%BF%E7%94%A8ConfigFilter
driverClassName 根据url自动识别 这一项可配可不配，如果不配置druid会根据url自动识别dbType，然后选择相应的driverClassName(建议配置下)
initialSize 0 初始化时建立物理连接的个数。初始化发生在显示调用init方法，或者第一次getConnection时
maxActive 8 最大连接池数量
maxIdle 8 已经不再使用，配置了也没效果
minIdle 最小连接池数量
maxWait 获取连接时最大等待时间，单位毫秒。配置了maxWait之后，缺省启用公平锁，并发效率会有所下降，如果需要可以通过配置useUnfairLock属性为true使用非公平锁。
poolPreparedStatements false 是否缓存preparedStatement，也就是PSCache。PSCache对支持游标的数据库性能提升巨大，比如说oracle。在mysql下建议关闭。
maxOpenPreparedStatements -1 要启用PSCache，必须配置大于0，当大于0时，poolPreparedStatements自动触发修改为true。在Druid中，不会存在Oracle下PSCache占用内存过多的问题，可以把这个数值配置大一些，比如说100
validationQuery 用来检测连接是否有效的sql，要求是一个查询语句。如果validationQuery为null，testOnBorrow、testOnReturn、testWhileIdle都不会其作用。
testOnBorrow true 申请连接时执行validationQuery检测连接是否有效，做了这个配置会降低性能。
validationQueryTimeout 单位：秒，检测连接是否有效的超时时间。底层调⽤用jdbc Statement对象的void setQueryTimeout(int seconds)⽅方法
testOnReturn false 归还连接时执行validationQuery检测连接是否有效，做了这个配置会降低性能
testWhileIdle false 建议配置为true，不影响性能，并且保证安全性。申请连接的时候检测，如果空闲时间大于timeBetweenEvictionRunsMillis，执行validationQuery检测连接是否有效。
timeBetweenEvictionRunsMillis 1分钟（1.0.14） 有两个含义： 1) Destroy线程会检测连接的间隔时间2) testWhileIdle的判断依据，详细看testWhileIdle属性的说明
numTestsPerEvictionRun 不再使用，一个DruidDataSource只支持一个EvictionRun
minEvictableIdleTimeMillis 30分钟（1.0.14） 连接保持空闲⽽而不不被驱逐的最⻓长时间
connectionInitSqls 物理连接初始化的时候执行的sql
exceptionSorter 根据dbType自动识别 当数据库抛出一些不可恢复的异常时，抛弃连接
filters 属性类型是字符串，通过别名的方式配置扩展插件，常用的插件有： 监控统计用的filter:stat日志用的filter:log4j防御sql注入的filter:wall
proxyFilters 类型是List<com.alibaba.druid.filter.
maxPoolPreparedStatementPerConnectionSize 10 要启⽤用PSCache，必须配置⼤大于0，当⼤大于0时poolPreparedStatements自动触发修改为true。单个connnection独享⼀一个statement cache，也就是说maxOpenPreparedStatements是针对单个connection链接的

连接池运行原理

  • 连接池初始化的时候按照initialSize创建多个连接
  • 有DB操作访问的时候，就从里面取一个
  • 如果当前正在使用的连接=maxActive,就会进入等待，没有到maxActive拿一个空闲连接，没有空闲就创建一个新连接，等待超过maxWati则会报错
  • 使用完毕还回去等待其它人用，不会物理销毁
  • 每一个connection在连接池里都有空闲时长的，允许最大空闲时长：minEvictableldleTimeMillis,多久检测一次：timeBetweenEvictionRunsMillis
  • maxActive如何配置：理论上应该设置成最大并发数
  • 只要连接被前端业务拿到就算不空闲了，这个时候如果说长时间占有连接，连接数是不会崩溃，连接池主动关闭是使用中的连接，属于一个高级功能

SpringBoot 集成Druid

pom添加依赖

1
2
3
4
5
<dependency>
	<groupId>com.alibaba</groupId>
	<artifactId>druid</artifactId>
	<version>1.1.22</version>
</dependency>

编写application.yaml

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
spring:
  #配置数据源
  datasource:
    ############################## 本地 ###########################################
    #    url: jdbc:mysql://localhost:3306/OnlyDream?useUnicode=true&characterEncoding=UTF-8
    #    username: OnlyDream
    #    password: 123456
    ############################## 阿里云 ###########################################
    url: jdbc:mysql://localhost:3306/OnlyDream?useUnicode=true&characterEncoding=UTF-8
    username: 用户名
    password: 密码
    type: com.alibaba.druid.pool.DruidDataSource
    #Spring Boot 默认是不注入这些属性值的，需要自己绑定
    #druid 数据源专有配置
    initialSize: 5 #初始化连接数
    minIdle: 5 #最小连接数
    maxActive: 20 #最大连接数
    maxWait: 60000 #获取连接时最大等待时间，单位毫秒
    timeBetweenEvictionRunsMillis: 60000 # 1.Destroy线程会检测连接的间隔时间 2.testWhileIdle的判断依据
    minEvictableIdleTimeMillis: 300000 #连接保持空闲⽽而不不被驱逐的最⻓长时间
    validationQuery: SELECT 1 FROM DUAL #用来检测连接是否有效的sql，要求是一个查询语句
    testWhileIdle: true #建议配置为true，不影响性能，并且保证安全性。申请连接的时候检测，如果空闲时间大于timeBetweenEvictionRunsMillis，执行validationQuery检测连接是否有效
    testOnBorrow: false #申请连接时执行validationQuery检测连接是否有效，做了这个配置会降低性能。
    testOnReturn: false #归还连接时执行validationQuery检测连接是否有效，做了这个配置会降低性能
    # 是否缓存preparedStatement，也就是PSCache。PSCache对支持游标的数据库性能提升巨大，比如说oracle。在mysql下建议关闭
    poolPreparedStatements: false
    #配置监控统计拦截的filters，stat:监控统计、log4j：日志记录、wall：防御sql注入
    #如果运行时报错  java.lang.ClassNotFoundException: org.apache.log4j.Priority
    #则导入 log4j 依赖即可，Maven 地址： https://mvnrepository.com/artifact/log4j/log4j
    filters: stat,wall,slf4j,config
    #指定每个连接上PSCache的大小
    maxPoolPreparedStatementPerConnectionSize: 20
    #合并多个DruidDataSource的监控数据
    useGlobalDataSourceStat: true
    # 加密公钥
    # connectionProperties: config.decrypt=true;config.decrypt.key=公钥

编写配置类

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
53
54
@SpringBootApplication
public class DruidApplication {

    /**
     * 注册DruidServlet
     *
     * @return
     */
    @Bean
    public ServletRegistrationBean druidServletRegistrationBean() {
        ServletRegistrationBean servletRegistrationBean = new ServletRegistrationBean();
        servletRegistrationBean.setServlet(new StatViewServlet());
        servletRegistrationBean.addUrlMappings("/druid/*");
        /** 初始化参数配置，initParams**/
        //白名单
//        servletRegistrationBean.addInitParameter("allow", "127.0.0.1");
        //IP黑名单 (存在共同时，deny优先于allow) : 如果满足deny的话提示:Sorry, you are not permitted to view this page.
//        servletRegistrationBean.addInitParameter("deny", "192.168.1.73");
        //登录查看信息的账号密码.
        servletRegistrationBean.addInitParameter("loginUsername", "admin");
        servletRegistrationBean.addInitParameter("loginPassword", "123456");
        //是否能够重置数据.
        servletRegistrationBean.addInitParameter("resetEnable", "false");
        servletRegistrationBean.addInitParameter("principalSessionName","USER_SESSION");
        return servletRegistrationBean;
    }

    /**
     * 注册DruidFilter拦截
     *
     * @return
     */
    @Bean
    public FilterRegistrationBean duridFilterRegistrationBean() {
        FilterRegistrationBean filterRegistrationBean = new FilterRegistrationBean();
        filterRegistrationBean.setFilter(new WebStatFilter());
        Map<String, String> initParams = new HashMap<String, String>();
        //设置忽略请求
        initParams.put("exclusions", "*.js,*.gif,*.jpg,*.bmp,*.png,*.css,*.ico,/druid/*");
        filterRegistrationBean.setInitParameters(initParams);
        filterRegistrationBean.addUrlPatterns("/*");
        return filterRegistrationBean;
    }


    @ConfigurationProperties(prefix = "spring.datasource")
    @Bean
    public DataSource druidDataSource(){
        return new DruidDataSource();
    }


}

启动项目

启动项目，访问 http://localhost:8080/druid/login.html 打开Druid的监控登录界面

数据库密码加密

  1. 在本地maven仓库中找到druid的jar包,执行
1
java -cp druid-1.1.22.jar com.alibaba.druid.filter.config.ConfigTools 你的密码
  1. 执行完会生成privateKey私钥，publicKey公钥，password密码
privateKey:MIIBVQIBADANBgkqhkiG9w0BAQEFAASCAT8wggE7AgEAAkEAxJkUaiETWFThsOr4WWGdVRnDEwp68256PkT3l+ukzP3Il4MQ2sBcN00jjMyHUqYgXWl4k3fs2xozMwT2AJHKVwIDAQABAkB9ZQpBWxFksNc3Kdf34qwgYIstNO0RIbE00HZ/3txBpql1bN21GLPqgyahlJeemlJh3zesiZp/8hnxOPTOUYH5AiEA+uiiDWI58GvGgE+ib/BxyGpukWk36vUQQkgOcOvBbx0CIQDIllMoGBV7zXFByppMeTz3crQx8yePJSIjgiDq+ynhAwIhANfU+2lV4I8uto8zcYCnLcl/vGL7Rq2nZvgNMdbzBe8FAiB2veaEOZ2eKEP/enxVAQBCS7i4SQUGDCllc8cg04Y7GQIhAPnRJL/c9WK+nGqQaQ9kJY+o+EJAI6hZhe9jri2CEhPk
publicKey:MFwwDQYJKoZIhvcNAQEBBQADSwAwSAJBAMSZFGohE1hU4bDq+FlhnVUZwxMKevNuej5E95frpMz9yJeDENrAXDdNI4zMh1KmIF1peJN37NsaMzME9gCRylcCAwEAAQ==
password:ICc2qWcdB4bb5hBJVyVp2Mr51DB2/tUhhAlvLoEp+L1X1T+f66qfLgCtFNq7aBoK5EjSGvp4sSbHhrGjOEMsjA==
  1. 修改yml中Druid的配置
1
2
password: ICc2qWcdB4bb5hBJVyVp2Mr51DB2/tUhhAlvLoEp+L1X1T+f66qfLgCtFNq7aBoK5EjSGvp4sSbHhrGjOEMsjA==
connectionProperties: config.decrypt=true;config.decrypt.key=MFwwDQYJKoZIhvcNAQEBBQADSwAwSAJBAMSZFGohE1hU4bDq+FlhnVUZwxMKevNuej5E95frpMz9yJeDENrAXDdNI4zMh1KmIF1peJN37NsaMzME9gCRylcCAwEAAQ==
目录
豫ICP备2021003891号-1鄂公网安备42011502001761号Email: v-kun@foxmail.com