当前位置:   article > 正文

SpringBoot中数据库连接池的使用_max-pool-prepared-statement-per-connection-size

max-pool-prepared-statement-per-connection-size

目录

一、前言

二、连接池介绍

1. 使用连接池的好处

2. 常见连接池

3. 各种连接池的优缺点

4. 项目中该如何选择连接池

三、SpringBoot中的连接池及使用

1.SpringBoot默认连接池(Hikari)使用

2.SpringBoot整合druid(德鲁伊)连接池


一、前言

开发web项目,我们肯定会和数据库打交道,因此就会涉及到数据库链接的问题。在以前我们开发传统的SSM结构的项目时进行数据库链接都是通过JDBC进行数据链接,我们每和数据库打一次交道都需要先获取一次链接,操作完后再关闭链接,这样子效率很低,因此就出现了连接池,用于高效创建并合理分配数据库链接,数据库连接池跟线程池其实也一样的道理。

说到连接池就不得不说到持久层的框架JDBC、MyBatis、Hibernate、Spring Data等,目前市面上最流行的应该属于MyBatis(底层JDBC),其中还有个MyBatis-plus并不属于新的框架,只能算是在MyBatis上包装了一层更便于开发人员使用而已。从上图可以看出来,其实现在市面上演变而来的持久层框架大多都是基于JDBC而来的,下面我们就讲一讲连接池相关的内容吧。

二、连接池介绍

1. 使用连接池的好处

①资源重用

避免了频繁创建、释放连接引起的大量性能开销。在减少系统消耗的基础上,另一方面也增进了系统运行环境的平稳性(减少内存碎片以及数据库临时进程/线程的数量)。

②更快的系统响应速度

在初始化过程中,就已经创建好若干数据库连接。此时连接的初始化工作均已完成。对于业务请求处理而言,直接利用现有可用连接,避免了数据库连接初始化和释放过程的时间开销,从而缩减了系统整体响应时间。

③新的资源分配手段

对于多应用共享同一数据库的系统而言,可在应用层通过数据库连接的配置,实现数据库连接池技术,几年钱也许还是个新鲜话题,对于目前的业务系统而言,如果设计中还没有考虑到连接池的应用,那么…….快在设计文档中加上这部分的内容吧。某一应用最大可用数据库连接数的限制,避免某一应用独占所有数据库资源。

④ 统一的连接管理,避免数据库连接泄漏

在较为完备的数据库连接池实现中,可根据预先的连接占用超时设定,强制收回被占用连接。从而避免了常规数据库连接操作中可能出现的资源泄漏。

2. 常见连接池

现在市面上的连接池有很多种,此处我也只列举几种使用较多的:

①C3P0

开源的JDBC连接池,实现了数据源和JNDI绑定,支持JDBC3规范和JDBC2的标准扩展。目前使用它的开源项目有Hibernate、Spring等。单线程,性能较差,适用于小型系统,代码600KB左右。

②DBCP

全称(Database Connection Pool),由Apache开发的一个Java数据库连接池项目, Jakarta commons-pool对象池机制,Tomcat使用的连接池组件就是DBCP。单独使用dbcp需要3个包:common-dbcp.jar,common-pool.jar,common-collections.jar,预先将数据库连接放在内存中,应用程序需要建立数据库连接时直接到连接池中申请一个就行,用完再放回。单线程,并发量低,性能不好,适用于小型系统。

③Tomcat Jdbc Pool

Tomcat在7.0以前都是使用common-dbcp做为连接池组件,但是dbcp是单线程,为保证线程安全会锁整个连接池,性能较差,dbcp有超过60个类,也相对复杂。Tomcat从7.0开始引入了新增连接池模块叫做Tomcat jdbc pool,基于Tomcat JULI,使用Tomcat日志框架,完全兼容dbcp,通过异步方式获取连接,支持高并发应用环境,超级简单核心文件只有8个,支持JMX,支持XA Connection。

④BoneCP

官方说法BoneCP是一个高效、免费、开源的Java数据库连接池实现库。设计初衷就是为了提高数据库连接池性能,根据某些测试数据显示,BoneCP的速度是最快的,要比当时第二快速的连接池快25倍左右,完美集成到一些持久化产品如Hibernate和DataNucleus中。BoneCP特色:高度可扩展,快速;连接状态切换的回调机制;允许直接访问连接;自动化重置能力;JMX支持;懒加载能力;支持XML和属性文件配置方式;较好的Java代码组织,100%单元测试分支代码覆盖率;代码40KB左右。

