Java中 Apache Commons ObjectPool2 怎么实现 GenericKeyedObjectPool-java教程-PHP中文网

generickeyedobjectpool是apache commons pool 2中独立设计的键控对象池，支持按键（如string）管理不同类对象（如connection），需实现keyedpooledobjectfactory并配置generickeyedobjectpoolconfig，borrow/return必须使用相同key。

java中 apache commons objectpool2 怎么实现 generickeyedobjectpool<k, v>

GenericKeyedObjectPool<k v></k> 是 Apache Commons Pool 2 中用于管理带键的、可重用对象池的核心类，适用于每个键（key）对应一类对象（如不同数据库连接池、不同配置的 HTTP 客户端等）。它不是 GenericObjectPool<v></v> 的泛型扩展，而是独立设计的键控对象池，支持按 K（键类型）获取和归还对象。

注意：你写的 <k v=""></k> 是无效泛型写法 —— 正确声明应为：

GenericKeyedObjectPool<string connection></string>

即：K 是键类型（如 String 表示数据源名），V 是池中对象类型（如 Connection）。

✅ 核心实现步骤（基于 Pool 2.11+）

1. 定义工厂：实现 `KeyedPooledObjectFactory<k v></k>`

这是池的“生产者”，负责创建、验证、销毁键控对象。

Java JDK 25

Java JDK 25 来自 OpenJDK 官方归档，版本为 JDK 25，本条下载地址已指向官方 Windows x64 zip 安装包直链，适合调试旧项目或兼容旧版 Java 运行环境。

下载

public class ConnectionFactory implements KeyedPooledObjectFactory<string connection> {

    private final DataSourceProvider dataSourceProvider;

    public ConnectionFactory(DataSourceProvider provider) {
        this.dataSourceProvider = provider;
    }

    @Override
    public PooledObject<connection> makeObject(String key) throws Exception {
        DataSource ds = dataSourceProvider.getDataSource(key);
        Connection conn = ds.getConnection();
        return new DefaultPooledObject(conn); // 包装为可池化对象
    }

    @Override
    public void destroyObject(String key, PooledObject<connection> p) throws Exception {
        Connection conn = p.getObject();
        if (conn != null && !conn.isClosed()) {
            conn.close();
        }
    }

    @Override
    public boolean validateObject(String key, PooledObject<connection> p) {
        Connection conn = p.getObject();
        try {
            return conn != null && !conn.isClosed() && conn.isValid(1);
        } catch (SQLException e) {
            return false;
        }
    }

    @Override
    public void activateObject(String key, PooledObject<connection> p) throws Exception {
        // 可选：借出前执行（如重置事务状态）
    }

    @Override
    public void passivateObject(String key, PooledObject<connection> p) throws Exception {
        // 可选：归还前执行（如清理语句、重置 autocommit）
    }
}</connection></connection></connection></connection></connection></string>

⚠️ 注意：KeyedPooledObjectFactory 的 makeObject(key) 必须根据 key 返回对应类型的实例（例如不同 URL 的 Connection）。

2. 配置池参数：使用 `GenericKeyedObjectPoolConfig`

GenericKeyedObjectPoolConfig<connection> config = new GenericKeyedObjectPoolConfig();
config.setMaxTotalPerKey(20);      // 每个 key 最多 20 个实例
config.setMaxIdlePerKey(10);       // 每个 key 空闲最多 10 个
config.setMinIdlePerKey(2);        // 每个 key 至少保留 2 个空闲
config.setTimeBetweenEvictionRunsMillis(30_000); // 后台驱逐线程间隔
config.setTestWhileIdle(true);
config.setMinEvictableIdleTimeMillis(60_000);</connection>

3. 创建并使用池

KeyedPooledObjectFactory<string connection> factory = new ConnectionFactory(dataSourceProvider);
GenericKeyedObjectPool<string connection> pool =
        new GenericKeyedObjectPool(factory, config);

// 借对象（按 key）
Connection conn = pool.borrowObject("mysql-prod"); // key = "mysql-prod"

// 归还对象（必须指定相同 key）
pool.returnObject("mysql-prod", conn);

// 关闭池（应用退出时调用）
pool.close();</string></string>

✅ borrowObject(key) 和 returnObject(key, obj) 必须使用完全相同的 key，否则行为未定义（可能泄漏或报错）。

4. 高级技巧：支持动态 key + 自动清理

若 key 动态生成（如 "redis://" + host + ":" + port），确保 equals()/hashCode() 正确（推荐用不可变对象，如 String 或自定义 HostPortKey）。
不要手动 removeObject(key)，除非明确要清空某 key 下所有对象（慎用）。
如需监控，可通过 getNumActive(key) / getNumIdle(key) 查询各键状态。