Java Web 开发：连接池

2169 字
11 分钟
Java Web 开发：连接池
2026-06-10
Java Web 开发
Java
/
Java Web 开发
/
连接池
/
数据库

学习目标

🔸理解连接池是什么

🔸掌握池化思想的好处

🔸会使用第三方的连接池

学习明确一下：

Connection是用户与MySQL数据库进行交互的桥梁。通过Connection，用户能够执行各种数据库操作，如查询、插入、更新和删除数据。

Connection是事务执行的基础和通道，而事务则是通过Connection来执行的一系列数据库操作的逻辑单元。它们共同协作，确保数据库操作的正确性和一致性。

所以能够正确的获取Connection还是非常重要的

连接池#

连接池是创建和管理一个连接的缓冲池的技术，这些连接准备好被任何需要它们的线程使用。

image-20230103093213233

使用连接池有哪些好处？

  • 减少连接创建时间

创建新的 JDBC 连接仍会有网络和 JDBC 驱动的开销。如果这类连接是“循环”使用的，使用该方式这些花销就可避免。平分。

  • 简化的编程模式

当使用连接池时，每一个单独的线程能够像创建了一个自己的 JDBC 连接一样操作，允许用户直接使用JDBC编程技术。

  • 受控的资源使用

如果用户不使用连接池，而是每当线程需要时创建一个新的连接，那么用户的应用程序的资源使用会产生非常大的浪费并且可能会导致高负载下的异常发生。

image-20230103093823203

池化思想 池化技术。

听不懂面试官的问题。

面试时，如果面试官问连接池有什么好处、线程池有什么好处？应该怎么答呢？

池化技术（Pooling）是一种常见的资源管理技术，它可以通过预先创建和维护一定数量的资源实例来提高系统的性能和可靠性。池化技术的好处包括：

  1. 提高性能：池化技术可以避免频繁地创建和销毁资源实例，从而减少了资源的开销和系统资源的消耗。这样可以提高系统的性能和响应速度。
  2. 提高可靠性：池化技术可以监控资源实例的状态，如果资源实例出现异常或超时，池化技术会自动将其标记为无效实例，并重新创建新的实例。这样可以提高系统的可靠性和稳定性。
  3. 节约资源：池化技术可以限制资源实例的数量，以避免过多的实例占用系统资源。这样可以节约资源，并提高系统的可扩展性和稳定性。
  4. 简化开发：池化技术可以通过配置文件或代码来管理资源实例，使得开发人员可以更加方便地使用资源实例，同时也减少了一些资源管理的复杂性。

总之，池化技术是一种非常有用的技术，可以提高系统的性能、可靠性、节约资源和简化开发。在高并发、大数据量的应用场景下，使用池化技术可以发挥更加显著的优势。常见的池化技术包括连接池、线程池、对象池等。

自己实现的连接池#

连接池。你需要使用的时候，从池子里面（集合）取；使用完毕，放回池子。

代码的核心思想就是：创建一个可以存和取的Connection的集合类对象，关于Connection的获取和放回都通过对这个对象的操作来完成

{
  private static List<Connection> connections;




  private static String driverClassName;
  private static String url;
  private static String username;
  private static String password;


  static {
    connections = new ArrayList<>();


    Properties properties = new Properties();
    try {
      properties.load(new FileInputStream("db.properties"));
    } catch (IOException e) {
      throw new RuntimeException(e);
    }


    driverClassName = properties.getProperty("driverClass");
    url = properties.getProperty("url");
    username = properties.getProperty("username");
    password = properties.getProperty("password");


    try {
      Class.forName(driverClassName);
    } catch (ClassNotFoundException e) {
      throw new RuntimeException(e);
    }


    for (int i = 0; i < 5; i++) {
      try {
        connections.add(DriverManager.getConnection(url, username, password));
      } catch (SQLException e) {
        throw new RuntimeException(e);
      }
    }
  }


  /**
     * 获取连接的方法，如果连接池为空，则直接返回null。
     *
     * @return 连接池对象
     */
  public static Connection getConnection() {
    if (connections.isEmpty()) {
      return null;
    }
    return connections.remove(0);
  }




  public static void returnConnection(Connection connection) {
    connections.add(connection);
  }


}
  • 实现了哪些功能
    • 数据库的连接获取和释放
    • 自动扩容
  • 未实现哪些功能
    • 初始化容量，扩容数量的优化
    • 最大连接数量的限制
    • 没有超时自动回收功能

市面上已经提供了非常成熟的产品了，我们没有必要自己造轮子。

第三方提供的连接池#

如果每一种连接池都有一种自己的获取连接的方式，会导致非常混乱。

// 连接池A提供的获取连接的方法
Connection getConnection(){}


// 连接池B提供的获取连接的方法
Connection aquireConnection(){}


// 连接池C提供的获取连接的方法
Connection get(){}

这样对于Java的使用者来说去使用第三方开源的数据库连接池就可能不太方便，那么Java开发者就在JDBC中定义了一个数据库连接池的接口（ javax.sql.Datasource ），其他的数据库连接池的实现都需要去实现这个接口，这就对我们Java开发者来说造成了极大的便利，方便我们去在Java中使用数据库连接池。

DataSource接口，就是JDBC提供给我们的一个获取连接的接口。

public interface DataSource  extends CommonDataSource, Wrapper {


  Connection getConnection() throws SQLException;


  Connection getConnection(String username, String password)
    throws SQLException;
}

大家可以理解为实现了DataSource接口的类都是连接池类。以下的不同的连接池都是为了给你提供一个DataSource对象

