Java轻量级连接池核心是对象复用、线程安全、超时控制与状态管理，含PoolConfig、PooledConnection和SimpleConnectionPool三组件，通过BlockingQueue管理连接，重写close归还连接，校验有效性并支持预热保活。
Java 中自定义实现一个轻量级数据库连接池，核心在于封装 Connection 的获取、复用、回收和销毁逻辑，避免每次请求都新建物理连接。关键不是造轮子替代 HikariCP 或 Druid，而是理解连接池本质：**对象复用 + 线程安全 + 超时控制 + 状态管理**。
1. 定义连接池核心组件
需要几个基础类协同工作：
- PoolConfig：配置最大连接数、最小空闲、获取超时、空闲检测间隔等
-
PooledConnection：包装原始
Connection，重写close()方法使其归还到池中，而非真正关闭 -
SimpleConnectionPool：主池类，维护可用连接队列（如
BlockingQueue<PooledConnection>）、忙连接集合、线程安全的创建/回收逻辑
2. 关键实现细节
重点不在“能连上”，而在“连得稳、收得准、不泄漏”：
-
连接获取要阻塞等待：用
BlockingQueue.poll(timeout, unit)或take()，配合超时机制，避免无限等待 -
close() 必须是“归还”而非“销毁”：在
PooledConnection.close()中调用pool.returnConnection(this)，同时清空事务状态（如setAutoCommit(true)）、重置只读标志、清除警告 -
连接有效性校验不能省：从池中取出前执行
connection.isValid(1)或简单connection.getMetaData()；归还时若发现已关闭或异常，直接丢弃不放回 -
预热与保活可选但实用：启动时按
minIdle创建一批连接；后台线程定期检查空闲连接是否超时（如 > 30 分钟），并剔除失效连接
3. 线程安全与资源清理
多线程环境下必须保证原子性：
立即学习“Java免费学习笔记（深入）”；
- 用
ConcurrentLinkedQueue或LinkedBlockingQueue存储空闲连接，避免显式加锁 - 连接创建过程（DriverManager.getConnection）本身是线程安全的，但需捕获 SQLException 并统一处理
- 池关闭时，遍历所有连接调用真实
close()，并中断监控线程；建议实现AutoCloseable接口，支持 try-with-resources
4. 一个极简可运行骨架示例
以下为关键代码片段（省略异常处理和日志）：
public class SimpleConnectionPool implements AutoCloseable {
private final BlockingQueue<PooledConnection> idleConnections;
private final PoolConfig config;
private final DataSource dataSource;
public SimpleConnectionPool(PoolConfig config) {
this.config = config;
this.idleConnections = new LinkedBlockingQueue<>(config.getMaxTotal());
this.dataSource = createDataSource(); // 基于 DriverManager 或 HikariDataSource 包装
initIdleConnections();
}
public Connection getConnection() throws SQLException {
PooledConnection conn = idleConnections.poll(config.getMaxWait(), TimeUnit.MILLISECONDS);
if (conn == null || !conn.isValid()) {
conn = createNewConnection();
}
return conn;
}
void returnConnection(PooledConnection conn) {
if (conn != null && conn.isValid()) {
idleConnections.offer(conn);
}
}
private PooledConnection createNewConnection() throws SQLException {
Connection raw = dataSource.getConnection();
return new PooledConnection(raw, this);
}
}
其中 PooledConnection 继承 Connection 接口代理（可用 JDK 动态代理或手动实现），确保 close() 调用的是 returnConnection()。
