使用Apache Common将java对象池化的问题

发布时间：2023-02-20 10:51:58 所属栏目：Apache 来源：互联网

导读：什么是对象池化？对象被创建后，使用完毕不是立即销毁回收对象，而是将对象放到一个容器保存起来，下次使用的时候不用创建对象，而是从容器中直接获

　　什么是对象池化？
　　对象被创建后，使用完毕不是立即销毁回收对象，而是将对象放到一个容器保存起来，下次使用的时候不用创建对象，而是从容器中直接获取。

　　对象池化的好处?
　　这些对象池化后，之后使用的时候不用创建,直接使用即可，可以大大缩短程序的运行时间，以及创建对象时对CPU资源的消耗，以及对系统资源的控制(池化的对象数量有限，不会一直创建对象，导致系统资源耗尽，或者造成程序OOM的情况)进而提高系统的稳定性。

　　使用apache-common-pool池化对象
　　引入依赖

　　<dependency>
　　    <groupId>org.apache.commons</groupId>
　　    <artifactId>commons-pool2</artifactId>
　　    <version>2.9.0</version>
　　</dependency>
　　需要池化的对象示例

　　public class Foo {
　　    private final String username;
　　    public Foo(String username) {
　　        this.username = username;
　　    }
　　    public String getUsername() {
　　        return username;
　　    }
　　}
　　构建对象创建工厂
　　可以直接实现org.apache.commons.pool2.PooledObjectFactory<T>接口实现创建、销毁、钝化、取消等接口，也可以使用他的抽象类，实现创建和包装方法即可。

　　public class FooPoolObjectFactory extends BasePooledObjectFactory<Foo> {
　　    @Override
　　    public Foo create() throws Exception {
　　        return new Foo(String.valueOf(RandomUtils.randomInt(0, 10)));
　　    }
　　    @Override
　　    public PooledObject<Foo> wrap(Foo obj) {
　　        return new DefaultPooledObject<>(obj);
　　    }
　　}
　　实现驱逐策略
　　一般数据库链接对象，要定期进行心跳，确保链接可用，如果链接断开，需要销毁对象，并重新创建新的对象。common-pool中，我们可以实现驱逐策略，对对象进行定期检查

　　public class FooEvictionPolicy implements EvictionPolicy<Foo> {
　　    @Override
　　    public boolean evict(EvictionConfig config, PooledObject<Foo> underTest, int idleCount) {
　　        // todo 定期检查对象某些功能是否可用
　　        return true;
　　    }
　　}

　　public GenericObjectPool<Foo> fooGenericObjectPool() {
　　    GenericObjectPoolConfig<Foo> poolConfig = new GenericObjectPoolConfig<>();
　　    poolConfig.setEvictionPolicy(new FooEvictionPolicy());
　　    poolConfig.setBlockWhenExhausted(true);
　　    poolConfig.setJmxEnabled(false);
　　    poolConfig.setMaxWaitMillis(1000 * 10);
　　    poolConfig.setTimeBetweenEvictionRunsMillis(60 * 1000);
　　    poolConfig.setMinEvictableIdleTimeMillis(20 * 1000);
　　    poolConfig.setTestWhileIdle(true);
　　    poolConfig.setTestOnReturn(true);
　　    poolConfig.setTestOnBorrow(true);
　　    poolConfig.setMaxTotal(3);
　　    // 设置抛弃策略
　　    AbandonedConfig abandonedConfig = new AbandonedConfig();
　　    abandonedConfig.setRemoveAbandonedOnMaintenance(true);
　　    abandonedConfig.setRemoveAbandonedOnBorrow(true);
　　    return new GenericObjectPool<>(new FooPoolObjectFactory(), poolConfig, abandonedConfig);
　　}
　　如果我们使用的是spring容器，一般我们需要将该对象交由spring管理。

　　private final GenericObjectPool<Foo> fooGenericObjectPool = fooGenericObjectPool();
　　public Foo borrowFoo () throws Exception {
　　    return fooGenericObjectPool.borrowObject();
　　}
　　public void returnObject(Foo foo){
　　    fooGenericObjectPool.returnObject(foo);
　　}

（编辑：甘南站长网）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!