利用Apache Common將java對象池化的問題

什么是對象池化？

對象被創建后，使用完畢不是立即銷毀回收對象，而是將對象放到一個容器保存起來，下次使用的時候不用創建對象，而是從容器中直接獲取。

什么樣的對象需要池化?

一般需要池化的對象往往都是比"重量級"較的對象，創建和銷毀都比較耗時，比如我們的"線程","數據庫鏈接對象"，"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.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);
    }

到此這篇關于利用Apache Common將java對象“池化”的文章就介紹到這了,更多相關Apache Common java對象池化內容請搜索以前的文章或繼續瀏覽下面的相關文章希望大家以后多多支持！