⑤Druid(德鲁伊)–推荐使用

Druid是Java语言中最好的数据库连接池,Druid能够提供强大的监控和扩展功能,是一个可用于大数据实时查询和分析的高容错、高性能的开源分布式系统,尤其是当发生代码部署、机器故障以及其他产品系统遇到宕机等情况时,Druid仍能够保持100%正常运行。主要特色:为分析监控设计;快速的交互式查询;高可用;可扩展;Druid是一个开源项目,源码托管在github上。

⑥Hikari

HiKariCP是数据库连接池的一个后起之秀,号称性能最好,可以完美地PK掉其他连接池,是一个高性能的JDBC连接池,基于BoneCP做了不少的改进和优化。并且 在springboot2.0之后,采用的默认数据库连接池就是Hikari。

3. 各种连接池的优缺点

4. 项目中该如何选择连接池

小型项目

若只是小型SpringBoot项目,那么你无论使用Druid和Hikari哪种都可以,都有各自的优缺点。使用SpringBoot自带的Hikari数据库连接池操作简单,不需要引入额外的jar包,拿来即用,也不需要额外的多做配置等,使用Druid连接池还支持sql级监控、扩展、SQL防注入等。–推荐使用Druid连接池

中型项目

推荐使用Druid数据库,也就是我们平时说的德鲁伊连接池,使用理由如下:

Druid功能更全面,除具备连接池基本功能外,还支持sql级监控、扩展、SQL防注入等。最新版甚至有集群监控

单从性能角度考虑,从数据上确实HikariCP要强,但Druid有更多、更久的生产实践,它可靠。

大型项目

推荐使用默认的HikariCP连接池,因为大型项目中有专门用于监控的系统(skywalking、prometheus),连接池就只需要它做好连接池的本职工作即可,因此性能更好的HikariCP才是首选。

三、SpringBoot中的连接池及使用

1.SpringBoot默认连接池(Hikari)使用

配置文件中的数据源配置中不设置数据源类型即使用默认的Hikari,如果需要设置连接池配置参数直接在配置文件中设置即可:

  1. #数据库配置
  2. spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
  3. spring.datasource.url=jdbc:mysql://localhost:3306/gsnm_base_0000?serverTimezone=UTC&useUnicode=true&characterEncoding=utf8
  4. spring.datasource.username=root
  5. spring.datasource.password=123456
  6. # 数据库连接池配置
  7. #最小空闲连接,默认值10,小于0或大于maximum-pool-size,都会重置为maximum-pool-size
  8. spring.datasource.hikari.minimum-idle=10
  9. #最大连接数,小于等于0会被重置为默认值10;大于零小于1会被重置为minimum-idle的值
  10. spring.datasource.hikari.maximum-pool-size=20
  11. #空闲连接超时时间,默认值60000010分钟),大于等于max-lifetime且max-lifetime>0,会被重置为0;不等于0且小于10秒,会被重置为10
  12. spring.datasource.hikari.idle-timeout=500000
  13. #连接最大存活时间,不等于0且小于30秒,会被重置为默认值30分钟.设置应该比mysql设置的超时时间短
  14. spring.datasource.hikari.max-lifetime=540000
  15. #连接超时时间:毫秒,小于250毫秒,否则被重置为默认值30
  16. spring.datasource.hikari.connection-timeout=60000

Hikari连接池的使用是很简单的,因为是默认的连接池,因此我们也不需要做过多的配置,拿来既可以使用。

2.SpringBoot整合druid(德鲁伊)连接池

①导入druid-spring-boot-starter包(推荐1.2.21版本)

注意:此包1.1.10后的版本数据监控中心做了调整需要自己新增配置类

  1. <!--引入druid数据源 1.1.10 此版本的数据监控中心可以直接使用-->
  2. <dependency>
  3. <groupId>com.alibaba</groupId>
  4. <artifactId>druid-spring-boot-starter</artifactId>
  5. <version>1.1.10</version>
  6. </dependency>
  1. <!--druid数据源 1.1.21 此版本的数据监控中心增加了登录界面需要增加配置类-->
  2. <dependency>
  3. <groupId>com.alibaba</groupId>
  4. <artifactId>druid-spring-boot-starter</artifactId>
  5. <version>1.1.21</version>
  6. </dependency>

