【JavaWeb】数据库连接池

太过爱你忘了你带给我的痛 2024-04-26 03:27 86阅读 0赞

> ? 本文由 [程序喵正在路上][Link 1] 原创，CSDN首发！  
> ? 系列专栏：[?JavaWeb从入门到实战][JavaWeb]  
> ? 首发时间：2022年9月2日  
> ? 欢迎关注?点赞?收藏?留言?  
> ? 一以贯之的努力 不得懈怠的人生

#### 阅读指南 ####

*  数据库连接池
 *   *  1 - 概述
     *  2 - 数据库连接池实现
     *  3 - Driud使用

## 数据库连接池 ##

--------------------

### 1 - 概述 ###

数据库连接池是什么

*  数据库连接池是一个容器，它负责分配、管理数据库连接
 *  它允许应用程序重复使用一个现有的数据库连接，而不是再重新建立一个
 *  它会释放空闲时间超过最大空闲时间的数据库连接，以此来避免因为没有释放数据库连接而引起的数据库连接遗漏

数据库连接池的优点

*  资源重用
 *  提升系统响应速度
 *  避免数据库连接遗漏

之前我们代码中使用连接都是创建一个 **Connection** 对象，使用完毕就将其销毁，这样重复创建销毁的过程，其实是特别耗费计算机的性能的及消耗时间的

而数据库使用了数据库连接池后，就能达到 **Connection** 对象的复用，如下图

![在这里插入图片描述][9b47569fb93f430ea8b38ab8fa4a0ad4.png]

连接池是在一开始就创建好了一些连接（**Connection**）对象存储起来。用户需要连接数据库时，不需要自己创建连接，而只需要从连接池中获取一个连接进行使用，使用完毕后再将连接对象归还给连接池

这样就可以起到资源重用，也节省了频繁创建连接销毁连接所花费的时间，从而提升了系统响应的速度

### 2 - 数据库连接池实现 ###

标准接口：DataSource

**DataSource** 是官方(SUN) 提供的数据库连接池标准接口，由第三方组织实现此接口，该接口提供了获取连接的功能：

Connection getConnection()

那么以后我们就不需要再通过 **DriverManager** 对象获取 **Connection** 对象，而是通过连接池获取 **Connection** 对象

常见的数据库连接池

*  **DBCP**
 *  **C3P0**
 *  **Druid**

我们现在使用更多的是**Druid**，它的性能比其他两个会好一些

Druid（德鲁伊）

*  **Druid** 连接池是阿里巴巴开源的数据库连接池项目
 *  功能强大，性能优秀，是 **Java** 语言最好的数据库连接池之一

### 3 - Driud使用 ###

使用步骤：

1.  导入 **jar** 包 **druid-1.1.12.jar**
2.  定义配置文件
3.  加载配置文件
4.  获取数据库连接池对象
5.  获取连接

现在我们通过代码来实现，首先需要先将 **Druid** 的 **jar** 包放到项目下的 **lib** 下并添加为库文件

[点击此处获取jar包][jar]

将 **jar** 包添加到 **lib** 下：

![在这里插入图片描述][ed746972fdd44f2dac7f7d2cff907271.png]

添加为库文件，选择模块库：

![在这里插入图片描述][a9298d137d79453684655b3a3cb3d2a9.png]

![在这里插入图片描述][e0b9b144deb64cd8a892e354c64962c5.png]

在 **src** 下添加一个类：

![在这里插入图片描述][47e0d76c6be04a0a85bdf7a4644d8d0a.png]

在 **src** 下新建一个配置文件 **druid.properties**，内容如下：

![在这里插入图片描述][23efd2f7fbff48fabf4fe0d912fe2d3c.png]

driverClassName=com.mysql.jdbc.Driver
    url=jdbc:mysql:///db1?useSSL=false&useServerPrepStmts=true
    username=root
    password=1234
    # 初始化连接数量
    initialSize=5
    # 最大连接数
    maxActive=10
    # 最大等待时间
    maxWait=3000

关于配置文件的参数，还有很多，具体参考下表：

