服务器之家

服务器之家 > 正文

如何在SpringBoot 中使用 Druid 数据库连接池

时间:2021-08-26 11:18     来源/作者:水货程序员

Druid是阿里开源的一款数据库连接池,除了常规的连接池功能外,它还提供了强大的监控和扩展功能。这对没有做数据库监控的小项目有很大的吸引力。

下列步骤可以让你无脑式的在SpringBoot2.x中使用Druid。

1.Maven中的pom文件

  1. <dependency>
  2. <groupId>com.alibaba</groupId>
  3. <artifactId>druid</artifactId>
  4. <version>1.1.14</version>
  5. </dependency>
  6. <dependency>
  7. <groupId>log4j</groupId>
  8. <artifactId>log4j</artifactId>
  9. <version>1.2.17</version>
  10. </dependency>

使用 Spring Boot-2.x时,如果未引入log4j,在配置 Druid 时,会遇到Caused by: java.lang.ClassNotFoundException: org.apache.log4j.Priority的报错。因为Spring Boot默认使用的是log4j2。

2.SpringBoot 配置文件

下面是一个完整的yml文件的,其中使用mybatis作为数据库访问框架

  1. server:
  2. servlet:
  3. context-path: /
  4. session:
  5. timeout: 60m
  6. port: 8080
  7.  
  8. spring:
  9. datasource:
  10. url: jdbc:mysql://127.0.0.1:9080/hospital?allowMultiQueries=true&useUnicode=true&characterEncoding=UTF-8&zeroDateTimeBehavior=convertToNull
  11. username: root
  12. password: root
  13. # 环境 dev|test|pro
  14. profiles:
  15. active: dev
  16. driver-class-name: com.mysql.cj.jdbc.Driver
  17.  
  18. ########################## druid配置 ##########################
  19. type: com.alibaba.druid.pool.DruidDataSource
  20. # 初始化大小,最小,最大
  21. initialSize: 5
  22. minIdle: 1
  23. maxActive: 20
  24. # 配置获取连接等待超时的时间
  25. maxWait: 60000
  26. # 配置间隔多久才进行一次检测,检测需要关闭的空闲连接,单位是毫秒
  27. timeBetweenEvictionRunsMillis: 60000
  28. # 配置一个连接在池中最小生存的时间,单位是毫秒
  29. minEvictableIdleTimeMillis: 300000
  30. # 校验SQL,Oracle配置 validationQuery=SELECT 1 FROM DUAL,如果不配validationQuery项,则下面三项配置无用
  31. validationQuery: SELECT 1 FROM DUAL
  32. testWhileIdle: true
  33. testOnBorrow: false
  34. testOnReturn: false
  35. # 打开PSCache,并且指定每个连接上PSCache的大小
  36. poolPreparedStatements: true
  37. maxPoolPreparedStatementPerConnectionSize: 20
  38. # 配置监控统计拦截的filters,去掉后监控界面sql无法统计,'wall'用于防火墙
  39. filters: stat,wall,log4j
  40. # 通过connectProperties属性来打开mergeSql功能;慢SQL记录
  41. connectionProperties: druid.stat.mergeSql=true;druid.stat.slowSqlMillis=5000
  42. # 合并多个DruidDataSource的监控数据
  43. useGlobalDataSourceStat: true
  44.  
  45. # Mybatis配置
  46. mybatis:
  47. mapperLocations: classpath:mapper/*.xml,classpath:mapper/extend/*.xml
  48. configuration:
  49. map-underscore-to-camel-case: true
  50. log-impl: org.apache.ibatis.logging.stdout.StdOutImpl

3.配置Druid数据源实例

由于Druid暂时不在Spring Boot中的直接支持,故需要进行配置信息的定制:

SpringBoot中的配置信息无法再Druid中直接生效,需要在Spring容器中实现一个DataSource实例。

  1. import java.sql.SQLException;
  2. import javax.sql.DataSource;
  3. import org.apache.log4j.Logger;
  4. import org.springframework.beans.factory.annotation.Value;
  5. import org.springframework.context.annotation.Bean;
  6. import org.springframework.context.annotation.Configuration;
  7. import org.springframework.context.annotation.Primary;
  8.  
  9. import com.alibaba.druid.pool.DruidDataSource;
  10.  
  11. @Configuration
  12. public class DruidDBConfig {
  13. private Logger logger = Logger.getLogger(this.getClass()); //log4j日志
  14.  
  15. @Value("${spring.datasource.url}")
  16. private String dbUrl;
  17.  
  18. @Value("${spring.datasource.username}")
  19. private String username;
  20.  
  21. @Value("${spring.datasource.password}")
  22. private String password;
  23.  
  24. @Value("${spring.datasource.driver-class-name}")
  25. private String driverClassName;
  26.  
  27. @Value("${spring.datasource.initialSize}")
  28. private int initialSize;
  29.  
  30. @Value("${spring.datasource.minIdle}")
  31. private int minIdle;
  32.  
  33. @Value("${spring.datasource.maxActive}")
  34. private int maxActive;
  35.  
  36. @Value("${spring.datasource.maxWait}")
  37. private int maxWait;
  38.  
  39. @Value("${spring.datasource.timeBetweenEvictionRunsMillis}")
  40. private int timeBetweenEvictionRunsMillis;
  41.  
  42. @Value("${spring.datasource.minEvictableIdleTimeMillis}")
  43. private int minEvictableIdleTimeMillis;
  44.  
  45. @Value("${spring.datasource.validationQuery}")
  46. private String validationQuery;
  47.  
  48. @Value("${spring.datasource.testWhileIdle}")
  49. private boolean testWhileIdle;
  50.  
  51. @Value("${spring.datasource.testOnBorrow}")
  52. private boolean testOnBorrow;
  53.  
  54. @Value("${spring.datasource.testOnReturn}")
  55. private boolean testOnReturn;
  56.  
  57. @Value("${spring.datasource.poolPreparedStatements}")
  58. private boolean poolPreparedStatements;
  59.  
  60. @Value("${spring.datasource.maxPoolPreparedStatementPerConnectionSize}")
  61. private int maxPoolPreparedStatementPerConnectionSize;
  62.  
  63. @Value("${spring.datasource.filters}")
  64. private String filters;
  65.  
  66. @Value("{spring.datasource.connectionProperties}")
  67. private String connectionProperties;
  68.  
  69. @Bean // 声明其为Bean实例
  70. @Primary // 在同样的DataSource中,首先使用被标注的DataSource
  71. public DataSource dataSource() {
  72. DruidDataSource datasource = new DruidDataSource();
  73.  
  74. datasource.setUrl(dbUrl);
  75. datasource.setUsername(username);
  76. datasource.setPassword(password);
  77. datasource.setDriverClassName(driverClassName);
  78.  
  79. // configuration
  80. datasource.setInitialSize(initialSize);
  81. datasource.setMinIdle(minIdle);
  82. datasource.setMaxActive(maxActive);
  83. datasource.setMaxWait(maxWait);
  84. datasource.setTimeBetweenEvictionRunsMillis(timeBetweenEvictionRunsMillis);
  85. datasource.setMinEvictableIdleTimeMillis(minEvictableIdleTimeMillis);
  86. datasource.setValidationQuery(validationQuery);
  87. datasource.setTestWhileIdle(testWhileIdle);
  88. datasource.setTestOnBorrow(testOnBorrow);
  89. datasource.setTestOnReturn(testOnReturn);
  90. datasource.setPoolPreparedStatements(poolPreparedStatements);
  91. datasource.setMaxPoolPreparedStatementPerConnectionSize(maxPoolPreparedStatementPerConnectionSize);
  92. try {
  93. datasource.setFilters(filters);
  94. } catch (SQLException e) {
  95. //logger.error("druid configuration initialization filter", e);
  96. logger.error("druid configuration initialization filter", e);
  97. e.printStackTrace();
  98. }
  99. datasource.setConnectionProperties(connectionProperties);
  100.  
  101. return datasource;
  102. }
  103.  
  104. }

4.过滤器和Servlet

还需要实现一个过滤器和Servlet,用于访问统计页面。

过滤器

  1. import javax.servlet.annotation.WebFilter;
  2. import javax.servlet.annotation.WebInitParam;
  3. import com.alibaba.druid.support.http.WebStatFilter;
  4. @WebFilter(filterName="druidWebStatFilter",urlPatterns="/*",
  5. initParams={
  6. @WebInitParam(name="exclusions",value="*.js,*.gif,*.jpg,*.bmp,*.png,*.css,*.ico,/druid/*")//忽略资源
  7. }
  8. )
  9. public class DruidStatFilter extends WebStatFilter {
  10. }

Servlet

  1. import javax.servlet.annotation.WebInitParam;
  2. import javax.servlet.annotation.WebServlet;
  3.  
  4. import com.alibaba.druid.support.http.StatViewServlet;
  5.  
  6. @WebServlet(urlPatterns="/druid/*",
  7. initParams={
  8. @WebInitParam(name="allow",value="127.0.0.1,192.168.163.1"),// IP白名单(没有配置或者为空,则允许所有访问)
  9. @WebInitParam(name="deny",value="192.168.1.73"),// IP黑名单 (存在共同时,deny优先于allow)
  10. @WebInitParam(name="loginUsername",value="admin"),// 用户名
  11. @WebInitParam(name="loginPassword",value="admin"),// 密码
  12. @WebInitParam(name="resetEnable",value="false")// 禁用HTML页面上的“Reset All”功能
  13. })
  14. public class DruidStatViewServlet extends StatViewServlet {
  15. private static final long serialVersionUID = -2688872071445249539L;
  16.  
  17. }

5.使用@ServletComponentScan注解,

使得刚才创建的Servlet,Filter能被访问,SpringBoot扫描并注册。

  1. @SpringBootApplication()
  2. @MapperScan("cn.china.mytestproject.dao")
  3. //添加servlet组件扫描,使得Spring能够扫描到我们编写的servlet和filter
  4. @ServletComponentScan
  5. public class MytestprojectApplication {
  6. public static void main(String[] args) {
  7. SpringApplication.run(MytestprojectApplication.class, args);
  8. }
  9. }

6.Dao层

接着Dao层代码的实现,可以使用mybatis,或者JdbcTemplate等。此处不举例。

7.运行

访问http://localhost:8080/druid/login.html地址即可打开登录页面,账号在之前的Servlet代码中。

如何在SpringBoot 中使用 Druid 数据库连接池

至此完成。

要了解更多,访问:https://github.com/alibaba/druid

以上就是SpringBoot 中使用 Druid 数据库连接池的实现步骤的详细内容,更多关于SpringBoot 中使用 Druid 数据库连接池的资料请关注服务器之家其它相关文章!

原文链接:https://cloud.tencent.com/developer/article/1402862

相关文章

热门资讯

yue是什么意思 网络流行语yue了是什么梗
yue是什么意思 网络流行语yue了是什么梗 2020-10-11
2020微信伤感网名听哭了 让对方看到心疼的伤感网名大全
2020微信伤感网名听哭了 让对方看到心疼的伤感网名大全 2019-12-26
背刺什么意思 网络词语背刺是什么梗
背刺什么意思 网络词语背刺是什么梗 2020-05-22
苹果12mini价格表官网报价 iPhone12mini全版本价格汇总
苹果12mini价格表官网报价 iPhone12mini全版本价格汇总 2020-11-13
2021年耽改剧名单 2021要播出的59部耽改剧列表
2021年耽改剧名单 2021要播出的59部耽改剧列表 2021-03-05
返回顶部