springboot 整合Druid

绝地灬酷狼 2022-05-29 11:36 373阅读 0赞
  • springBoot目录

1.Druid

Durid据说是Java语言中最好的一个数据库连接池。能够提供强大的监控和扩展功能。Druid是一个开源项目，源码托管在github上，源代码仓库地址是

[https://github.com/alibaba/druid\](https://github.com/alibaba/druid)

2.如何在Springboot中整合Druid.

项目结构图：

在这里插入图片描述
首先我们需要引入Druid相应的依赖

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

其次在配置文件中配置该连接池（采用yml格式的配置文件）

  1. spring:
  2.   datasource:
  3.       url: jdbc:mysql://localhost/springboot
  4.       driver-class-name: com.mysql.jdbc.Driver
  5.       username: root
  6.       password:
  7.       type: com.alibaba.druid.pool.DruidDataSource
  8.       druid:
  9.         initial-size: 8
  10.       #  filter-class-names: stat
  11.         filters: stat,config
  12.         #初始化连接大小
  13.         initial-size: 8
  14.         #最小空闲连接数
  15.         min-idle: 5
  16.         #最大连接数
  17.         max-active: 10
  18.         #查询超时时间
  19.         query-timeout: 6000
  20.         #事务查询超时时间
  21.         transaction-query-timeout: 6000
  22.         #关闭空闲连接超时时间
  23.         remove-abandoned-timeout: 1800

spring.datasource.type设置所使用的连接池为druid，
spring.datasource.druid.* 配置连接池的各种属性。

注意：关于spring.datasource.type属性
旧版本不支持 1.3.x开始支持，1.4.0不支持，1.4.1及之后都支持
接着要添加druid的支持类，及是项目结构图中的两个类
1.DruidDataSourceProperties

  1. package com.example.springboot.mysqldemo.util.configuration;
  3. import org.springframework.boot.context.properties.ConfigurationProperties;
  5. import java.util.Properties;
  7. @ConfigurationProperties("spring.datasource.druid")
  8. public class DruidDataSourceProperties {
  9.     private Boolean testWhileIdle = true;
  10.     private Boolean testOnBorrow;
  11.     private String validationQuery = "SELECT 1";
  12.     private Boolean useGlobalDataSourceStat;
  13.     private String filters;
  14.     private Long timeBetweenLogStatsMillis;
  15.     private Integer maxSize;
  16.     private Boolean clearFiltersEnable;
  17.     private Boolean resetStatEnable;
  18.     private Integer notFullTimeoutRetryCount;
  19.     private Integer maxWaitThreadCount;
  20.     private Boolean failFast;
  21.     private Boolean phyTimeoutMillis;
  22.     private Long minEvictableIdleTimeMillis = 300000L;
  23.     private Long maxEvictableIdleTimeMillis;
  24.     private Integer initialSize = 5;
  25.     private Integer minIdle = 5;
  26.     private Integer maxActive = 20;
  27.     private Long maxWait = 60000L;
  28.     private Long timeBetweenEvictionRunsMillis = 60000L;
  29.     private Boolean poolPreparedStatements = true;
  30.     private Integer maxPoolPreparedStatementPerConnectionSize = 20;
  31.     private Properties connectionProperties = new Properties() {
  32.    {
  33.         put("druid.stat.mergeSql", "true");
  34.         put("druid.stat.slowSqlMillis", "5000");
  35.     }};
  37.     public Boolean getTestWhileIdle() {
  38.         return testWhileIdle;
  39.     }
  41.     public void setTestWhileIdle(Boolean testWhileIdle) {
  42.         this.testWhileIdle = testWhileIdle;
  43.     }
  45.     public Boolean getTestOnBorrow() {
  46.         return testOnBorrow;
  47.     }
  49.     public void setTestOnBorrow(Boolean testOnBorrow) {
  50.         this.testOnBorrow = testOnBorrow;
  51.     }
  53.     public String getValidationQuery() {
  54.         return validationQuery;
  55.     }
  57.     public void setValidationQuery(String validationQuery) {
  58.         this.validationQuery = validationQuery;
  59.     }
  61.     public Boolean getUseGlobalDataSourceStat() {
  62.         return useGlobalDataSourceStat;
  63.     }
  65.     public void setUseGlobalDataSourceStat(Boolean useGlobalDataSourceStat) {
  66.         this.useGlobalDataSourceStat = useGlobalDataSourceStat;
  67.     }
  69.     public String getFilters() {
  70.         return filters;
  71.     }
  73.     public void setFilters(String filters) {
  74.         this.filters = filters;
  75.     }
  77.     public Long getTimeBetweenLogStatsMillis() {
  78.         return timeBetweenLogStatsMillis;
  79.     }
  81.     public void setTimeBetweenLogStatsMillis(Long timeBetweenLogStatsMillis) {
  82.         this.timeBetweenLogStatsMillis = timeBetweenLogStatsMillis;
  83.     }
  85.     public Integer getMaxSize() {
  86.         return maxSize;
  87.     }
  89.     public void setMaxSize(Integer maxSize) {
  90.         this.maxSize = maxSize;
  91.     }
  93.     public Boolean getClearFiltersEnable() {
  94.         return clearFiltersEnable;
  95.     }
  97.     public void setClearFiltersEnable(Boolean clearFiltersEnable) {
  98.         this.clearFiltersEnable = clearFiltersEnable;
  99.     }
  101.     public Boolean getResetStatEnable() {
  102.         return resetStatEnable;
  103.     }
  105.     public void setResetStatEnable(Boolean resetStatEnable) {
  106.         this.resetStatEnable = resetStatEnable;
  107.     }
  109.     public Integer getNotFullTimeoutRetryCount() {
  110.         return notFullTimeoutRetryCount;
  111.     }
  113.     public void setNotFullTimeoutRetryCount(Integer notFullTimeoutRetryCount) {
  114.         this.notFullTimeoutRetryCount = notFullTimeoutRetryCount;
  115.     }
  117.     public Integer getMaxWaitThreadCount() {
  118.         return maxWaitThreadCount;
  119.     }
  121.     public void setMaxWaitThreadCount(Integer maxWaitThreadCount) {
  122.         this.maxWaitThreadCount = maxWaitThreadCount;
  123.     }
  125.     public Boolean getFailFast() {
  126.         return failFast;
  127.     }
  129.     public void setFailFast(Boolean failFast) {
  130.         this.failFast = failFast;
  131.     }
  133.     public Boolean getPhyTimeoutMillis() {
  134.         return phyTimeoutMillis;
  135.     }
  137.     public void setPhyTimeoutMillis(Boolean phyTimeoutMillis) {
  138.         this.phyTimeoutMillis = phyTimeoutMillis;
  139.     }
  141.     public Long getMinEvictableIdleTimeMillis() {
  142.         return minEvictableIdleTimeMillis;
  143.     }
  145.     public void setMinEvictableIdleTimeMillis(Long minEvictableIdleTimeMillis) {
  146.         this.minEvictableIdleTimeMillis = minEvictableIdleTimeMillis;
  147.     }
  149.     public Long getMaxEvictableIdleTimeMillis() {
  150.         return maxEvictableIdleTimeMillis;
  151.     }
  153.     public void setMaxEvictableIdleTimeMillis(Long maxEvictableIdleTimeMillis) {
  154.         this.maxEvictableIdleTimeMillis = maxEvictableIdleTimeMillis;
  155.     }
  157.     public Integer getInitialSize() {
  158.         return initialSize;
  159.     }
  161.     public void setInitialSize(Integer initialSize) {
  162.         this.initialSize = initialSize;
  163.     }
  165.     public Integer getMinIdle() {
  166.         return minIdle;
  167.     }
  169.     public void setMinIdle(Integer minIdle) {
  170.         this.minIdle = minIdle;
  171.     }
  173.     public Integer getMaxActive() {
  174.         return maxActive;
  175.     }
  177.     public void setMaxActive(Integer maxActive) {
  178.         this.maxActive = maxActive;
  179.     }
  181.     public Long getMaxWait() {
  182.         return maxWait;
  183.     }
  185.     public void setMaxWait(Long maxWait) {
  186.         this.maxWait = maxWait;
  187.     }
  189.     public Long getTimeBetweenEvictionRunsMillis() {
  190.         return timeBetweenEvictionRunsMillis;
  191.     }
  193.     public void setTimeBetweenEvictionRunsMillis(Long timeBetweenEvictionRunsMillis) {
  194.         this.timeBetweenEvictionRunsMillis = timeBetweenEvictionRunsMillis;
  195.     }
  197.     public Boolean getPoolPreparedStatements() {
  198.         return poolPreparedStatements;
  199.     }
  201.     public void setPoolPreparedStatements(Boolean poolPreparedStatements) {
  202.         this.poolPreparedStatements = poolPreparedStatements;
  203.     }
  205.     public Integer getMaxPoolPreparedStatementPerConnectionSize() {
  206.         return maxPoolPreparedStatementPerConnectionSize;
  207.     }
  209.     public void setMaxPoolPreparedStatementPerConnectionSize(Integer maxPoolPreparedStatementPerConnectionSize) {
  210.         this.maxPoolPreparedStatementPerConnectionSize = maxPoolPreparedStatementPerConnectionSize;
  211.     }
  213.     public Properties getConnectionProperties() {
  214.         return connectionProperties;
  215.     }
  217.     public void setConnectionProperties(Properties connectionProperties) {
  218.         this.connectionProperties = connectionProperties;
  219.     }
  221.     public Properties toProperties() {
  222.         Properties properties = new Properties();
  223.         notNullAdd(properties, "testWhileIdle", this.testWhileIdle);
  224.         notNullAdd(properties, "testOnBorrow", this.testOnBorrow);
  225.         notNullAdd(properties, "validationQuery", this.validationQuery);
  226.         notNullAdd(properties, "useGlobalDataSourceStat", this.useGlobalDataSourceStat);
  227.         notNullAdd(properties, "filters", this.filters);
  228.         notNullAdd(properties, "timeBetweenLogStatsMillis", this.timeBetweenLogStatsMillis);
  229.         notNullAdd(properties, "stat.sql.MaxSize", this.maxSize);
  230.         notNullAdd(properties, "clearFiltersEnable", this.clearFiltersEnable);
  231.         notNullAdd(properties, "resetStatEnable", this.resetStatEnable);
  232.         notNullAdd(properties, "notFullTimeoutRetryCount", this.notFullTimeoutRetryCount);
  233.         notNullAdd(properties, "maxWaitThreadCount", this.maxWaitThreadCount);
  234.         notNullAdd(properties, "failFast", this.failFast);
  235.         notNullAdd(properties, "phyTimeoutMillis", this.phyTimeoutMillis);
  236.         notNullAdd(properties, "minEvictableIdleTimeMillis", this.minEvictableIdleTimeMillis);
  237.         notNullAdd(properties, "maxEvictableIdleTimeMillis", this.maxEvictableIdleTimeMillis);
  238.         notNullAdd(properties, "initialSize", this.initialSize);
  239.         notNullAdd(properties, "minIdle", this.minIdle);
  240.         notNullAdd(properties, "maxActive", this.maxActive);
  241.         notNullAdd(properties, "maxWait", this.maxWait);
  242.         notNullAdd(properties, "timeBetweenEvictionRunsMillis", this.timeBetweenEvictionRunsMillis);
  243.         notNullAdd(properties, "poolPreparedStatements", this.poolPreparedStatements);
  244.         notNullAdd(properties, "maxPoolPreparedStatementPerConnectionSize", this.maxPoolPreparedStatementPerConnectionSize);
  245.         return properties;
  246.     }
  248.     private void notNullAdd(Properties properties, String key, Object value) {
  249.         if (value != null) {
  250.             properties.setProperty("druid." + key, value.toString());
  251.         }
  252.     }
  253. }

2.DruidConfiguration

  1. package com.example.springboot.mysqldemo.util.configuration;
  3. import com.alibaba.druid.pool.DruidDataSource;
  4. import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
  5. import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
  6. import org.springframework.boot.autoconfigure.jdbc.DataSourceProperties;
  7. import org.springframework.boot.context.properties.EnableConfigurationProperties;
  8. import org.springframework.context.annotation.Bean;
  9. import org.springframework.context.annotation.Configuration;
  11. @Configuration
  12. @ConditionalOnClass({DruidDataSource.class})
  13. @ConditionalOnProperty(
  14.         name = {"spring.datasource.type"},
  15.         havingValue = "com.alibaba.druid.pool.DruidDataSource",
  16.         matchIfMissing = true
  17. )
  18. @EnableConfigurationProperties(DruidDataSourceProperties.class)
  19. public class DruidConfiguration {
  20.     @Bean
  21.     public DruidDataSource dataSource(DataSourceProperties dataSourceProperties, DruidDataSourceProperties druidDataSourceProperties) {
  22.         DruidDataSource druidDataSource = dataSourceProperties.initializeDataSourceBuilder().type(DruidDataSource.class).build();
  23.         druidDataSource.configFromPropety(druidDataSourceProperties.toProperties());
  24.         druidDataSource.setInitialSize(druidDataSourceProperties.getInitialSize());
  25.         druidDataSource.setMinIdle(druidDataSourceProperties.getMinIdle());
  26.         druidDataSource.setMaxActive(druidDataSourceProperties.getMaxActive());
  27.         druidDataSource.setMaxWait(druidDataSourceProperties.getMaxWait());
  28.         druidDataSource.setConnectProperties(druidDataSourceProperties.getConnectionProperties());
  29.         return druidDataSource;
  30.     }
  32. }

至此druid就整合到springboot中了。

3.Druid的监控配置.

首先配置监控界面的servlet

  1. package com.example.springboot.mysqldemo.util.servlet;
  3. import javax.servlet.annotation.WebInitParam;
  4. import javax.servlet.annotation.WebServlet;
  6. import com.alibaba.druid.support.http.StatViewServlet;
  9. @WebServlet(urlPatterns = { "/druid/*" }, initParams = { @WebInitParam(name = "loginUsername", value = "root"), @WebInitParam(name = "loginPassword", value = "1234") })
  10. public class DruidStatViewServlet extends StatViewServlet {
  12.     private static final long serialVersionUID = 1L;
  14. }

配置过滤器

  1. package com.example.springboot.mysqldemo.util.filter;
  3. import javax.servlet.annotation.WebFilter;
  4. import javax.servlet.annotation.WebInitParam;
  6. import com.alibaba.druid.support.http.WebStatFilter;
  8. /**
  9.  * @author wujing
  10.  */
  11. @WebFilter(filterName = "druidWebStatFilter", urlPatterns = "/*", initParams = { @WebInitParam(name = "exclusions", value = "*.js,*.gif,*.jpg,*.bmp,*.png,*.css,*.ico,/druid/*") })
  12. public class DruidWebStatFilter extends WebStatFilter {
  14. }

最后启动tomact，测试链接http://localhost:8080/druid/login.html
这里写图片描述

但要配置sql监控则在配置文件中添加如下内容

  1. spring.datasource.druid.filters: stat,config

配置spring监控
在resouce文件夹下添加配置文件druid-bean.xml

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <beans xmlns="http://www.springframework.org/schema/beans"
  3.     xmlns:aop="http://www.springframework.org/schema/aop" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  4.     xsi:schemaLocation="
  5.         http://www.springframework.org/schema/beans
  6.         http://www.springframework.org/schema/beans/spring-beans.xsd
  7.         http://www.springframework.org/schema/aop
  8.         http://www.springframework.org/schema/aop/spring-aop.xsd">
  10.     <!-- 配置_Druid和Spring关联监控配置 -->
  11.     <bean id="druid-stat-interceptor"
  12.         class="com.alibaba.druid.support.spring.stat.DruidStatInterceptor" />
  14.     <!-- 方法名正则匹配拦截配置 -->
  15.     <bean id="druid-stat-pointcut" class="org.springframework.aop.support.JdkRegexpMethodPointcut" scope="prototype">
  16.         <property name="patterns">
  17.             <list>
  18.                 <value>com.example.springboot.mysqldemo.controller.*</value>
  19.             </list>
  20.         </property>
  21.     </bean>
  23.     <aop:config proxy-target-class="true">
  24.         <aop:advisor advice-ref="druid-stat-interceptor" pointcut-ref="druid-stat-pointcut"></aop:advisor>
  25.     </aop:config>
  27. </beans>

在需要添加监控的Controller下注解

  1. @ImportResource(locations = { "classpath:druid-bean.xml" })

例：

  1. package com.example.springboot.mysqldemo.controller;
  3. import com.example.springboot.mysqldemo.dao.UserInfoDao;
  4. import com.example.springboot.mysqldemo.model.UserInfo;
  5. import org.springframework.beans.factory.annotation.Autowired;
  6. import org.springframework.context.annotation.ImportResource;
  7. import org.springframework.web.bind.annotation.RequestMapping;
  8. import org.springframework.web.bind.annotation.RestController;
  10. import java.util.List;
  12. @RestController
  13. @RequestMapping("/index")
  14. @ImportResource(locations = { "classpath:druid-bean.xml" })
  15. public class IndexController {
  16.     @Autowired
  17.     private UserInfoDao userInfoDao;
  19.     @RequestMapping("/getInofo")
  20.     public List<UserInfo> getInofo() {
  21.         List<UserInfo> userInfos = userInfoDao.findAll();
  22.         return userInfos;
  23.     }
  24. }

druid还可以进行sql监听等扩展功能。。。。待续

发表评论

表情：
评论列表 （有 0 条评论，373人围观）

还没有评论，来说两句吧...

相关阅读

    相关 SpringBoot整合Druid

    SpringBoot整合Druid 简介：Druid是阿里巴巴提供的数据库连接池，文本讲解SpringBoot整合Druid。 创建项目 ![在这里插入图片描述]

    傷城~傷城~/ 0 赞/ 139 阅读

    相关 Springboot 整合 Druid

    Druid( [阿里巴巴开源项目 Druid][Druid])首先是一个数据库连接池，但它不仅仅是一个数据库连接池，它还包含一个ProxyDriver，一系列内置的JDBC组件

    清疚清疚/ 0 赞/ 89 阅读