<table> 
 <thead> 
  <tr> 
   <th align="center">属性</th> 
   <th align="center">说明</th> 
   <th align="center">建议值</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td align="center">url</td> 
   <td align="center">数据库的jdbc连接地址。一般为连接oracle/mysql。示例如下：</td> 
   <td align="center"></td> 
  </tr> 
  <tr> 
   <td align="center"></td> 
   <td align="center">mysql : jdbc:mysql://ip:port/dbname?option1&amp;option2&amp;…</td> 
   <td align="center"></td> 
  </tr> 
  <tr> 
   <td align="center"></td> 
   <td align="center">oracle : jdbc:oracle:thin:@ip:port:oracle_sid</td> 
   <td align="center"></td> 
  </tr> 
  <tr> 
   <td align="center">username</td> 
   <td align="center">登录数据库的用户名</td> 
   <td align="center"></td> 
  </tr> 
  <tr> 
   <td align="center">password</td> 
   <td align="center">登录数据库的用户密码</td> 
   <td align="center"></td> 
  </tr> 
  <tr> 
   <td align="center">initialSize</td> 
   <td align="center">启动程序时，在连接池中初始化多少个连接</td> 
   <td align="center">10-50已足够</td> 
  </tr> 
  <tr> 
   <td align="center">maxActive</td> 
   <td align="center">连接池中最多支持多少个活动会话</td> 
   <td align="center"></td> 
  </tr> 
  <tr> 
   <td align="center">maxWait</td> 
   <td align="center">程序向连接池中请求连接时,超过maxWait的值后，认为本次请求失败，即连接池</td> 
   <td align="center">100</td> 
  </tr> 
  <tr> 
   <td align="center"></td> 
   <td align="center">没有可用连接，单位毫秒，设置-1时表示无限等待</td> 
   <td align="center"></td> 
  </tr> 
  <tr> 
   <td align="center">minEvictableIdleTimeMillis</td> 
   <td align="center">池中某个连接的空闲时长达到 N 毫秒后, 连接池在下次检查空闲连接时，将</td> 
   <td align="center">见说明部分</td> 
  </tr> 
  <tr> 
   <td align="center"></td> 
   <td align="center">回收该连接,要小于防火墙超时设置</td> 
   <td align="center"></td> 
  </tr> 
  <tr> 
   <td align="center"></td> 
   <td align="center">net.netfilter.nf_conntrack_tcp_timeout_established的设置</td> 
   <td align="center"></td> 
  </tr> 
  <tr> 
   <td align="center">timeBetweenEvictionRunsMillis</td> 
   <td align="center">检查空闲连接的频率，单位毫秒, 非正整数时表示不进行检查</td> 
   <td align="center"></td> 
  </tr> 
  <tr> 
   <td align="center">keepAlive</td> 
   <td align="center">程序没有close连接且空闲时长超过 minEvictableIdleTimeMillis,则会执</td> 
   <td align="center">true</td> 
  </tr> 
  <tr> 
   <td align="center"></td> 
   <td align="center">行validationQuery指定的SQL,以保证该程序连接不会池kill掉,其范围不超</td> 
   <td align="center"></td> 
  </tr> 
  <tr> 
   <td align="center"></td> 
   <td align="center">过minIdle指定的连接个数。</td> 
   <td align="center"></td> 
  </tr> 
  <tr> 
   <td align="center">minIdle</td> 
   <td align="center">回收空闲连接时，将保证至少有minIdle个连接.</td> 
   <td align="center">与initialSize相同</td> 
  </tr> 
  <tr> 
   <td align="center">removeAbandoned</td> 
   <td align="center">要求程序从池中get到连接后, N 秒后必须close,否则druid 会强制回收该</td> 
   <td align="center">false,当发现程序有未</td> 
  </tr> 
  <tr> 
   <td align="center"></td> 
   <td align="center">连接,不管该连接中是活动还是空闲, 以防止进程不会进行close而霸占连接。</td> 
   <td align="center">正常close连接时设置为true</td> 
  </tr> 
  <tr> 
   <td align="center">removeAbandonedTimeout</td> 
   <td align="center">设置druid 强制回收连接的时限，当程序从池中get到连接开始算起，超过此</td> 
   <td align="center">应大于业务运行最长时间</td> 
  </tr> 
  <tr> 
   <td align="center"></td> 
   <td align="center">值后，druid将强制回收该连接，单位秒。</td> 
   <td align="center"></td> 
  </tr> 
  <tr> 
   <td align="center">logAbandoned</td> 
   <td align="center">当druid强制回收连接后，是否将stack trace 记录到日志中</td> 
   <td align="center">true</td> 
  </tr> 
  <tr> 
   <td align="center">testWhileIdle</td> 
   <td align="center">当程序请求连接，池在分配连接时，是否先检查该连接是否有效。(高效)</td> 
   <td align="center">true</td> 
  </tr> 
  <tr> 
   <td align="center">validationQuery</td> 
   <td align="center">检查池中的连接是否仍可用的 SQL 语句,drui会连接到数据库执行该SQL, 如果</td> 
   <td align="center"></td> 
  </tr> 
  <tr> 
   <td align="center"></td> 
   <td align="center">正常返回，则表示连接可用，否则表示连接不可用</td> 
   <td align="center"></td> 
  </tr> 
  <tr> 
   <td align="center">testOnBorrow</td> 
   <td align="center">程序 <strong>申请</strong> 连接时,进行连接有效性检查（低效，影响性能）</td> 
   <td align="center">false</td> 
  </tr> 
  <tr> 
   <td align="center">testOnReturn</td> 
   <td align="center">程序 <strong>返还</strong> 连接时,进行连接有效性检查（低效，影响性能）</td> 
   <td align="center">false</td> 
  </tr> 
  <tr> 
   <td align="center">poolPreparedStatements</td> 
   <td align="center">缓存通过以下两个方法发起的SQL:</td> 
   <td align="center">true</td> 
  </tr> 
  <tr> 
   <td align="center"></td> 
   <td align="center">public PreparedStatement prepareStatement(String sql)</td> 
   <td align="center"></td> 
  </tr> 
  <tr> 
   <td align="center"></td> 
   <td align="center">public PreparedStatement prepareStatement(String sql, int resultSetType, int resultSetConcurrency)</td> 
   <td align="center"></td> 
  </tr> 
  <tr> 
   <td align="center">maxPoolPrepareStatementPerConnectionSize</td> 
   <td align="center">每个连接最多缓存多少个SQL</td> 
   <td align="center">20</td> 
  </tr> 
  <tr> 
   <td align="center">filters</td> 
   <td align="center">这里配置的是插件,常用的插件有:</td> 
   <td align="center">stat,wall,slf4j</td> 
  </tr> 
  <tr> 
   <td align="center"></td> 
   <td align="center">监控统计: filter:stat</td> 
   <td align="center"></td> 
  </tr> 
  <tr> 
   <td align="center"></td> 
   <td align="center">日志监控: filter:log4j 或者 slf4j</td> 
   <td align="center"></td> 
  </tr> 
  <tr> 
   <td align="center"></td> 
   <td align="center">防御SQL注入: filter:wall</td> 
   <td align="center"></td> 
  </tr> 
  <tr> 
   <td align="center">connectProperties</td> 
   <td align="center">连接属性。比如设置一些连接池统计方面的配置。</td> 
   <td align="center"></td> 
  </tr> 
  <tr> 
   <td align="center"></td> 
   <td align="center">druid.stat.mergeSql=true;druid.stat.slowSqlMillis=5000</td> 
   <td align="center"></td> 
  </tr> 
  <tr> 
   <td align="center"></td> 
   <td align="center">比如设置一些数据库连接属性</td> 
   <td align="center"></td> 
  </tr> 
 </tbody> 