DBCP#

不需要大家把这些背下来。 只要能照着文档，用起来就行。

最早大家都用的连接池。但是在 中间断更了几年，后续出现了一些bug，无人维护，所以索性有一些公司就自己开始开发了。

官网

  • 导包。需要两个包：commons-dbcp、commons-pool
image-20230103112524017
  • 配置
username=root
password=123456
url=jdbc:mysql://localhost:3306/test7
driverClassName=com.mysql.cj.jdbc.Driver
# 配置的参数。可以不用在url后面写。以分号分割
connectionProperties=characterEncoding=utf8;useSSL=false
# 初始化容量。
initialSize=10
  • 使用
public class DbcpDataSource1 {
    public static void main(String[] args) throws SQLException {
        DataSource dataSource = null;


        try {
            Properties properties = new Properties();
            properties.load(new FileInputStream("dbcp.properties"));
            dataSource = BasicDataSourceFactory.createDataSource(properties);
        } catch (Exception e) {
            throw new RuntimeException(e);
        }


        Connection connection = dataSource.getConnection();


        ExecuteQueryByConnection.executeQuery(connection);


        connection.close();
    }
}




public class ExecuteQueryByConnection {
    public static void executeQuery(Connection connection) throws SQLException {
        PreparedStatement preparedStatement = connection.prepareStatement("select * from account");
        ResultSet resultSet = preparedStatement.executeQuery();


        while (resultSet.next()) {
            int id = resultSet.getInt("id");
            String name = resultSet.getString("name");
            BigDecimal money = resultSet.getBigDecimal("money");


            System.out.println(id + " __ " + name + " __ " + money);
        }
    }
}

之前特别流行的连接池，但是由于中间几年没有更新，所以现在一般都是一些老项目在使用。

  • 如果单独导入了一个包(commons-dbcp)，报错了，怎么办？遇到这类问题，怎么解决？

ClassNotFoundException

C3P0#

dbcp断更后。出来的一个新的数据库连接池。

这里给大家演示一个问题，我们需要导两个包。有的时候忘记了，只导了一个，会出现什么问题？

lang.NoClassDefFoundError: com/mchange/v2/ser/Indirector

  • 没导入包会出现这个问题

  • 导包了，但是版本不对。

  • 拿这个报错去搜索引擎搜索搜索。或者去ChatGPT问。

  • 导包

    image-20230103115558878

  • 配置

需要在src目录下，新建一个配置文件。

方式一：(xml文件)

名字为固定的 c3p0-config.xml

<c3p0-config>
    <default-config>
        <property name="driverClass">com.mysql.cj.jdbc.Driver</property>
        <property
                name="jdbcUrl">jdbc:mysql://localhost:3306/test7?characterEncoding=utf8&amp;useSSL=false</property>
        <property name="user">root</property>
        <property name="password">123456</property>


        <property name="checkoutTimeout">30000</property>
        <property name="idleConnectionTestPeriod">30</property>
        <property name="initialPoolSize">10</property>
        <property name="maxIdleTime">30</property>
        <property name="maxPoolSize">100</property>
        <property name="minPoolSize">10</property>


    </default-config>
</c3p0-config>

方式二：(properties文件)

名字为固定的： c3p0.properties

c3p0.driverClass=com.mysql.cj.jdbc.Driver
c3p0.jdbcUrl=jdbc:mysql://localhost:3306/test7?characterEncoding=utf8&useSSL=false
c3p0.user=root
c3p0.password=123456
  • 使用
    static DataSource cpds;


    static {
      // 会自动去类路径下，会找指定的配置文件
      cpds = new ComboPooledDataSource();
    }

注意：c3p0的配置文件位置，都是写死在C3p0的代码里，所以配置文件的名字和位置都只能是固定的。

Druid#

阿里。

  • 导包
image-20230103142712492
  • 配置（写得配置文件，只要你有办法找到即可。但是尽量不要写绝对路径）
driverClassName=com.mysql.cj.jdbc.Driver
url=jdbc:mysql://localhost:3306/test7?characterEncoding=utf8&useSSL=false
username=root
password=123456
  • 使用
Properties properties = new Properties();
properties.load(new FileInputStream("druid.properties"));


DataSource dataSource = DruidDataSourceFactory.createDataSource(properties);
Connection connection = dataSource.getConnection();

HikariCP#

SpringBoot的一个数据库连接池。说明比较牛。

  • 导包
image-20230103174354990
  • 配置
jdbcUrl=jdbc:mysql://localhost:3306/test7?characterEncoding=utf8&useSSL=false
username=root
password=123456
  • 使用
Properties properties = new Properties();
properties.load(new FileInputStream("hikaricp.properties"));


HikariConfig config = new HikariConfig(properties);
DataSource hikariDataSource = new HikariDataSource(config);
Connection connection = hikariDataSource.getConnection();

重点：

池化思想。代码怎么写，不是特别重要，但是还是要练习。

一定一定要能自己的话描述出来。不是背出来。

文章分享

如果这篇文章对你有帮助，欢迎分享给更多人！

Java Web 开发：连接池
https://firefly-mu-weld.vercel.app/posts/03-连接池/
作者
Daisy
发布于
2026-06-10
许可协议
CC BY-NC-SA 4.0
Java Web 开发：JDBC
Java Web 开发：Maven
Profile Image of the Author
Daisy
Hello, I'm Daisy.
公告
欢迎来到我的博客！这是一则示例公告。
分类
标签
更多
© 2026 Daisy. All Rights Reserved. / RSS / Sitemap
Powered by Astro & Firefly

文章目录