什么是对象池化？

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

什么样的对象需要池化?

一般需要池化的对象往往都是比"重量级"较的对象，创建和销毁都比较耗时，比如我们的"线程","数据库链接对象"，"tcp链接对象", "FTP链接对象" 等等。

对象池化的好处?

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

对象池化后需要注意什么？

这些被池化的对象都有一个特点，都是"活的"，比如数据库链接对象内部一般保存了一个TCP链接，所以，这个对象"能用"的前提是这个TCP链接是有效的，线程对象"能用"的前提是线程的状态不是"凋亡"状态，所以我们有必要定期对对象的"健康状态"进行检查，剔除掉"不能用"的对象，并填充新的对象给"对象池"。

使用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.PooledObjectFactoryT> 接口实现创建、销毁、钝化、取消等接口，也可以使用他的抽象类，实现创建和包装方法即可。

public class FooPoolObjectFactory extends BasePooledObjectFactoryFoo>
 {

    @Override
    public Foo create() throws Exception {
    
        return new Foo(String.valueOf(RandomUtils.randomInt(0, 10)));

    }
    
    @Override
    public PooledObjectFoo>
 wrap(Foo obj) {
    
        return new DefaultPooledObject>
    (obj);

    }

}
    

• 实现驱逐策略

一般数据库链接对象，要定期进行心跳，确保链接可用，如果链接断开，需要销毁对象，并重新创建新的对象。common-pool中，我们可以实现驱逐策略，对对象进行定期检查

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

    }

}
    

• 构建& 配置对象池

    public GenericObjectPoolFoo>
 fooGenericObjectPool() {
    
        GenericObjectPoolConfigFoo>
     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 GenericObjectPoolFoo>
     fooGenericObjectPool = fooGenericObjectPool();

    public Foo borrowFoo () throws Exception {
    
        return fooGenericObjectPool.borrowObject();

    }

    public void returnObject(Foo foo){
    
        fooGenericObjectPool.returnObject(foo);

    }
    

声明：本文内容由网友自发贡献，本站不承担相应法律责任。对本内容有异议或投诉，请联系2913721942#qq.com核实处理，我们将尽快回复您，谢谢合作！