②修改配置文件

  1. #数据库连接中修改数据源类型
  2. spring.datasource.type=com.alibaba.druid.pool.DruidDataSource
  3. # druid参数调优(可选),若配置如下参数则必须手动添加配置类
  4. # 初始化大小,最小,最大
  5. spring.datasource.initialSize=5
  6. spring.datasource.minIdle=5
  7. spring.datasource.maxActive=20
  8. # 配置获取连接等待超时的时间
  9. spring.datasource.maxWait=60000
  10. # 配置间隔多久才进行一次检测,检测需要关闭的空闲连接,单位是毫秒
  11. spring.datasource.timeBetweenEvictionRunsMillis=60000
  12. # 配置一个连接在池中最小生存的时间,单位是毫秒
  13. spring.datasource.minEvictableIdleTimeMillis=300000
  14. # 测试连接
  15. spring.datasource.testWhileIdle=true
  16. spring.datasource.testOnBorrow=false
  17. spring.datasource.testOnReturn=false
  18. # 打开PSCache,并且指定每个连接上PSCache的大小
  19. spring.datasource.poolPreparedStatements=true
  20. # 配置监控统计拦截的filters
  21. # asyncInit是1.1.4中新增加的配置,如果有initialSize数量较多时,打开会加快应用启动时间
  22. spring.datasource.asyncInit=true
  23. # druid监控配置信息
  24. spring.datasource.filters=stat,config
  25. spring.datasource.maxPoolPreparedStatementPerConnectionSize=20
  26. spring.datasource.useGlobalDataSourceStat=true
  27. spring.datasource.connectionProperties=druid.stat.mergeSql=true;druid.stat.slowSqlMillis=500

③新增数据源配置类DruidConfig

若没有指定连接池参数,则无需此配置类

  1. import com.alibaba.druid.pool.DruidDataSource;
  2. import org.slf4j.Logger;
  3. import org.slf4j.LoggerFactory;
  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. import java.sql.SQLException;
  9. /**
  10. * Druid连接池调优配置信息:只有配置数据库连接池调优信息才需要该类
  11. */
  12. @Configuration
  13. public class DruidConfig {
  14. private Logger logger = LoggerFactory.getLogger(DruidConfig.class);
  15. @Value("${spring.datasource.url}")
  16. private String dbUrl;
  17. @Value("${spring.datasource.username}")
  18. private String username;
  19. @Value("${spring.datasource.password}")
  20. private String password;
  21. @Value("${spring.datasource.driver-class-name}")
  22. private String driverClassName;
  23. @Value("${spring.datasource.initial-size}")
  24. private int initialSize;
  25. @Value("${spring.datasource.min-idle}")
  26. private int minIdle;
  27. @Value("${spring.datasource.max-active}")
  28. private int maxActive;
  29. @Value("${spring.datasource.max-wait}")
  30. private int maxWait;
  31. @Value("${spring.datasource.time-between-eviction-runs-millis}")
  32. private int timeBetweenEvictionRunsMillis;
  33. @Value("${spring.datasource.min-evictable-idle-time-millis}")
  34. private int minEvictableIdleTimeMillis;
  35. @Value("${spring.datasource.test-while-idle}")
  36. private boolean testWhileIdle;
  37. @Value("${spring.datasource.test-on-borrow}")
  38. private boolean testOnBorrow;
  39. @Value("${spring.datasource.test-on-return}")
  40. private boolean testOnReturn;
  41. @Value("${spring.datasource.pool-prepared-statements}")
  42. private boolean poolPreparedStatements;
  43. @Value("${spring.datasource.max-pool-prepared-statement-per-connection-size}")
  44. private int maxPoolPreparedStatementPerConnectionSize;
  45. @Value("${spring.datasource.filters}")
  46. private String filters;
  47. @Primary //在同样的DataSource中,首先使用被标注的DataSource
  48. @Bean
  49. public DruidDataSource dataSourceDefault(){
  50. DruidDataSource datasource = new DruidDataSource();
  51. datasource.setUrl(this.dbUrl);
  52. datasource.setUsername(username);
  53. datasource.setPassword(password);
  54. datasource.setDriverClassName(driverClassName);
  55. //configuration
  56. datasource.setInitialSize(initialSize);
  57. datasource.setMinIdle(minIdle);
  58. datasource.setMaxActive(maxActive);
  59. datasource.setMaxWait(maxWait);
  60. datasource.setTimeBetweenEvictionRunsMillis(timeBetweenEvictionRunsMillis);
  61. datasource.setMinEvictableIdleTimeMillis(minEvictableIdleTimeMillis);
  62. datasource.setTestWhileIdle(testWhileIdle);
  63. datasource.setTestOnBorrow(testOnBorrow);
  64. datasource.setTestOnReturn(testOnReturn);
  65. datasource.setPoolPreparedStatements(poolPreparedStatements);
  66. datasource.setMaxPoolPreparedStatementPerConnectionSize(maxPoolPreparedStatementPerConnectionSize);
  67. try {
  68. datasource.setFilters(filters);
  69. } catch (SQLException e) {
  70. logger.error("druid configuration initialization filter", e);
  71. }
  72. return datasource;
  73. }
  74. }

