Apache common-pool: Java程序的对象池利器

2024-02-21 21:07:29

Apache common-pool 简介

Apache common-pool 是一个 Java 库，用于管理对象池，以提高应用程序的性能、可靠性和可伸缩性。它提供了一系列对象池实现，包括连接池、资源池和线程池。通过使用对象池，您可以减少创建和销毁对象的开销，提高应用程序的性能。同时，对象池还可以帮助您管理对象的生命周期，确保对象被正确地使用和释放，提高应用程序的可靠性和可用性。

Apache common-pool 的使用场景

Apache common-pool 可以用于各种场景，包括：

连接池： 管理数据库连接池、HTTP 连接池等，提高数据库访问和网络通信的性能。
资源池： 管理各种资源，如文件句柄、网络套接字等，提高资源利用率。
线程池： 管理线程池，提高应用程序的并发性能。

Apache common-pool 的配置参数

Apache common-pool 提供了丰富的配置参数，您可以根据具体场景进行配置。以下是几个常用的配置参数：

maxActive： 最大活动对象数，表示池中最多可以同时有多少个活动对象。
maxIdle： 最大空闲对象数，表示池中最多可以同时有多少个空闲对象。
minIdle： 最小空闲对象数，表示池中至少要保持多少个空闲对象。
maxWait： 最大等待时间，表示当池中没有可用对象时，最多等待多久。
testOnBorrow： 在借用对象时是否进行测试，以确保对象可用。
testOnReturn： 在归还对象时是否进行测试，以确保对象可用。

Apache common-pool 的代码示例

以下是一个使用 Apache common-pool 管理数据库连接池的代码示例：

import org.apache.commons.pool2.BasePooledObjectFactory;
import org.apache.commons.pool2.PooledObject;
import org.apache.commons.pool2.impl.GenericObjectPool;
import org.apache.commons.pool2.impl.GenericObjectPoolConfig;

import javax.sql.DataSource;
import java.sql.Connection;

public class ConnectionPool {

    private GenericObjectPool<Connection> pool;

    public ConnectionPool(DataSource dataSource) {
        GenericObjectPoolConfig config = new GenericObjectPoolConfig();
        config.setMaxTotal(10);
        config.setMaxIdle(5);
        config.setMinIdle(1);
        config.setMaxWaitMillis(1000);
        config.setTestOnBorrow(true);
        config.setTestOnReturn(true);

        ConnectionFactory factory = new ConnectionFactory(dataSource);
        pool = new GenericObjectPool<>(factory, config);
    }

    public Connection getConnection() throws Exception {
        return pool.borrowObject();
    }

    public void returnConnection(Connection connection) {
        pool.returnObject(connection);
    }

    private static class ConnectionFactory extends BasePooledObjectFactory<Connection> {

        private DataSource dataSource;

        public ConnectionFactory(DataSource dataSource) {
            this.dataSource = dataSource;
        }

        @Override
        public Connection create() throws Exception {
            return dataSource.getConnection();
        }

        @Override
        public PooledObject<Connection> wrap(Connection connection) {
            return new PooledObject<>(connection);
        }

        @Override
        public void destroyObject(PooledObject<Connection> pooledObject) throws Exception {
            pooledObject.getObject().close();
        }

        @Override
        public boolean validateObject(PooledObject<Connection> pooledObject) {
            try {
                return pooledObject.getObject().isValid(1);
            } catch (Exception e) {
                return false;
            }
        }
    }
}