Java 中怎么自定义实现一个简单的数据库连接池-java教程-PHP中文网

java中可基于jdk自定义轻量连接池，核心是用blockingqueue缓存connection、限制最大连接数、代理拦截close()实现归还、isvalid()校验有效性，并保证线程安全。

java 中怎么自定义实现一个简单的数据库连接池

Java 中自定义一个简单的数据库连接池，核心是复用 Connection 对象、控制最大连接数、避免连接泄漏，并提供线程安全的获取/归还机制。不需要依赖 HikariCP 或 Druid，用基础 JDK 就能实现一个轻量、可理解的版本。

1. 设计关键点：连接池要管什么？

一个最小可用的连接池需解决几个问题：

连接的创建与缓存：首次需要时创建，后续复用已有连接
连接数量限制：防止无节制创建导致数据库拒绝服务（如 maxActive=10）
线程安全：多线程并发取连接、还连接不能出错（用 BlockingQueue 或 synchronized）
连接有效性检查：归还前或取出前简单验证（比如调用 isValid(1)）
连接超时与销毁：空闲太久的连接主动关闭（简化版可先忽略，或用定时清理线程）

2. 核心类结构：PoolDataSource

定义一个实现 javax.sql.DataSource 的类，让 Spring 或 JDBC 工具能识别它：

// 简化版，不处理异常重试、JMX、属性配置等

public class SimpleConnectionPool implements DataSource {
    private final String url;
    private final String username;
    private final String password;
    private final int maxPoolSize;
    private final BlockingQueue<connection> pool;

    public SimpleConnectionPool(String url, String username, String password, int maxPoolSize) {
        this.url = url;
        this.username = username;
        this.password = password;
        this.maxPoolSize = maxPoolSize;
        this.pool = new LinkedBlockingQueue(maxPoolSize);
        // 预热：初始化一批连接
        for (int i = 0; i  T unwrap(Class<t> iface) { throw new SQLException("Not supported"); }
    public boolean isWrapperFor(Class> iface) { return false; }
    public Connection getConnection(String u, String p) { throw new SQLException("Not supported"); }
    // ... 其余方法类似
}</t></connection>

3. 关键：用代理包装 Connection，确保归还行为

直接返回原始 Connection，用户调用 close() 就真关了。必须拦截 close()，让它变成“归还到池”，而不是关闭。

用 java.lang.reflect.Proxy 实现动态代理：

DrugBank 数据库

访问并分析来自 DrugBank 数据库的全面药物信息，包括药物属性、相互作用、靶点、通路、化学结构和药理学数据。用于药物数据、药物发现研究、药理学研究、药物-

下载

public class PooledConnection implements InvocationHandler {
    private final Connection target;
    private final SimpleConnectionPool pool;

    public PooledConnection(Connection target, SimpleConnectionPool pool) {
        this.target = target;
        this.pool = pool;
    }

    @Override
    public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
        if ("close".equals(method.getName())) {
            pool.returnConnection(target);
            return null;
        }
        return method.invoke(target, args);
    }

    public static Connection wrap(Connection conn, SimpleConnectionPool pool) {
        return (Connection) Proxy.newProxyInstance(
            Connection.class.getClassLoader(),
            new Class[]{Connection.class},
            new PooledConnection(conn, pool)
        );
    }
}

然后在 getConnection() 中返回：wrap(conn, this) —— 这样用户调 close() 就只是归还，不是销毁。

4. 使用示例与注意事项

这样使用：

DataSource ds = new SimpleConnectionPool(
    "jdbc:h2:mem:test", "sa", "", 5
);
try (Connection c = ds.getConnection();
     PreparedStatement ps = c.prepareStatement("SELECT 1")) {
    ResultSet rs = ps.executeQuery();
    // ...
} // 自动归还

// 注意：务必用 try-with-resources 或显式 close，否则连接不会归还

常见坑提醒：