④新增数据监控中心配置类DruidMonitorConfig

若jar包版本高于1.1.10时才需要配置该类

  1. import com.alibaba.druid.support.http.StatViewServlet;
  2. import com.alibaba.druid.support.http.WebStatFilter;
  3. import org.springframework.boot.web.servlet.FilterRegistrationBean;
  4. import org.springframework.boot.web.servlet.ServletRegistrationBean;
  5. import org.springframework.context.annotation.Bean;
  6. import org.springframework.context.annotation.Configuration;
  7. import java.util.HashMap;
  8. import java.util.Map;
  9. /**
  10. * Druid连接池监控配置信息
  11. * 提示:druid-spring-boot-starter jar包的版本高于1.1.10时才需要配置该类
  12. * 1.若低于1.1.10版本时直接访问:IP:端口/druid/index.html即可
  13. * 2.若高于1.0.10版本时访问:IP:端口/druid/login.html即可 账号密码根据自己设置的来
  14. *
  15. * @author wyj
  16. * @date 2022/8/16 15:54
  17. */
  18. @Configuration
  19. public class DruidMonitorConfig {
  20. //因为Springboot内置了servlet容器,所以没有web.xml,替代方法就是将ServletRegistrationBean注册进去
  21. //加入后台监控
  22. @Bean //这里其实就相当于servlet的web.xml
  23. public ServletRegistrationBean<StatViewServlet> statViewServlet() {
  24. ServletRegistrationBean<StatViewServlet> bean =
  25. new ServletRegistrationBean<>(new StatViewServlet(), "/druid/*");
  26. //后台需要有人登录,进行配置
  27. //bean.addUrlMappings(); 这个可以添加映射,我们在构造里已经写了
  28. //设置一些初始化参数
  29. Map<String, String> initParas = new HashMap<>();
  30. initParas.put("loginUsername", "admin");//它这个账户密码是固定的
  31. initParas.put("loginPassword", "123456");
  32. //允许谁能防伪
  33. initParas.put("allow", "");//这个值为空或没有就允许所有人访问,ip白名单
  34. //initParas.put("allow","localhost");//只允许本机访问,多个ip用逗号,隔开
  35. //initParas.put("deny","");//ip黑名单,拒绝谁访问 deny和allow同时存在优先deny
  36. initParas.put("resetEnable", "false");//禁用HTML页面的Reset按钮
  37. bean.setInitParameters(initParas);
  38. return bean;
  39. }
  40. //再配置一个过滤器,Servlet按上面的方式注册Filter也只能这样
  41. @Bean
  42. public FilterRegistrationBean<WebStatFilter> webStatFilter() {
  43. FilterRegistrationBean<WebStatFilter> bean = new FilterRegistrationBean<>();
  44. //可以设置也可以获取,设置一个阿里巴巴的过滤器
  45. bean.setFilter(new WebStatFilter());
  46. bean.addUrlPatterns("/*");
  47. //可以过滤和排除哪些东西
  48. Map<String, String> initParams = new HashMap<>();
  49. //把不需要监控的过滤掉,这些不进行统计
  50. initParams.put("exclusions", "*.js,*.css,/druid/*");
  51. bean.setInitParameters(initParams);
  52. return bean;
  53. }
  54. }

数据监控中心访问地址:
1.若jar包版本低于1.1.10版本时访问:127.0.0.1:端口/druid/index.html
2.若jar包版本高于1.0.10版本时访问:127.0.0.1:端口/druid/login.html(账号密码根据自己设置的来)

声明:本文内容由网友自发贡献,不代表【wpsshop博客】立场,版权归原作者所有,本站不承担相应法律责任。如您发现有侵权的内容,请联系我们。转载请注明出处:https://www.wpsshop.cn/article/detail/52424?site
推荐阅读
相关标签
  

闽ICP备14008679号