</table>

使用 **druid** 的代码如下：

/**
     * Druid数据库连接池演示
     */
    import com.alibaba.druid.pool.DruidDataSourceFactory;
    import javax.sql.DataSource;
    import java.io.FileInputStream;
    import java.sql.Connection;
    import java.util.Properties;
    
    public class DruidDemo {
        
        public static void main(String[] args) throws Exception {
        
            //1.导入jar包
            //2.定义配置文件
    
            //3. 加载配置文件
            Properties prop = new Properties();
            prop.load(new FileInputStream("jdbc_demo/src/druid.properties"));
    
            //4. 获取连接池对象
            DataSource dataSource = DruidDataSourceFactory.createDataSource(prop);
    
            //5. 获取数据库连接 Connection
            Connection connection = dataSource.getConnection();
            System.out.println(connection); //获取到了连接后就可以继续做其他操作了
        }
    }

![在这里插入图片描述][ed9aa96b7c5f4ed9b8ba54ed671d7e2b.png]

[Link 1]: https://blog.csdn.net/weixin_62511863?spm=1011.2421.3001.5343
[JavaWeb]: https://blog.csdn.net/weixin_62511863/category_11971664.html?spm=1001.2014.3001.5482
[9b47569fb93f430ea8b38ab8fa4a0ad4.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/26/11796648da774c158bb62d4e19191932.png
[jar]: https://pan.baidu.com/s/12drQ0uoQ85KHdUKgDpfjqg?pwd=o4xb
[ed746972fdd44f2dac7f7d2cff907271.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/26/a7fb6132a99347649a9072e2c3150887.png
[a9298d137d79453684655b3a3cb3d2a9.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/26/41c843f0c1ca4ea089a003632dfe4658.png
[e0b9b144deb64cd8a892e354c64962c5.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/26/7a6bebeb79d1446ea5a705a5224253bb.png
[47e0d76c6be04a0a85bdf7a4644d8d0a.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/26/47c7d65ae3cf4d9bbecad7f703c45ce5.png
[23efd2f7fbff48fabf4fe0d912fe2d3c.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/26/53c7b711744b446ea010c75a7a95b1f9.png
[ed9aa96b7c5f4ed9b8ba54ed671d7e2b.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/26/1f1997f8d231445d865e8ff85e76fb3f.png