GenericObjectPool 避免泄漏

Keven 發(fā)布于2019-08-14 14:39 / 3103人閱讀

摘要：實(shí)際應(yīng)用中由于程序?qū)崿F(xiàn)的問題，可能造成在一些極端的情況下出現(xiàn)沒有被調(diào)用導(dǎo)致的泄漏問題。在的時(shí)候檢查是否有泄漏的時(shí)候檢查泄漏如果一個(gè)對(duì)象之后秒還沒有返還給，認(rèn)為是泄漏的對(duì)象秒運(yùn)行一次維護(hù)任務(wù)

更多內(nèi)容，請(qǐng)?jiān)L問 https://my.oschina.net/u/5751...

GenericObjectPool

GenericObjectPool 是 Apache Commons Pool 提供的對(duì)象池，使用的時(shí)候需要調(diào)用 borrowObject 獲取一個(gè)對(duì)象，使用完以后需要調(diào)用 returnObject 歸還對(duì)象，或者調(diào)用 invalidateObject 將這個(gè)對(duì)象標(biāo)記為不可再用。

實(shí)際應(yīng)用中由于程序?qū)崿F(xiàn)的問題，可能造成在一些極端的情況下出現(xiàn) borrowObject／invalidateObject 沒有被調(diào)用導(dǎo)致的泄漏問題。對(duì)象泄漏會(huì)導(dǎo)致對(duì)象池中的對(duì)象數(shù)量一直上升，達(dá)到設(shè)置的上限以后再調(diào)用 borrowObject 就會(huì)永遠(yuǎn)等待或者拋出 java.util.NoSuchElementException: Timeout waiting for idle object 異常。

對(duì)于這種問題，一方面是從應(yīng)用實(shí)現(xiàn)上進(jìn)行排查，另一方面可以通過 GenericObjectPool 自帶的機(jī)制進(jìn)行清理。

設(shè)置自動(dòng)清理 設(shè)置拋棄時(shí)間

GenericObjectPool判斷一個(gè)對(duì)象是否泄漏是根據(jù)對(duì)象最后一次使用或者最后一次borrow的時(shí)間進(jìn)行判斷的，如果超出了預(yù)設(shè)的值就會(huì)被認(rèn)為是一個(gè)泄漏的對(duì)象被清理掉（PooledObjectFactory.destroyObject在這一過程中會(huì)被調(diào)用）。拋棄時(shí)間可以通過 AbandonedConfig.setRemoveAbandonedTimeout 進(jìn)行設(shè)置，時(shí)間單位是秒。

打開泄漏清理

設(shè)置了拋棄時(shí)間以后還需要打開泄漏清理才會(huì)生效。泄漏判斷的開啟可以通過兩種方式：

從對(duì)象池中獲取對(duì)象的時(shí)候進(jìn)行清理
如果當(dāng)前對(duì)象池中少于2個(gè)idle狀態(tài)的對(duì)象或者 active數(shù)量>最大對(duì)象數(shù)-3 的時(shí)候，在borrow對(duì)象的時(shí)候啟動(dòng)泄漏清理。通過 AbandonedConfig.setRemoveAbandonedOnBorrow 為 true 進(jìn)行開啟。

啟動(dòng)定時(shí)任務(wù)進(jìn)行清理
AbandonedConfig.setRemoveAbandonedOnMaintenance 設(shè)置為 true 以后，在維護(hù)任務(wù)運(yùn)行的時(shí)候會(huì)進(jìn)行泄漏對(duì)象的清理，可以通過 GenericObjectPool.setTimeBetweenEvictionRunsMillis 設(shè)置維護(hù)任務(wù)執(zhí)行的時(shí)間間隔。

GenericObjectPool pool = new GenericObjectPool(new MyPooledObjectFactory(),config);

AbandonedConfig abandonedConfig = new AbandonedConfig();

abandonedConfig.setRemoveAbandonedOnMaintenance(true); //在Maintenance的時(shí)候檢查是否有泄漏

abandonedConfig.setRemoveAbandonedOnBorrow(true); //borrow 的時(shí)候檢查泄漏

abandonedConfig.setRemoveAbandonedTimeout(10); //如果一個(gè)對(duì)象borrow之后10秒還沒有返還給pool，認(rèn)為是泄漏的對(duì)象

pool.setAbandonedConfig(abandonedConfig);

pool.setTimeBetweenEvictionRunsMillis(5000); //5秒運(yùn)行一次維護(hù)任務(wù)