利用Apache?Common將java對象池化的問題
什么是對象池化?
對象被創(chuàng)建后,使用完畢不是立即銷毀回收對象,而是將對象放到一個容器保存起來,下次使用的時候不用創(chuàng)建對象,而是從容器中直接獲取。
什么樣的對象需要池化?
一般需要池化的對象往往都是比"重量級"較的對象,創(chuàng)建和銷毀都比較耗時,比如我們的"線程","數(shù)據(jù)庫鏈接對象","tcp鏈接對象", "FTP鏈接對象" 等等。
對象池化的好處?
這些對象池化后,之后使用的時候不用創(chuàng)建,直接使用即可,可以大大縮短程序的運(yùn)行時間,以及創(chuàng)建對象時對CPU資源的消耗,以及對系統(tǒng)資源的控制(池化的對象數(shù)量有限,不會一直創(chuàng)建對象,導(dǎo)致系統(tǒng)資源耗盡,或者造成程序OOM的情況)進(jìn)而提高系統(tǒng)的穩(wěn)定性。
對象池化后需要注意什么?
這些被池化的對象都有一個特點(diǎn),都是"活的",比如數(shù)據(jù)庫鏈接對象內(nèi)部一般保存了一個TCP鏈接,所以,這個對象"能用"的前提是這個TCP鏈接是有效的,線程對象"能用"的前提是線程的狀態(tài)不是"凋亡"狀態(tài),所以我們有必要定期對對象的"健康狀態(tài)"進(jìn)行檢查,剔除掉"不能用"的對象,并填充新的對象給"對象池"。
使用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; } }
- 構(gòu)建對象創(chuàng)建工廠
可以直接實(shí)現(xiàn)org.apache.commons.pool2.PooledObjectFactory<T>
接口實(shí)現(xiàn)創(chuàng)建、銷毀、鈍化、取消等接口,也可以使用他的抽象類,實(shí)現(xiàn)創(chuàng)建和包裝方法即可。
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); } }
- 實(shí)現(xiàn)驅(qū)逐策略
一般數(shù)據(jù)庫鏈接對象,要定期進(jìn)行心跳,確保鏈接可用,如果鏈接斷開,需要銷毀對象,并重新創(chuàng)建新的對象。common-pool中,我們可以實(shí)現(xiàn)驅(qū)逐策略,對對象進(jìn)行定期檢查
public class FooEvictionPolicy implements EvictionPolicy<Foo> { @Override public boolean evict(EvictionConfig config, PooledObject<Foo> underTest, int idleCount) { // todo 定期檢查對象某些功能是否可用 return true; } }
- 構(gòu)建&配置對象池
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); // 設(shè)置拋棄策略 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); }
到此這篇關(guān)于利用Apache Common將java對象“池化”的文章就介紹到這了,更多相關(guān)Apache Common java對象池化內(nèi)容請搜索本站以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持本站!
版權(quán)聲明:本站文章來源標(biāo)注為YINGSOO的內(nèi)容版權(quán)均為本站所有,歡迎引用、轉(zhuǎn)載,請保持原文完整并注明來源及原文鏈接。禁止復(fù)制或仿造本網(wǎng)站,禁止在非www.sddonglingsh.com所屬的服務(wù)器上建立鏡像,否則將依法追究法律責(zé)任。本站部分內(nèi)容來源于網(wǎng)友推薦、互聯(lián)網(wǎng)收集整理而來,僅供學(xué)習(xí)參考,不代表本站立場,如有內(nèi)容涉嫌侵權(quán),請聯(lián)系alex-e#qq.com處理。