摘要：使用提供了中對象池管理方式，它們的使用方式基本一樣，這里以對象池為例介紹其使用方式，一般實現自己的對象池需要經過個步驟實現接口該接口是一種工廠模式，實現其目的是讓對象池通過該工廠模式創建管理的對象創建對象池實例創建對象池我們假設對象是一
common-pool2 使用
common-pool2提供了3中對象池管理方式，它們的使用方式基本一樣，這里以GenericObjectPool對象池為例介紹其使用方式，一般實現自己的對象池需要經過2個步驟
實現PooledObjectFactory接口:該接口是一種工廠模式，實現其目的是讓對象池通過該工廠模式創建管理的對象
創建對象池(GenericObjectPool(PooledObjectFactory))實例
創建Conn對象池
我們假設Conn對象是一個建立TCP連接的對象，該對象的初始化時間平均為500ms，為了避免在程序中頻繁創建Conn對象，我們需要借助對象池管理Conn對象實例
import org.slf4j.LoggerFactory;
/**
* common-pool2 使用方式
*
* 假設這是一個建立TCP連接的對象，該對象的初始化時間平均為500ms，為了避免在程序中頻繁創建Conn對象，我們需要借助對象池管理Conn對象實例
*
* @author WangJun
* @version 1.0 15/10/28
* @since 1.6
*/
public class Conn {
/**
* 記錄對象的創建時間
*/
private long createTime;
/**
* 初始化Conn對象，模擬創建Conn對象平均消耗500ms
* @throws InterruptedException
*/
public Conn() throws InterruptedException {
Thread.sleep(500);
createTime = System.currentTimeMillis();
LoggerFactory.getLogger(getClass()).debug(" init conn suc... " + createTime);
}
/**
* 報告Conn對象信息
*/
public void report() {
LoggerFactory.getLogger(getClass()).info("this is a available conn " + createTime);
}
}
利用工廠模式，使對象池通過該工廠模式創建管理的對象
package com.peaceful.pool.demo;
import org.apache.commons.pool2.BasePooledObjectFactory;
import org.apache.commons.pool2.PooledObject;
import org.apache.commons.pool2.PooledObjectFactory;
import org.apache.commons.pool2.impl.DefaultPooledObject;
/**
* common-pool2 使用方式
*
* 為了使用common-pool2對象池管理，我們必須實現{@link org.apache.commons.pool2.PooledObjectFactory}或者其子類
* 這是一個工廠模式，告訴對象池怎樣去創建要管理的對象
*
* BasePooledObjectFactory 是對{@link org.apache.commons.pool2.PooledObjectFactory}的一個基本實現，我們可以繼承該類，減少一些方法的實現
*
* 在實現{@link org.apache.commons.pool2.PooledObjectFactory}接口時，我們一定要實現的接口方法是{@link PooledObjectFactory#makeObject()}方法。
*
* @author WangJun
* @version 1.0 15/10/28
* @since 1.6
*/
public class ConnFactory extends BasePooledObjectFactory {
/**
* 間接實現{@link PooledObjectFactory#makeObject()}方法，表明怎樣創建需要管理對象
*/
@Override
public Conn create() throws Exception {
return new Conn();
}
/**
* 在common-pool2中為了統計管理的對象的一些信息，比如調用次數，空閑時間，上次使用時間等，需要對管理的對象進行包裝，然后在放入到對象池中
*
* @param obj 對象池要管理的對象
* @return 返回包裝后的PooledObject對象
*/
@Override
public PooledObject wrap(Conn obj) {
return new DefaultPooledObject(obj);
}
}
為了模擬的更真實，ConnPool池可以讓使用者個性化配置
package com.peaceful.pool.demo;
import org.apache.commons.pool2.impl.GenericObjectPoolConfig;
/**
* common-pool2 使用方式
*
* {@link org.apache.commons.pool2.impl.GenericObjectPool}支持個性化配置，我們可以配置對象池中總共的對象數，最大、最小空閑對象數等等
* 這邊繼承{@link GenericObjectPoolConfig}是為了ConnPool也可以進行個性化的配置
*
* @author WangJun
* @version 1.0 15/10/28
* @since 1.6
*/
public class ConnPoolConfig extends GenericObjectPoolConfig {
public ConnPoolConfig() {
// defaults to make your life with connection pool easier :)
setMinIdle(5);
setTestOnBorrow(true);
}
}
有了創建對象的工廠，我們就可以創建一個對象池實例
package com.peaceful.pool.demo;
import org.apache.commons.pool2.impl.GenericObjectPool;
/**
* common-pool2 使用方式
*
* Conn對象管理池，這里利用GenericObjectPool作為對象池
*
* @author WangJun
* @version 1.0 15/10/28
* @since 1.6
*/
public class ConnPool extends GenericObjectPool {
/**
* 調用{@link GenericObjectPool}的構造方法，構造ConnPool
*/
public ConnPool() {
super(new ConnFactory(), new ConnPoolConfig());
}
/**
* 調用{@link GenericObjectPool}的構造方法，構造ConnPool
*/
public ConnPool(ConnPoolConfig connPoolConfig) {
super(new ConnFactory(), connPoolConfig);
}
}
這樣一個就完成了整個ConnPool的編碼，下面我們在寫一個demo，演示使用ConnPool
public class ConnDemo {
public static void main(String[] args) throws Exception {
ConnPoolConfig connPoolConfig = new ConnPoolConfig();
connPoolConfig.setMinIdle(5);
connPoolConfig.setMaxIdle(8);
ConnPool connPool = new ConnPool(connPoolConfig);
Conn conn1 = connPool.borrowObject();
Conn conn2 = connPool.borrowObject();
Conn conn3 = connPool.borrowObject();
Conn conn4 = connPool.borrowObject();
Conn conn5 = connPool.borrowObject();
conn1.report();
connPool.returnObject(conn1);
conn2.report();
connPool.returnObject(conn2);
conn3.report();
connPool.returnObject(conn3);
conn4.report();
connPool.returnObject(conn4);
conn5.report();
connPool.returnObject(conn5);
conn5.report();
// 被歸還的對象的引用，不可以在次歸還
// java.lang.IllegalStateException: Object has already been retured to this pool or is invalid
try {
connPool.returnObject(conn5);
}catch (Exception e){
e.printStackTrace();
}
}
}
下面是ConnDemo的運行結果
[2015-10-28 14:56:06 DEBUG] {com.peaceful.pool.demo.Conn:18}- init conn suc...
[2015-10-28 14:56:07 DEBUG] {com.peaceful.pool.demo.Conn:18}- init conn suc...
[2015-10-28 14:56:07 DEBUG] {com.peaceful.pool.demo.Conn:18}- init conn suc...
[2015-10-28 14:56:08 DEBUG] {com.peaceful.pool.demo.Conn:18}- init conn suc...
[2015-10-28 14:56:08 DEBUG] {com.peaceful.pool.demo.Conn:18}- init conn suc...
[2015-10-28 14:56:08 INFO ] {com.peaceful.pool.demo.Conn:22}-this is a available conn 1446015366746
[2015-10-28 14:56:08 INFO ] {com.peaceful.pool.demo.Conn:22}-this is a available conn 1446015367346
[2015-10-28 14:56:08 INFO ] {com.peaceful.pool.demo.Conn:22}-this is a available conn 1446015367853
[2015-10-28 14:56:08 INFO ] {com.peaceful.pool.demo.Conn:22}-this is a available conn 1446015368354
[2015-10-28 14:56:08 INFO ] {com.peaceful.pool.demo.Conn:22}-this is a available conn 1446015368860
[2015-10-28 14:56:08 INFO ] {com.peaceful.pool.demo.Conn:22}-this is a available conn 1446015368860
java.lang.IllegalStateException: Object has already been retured to this pool or is invalid
at org.apache.commons.pool2.impl.GenericObjectPool.returnObject(GenericObjectPool.java:595)
at com.peaceful.pool.demo.ConnDemo.main(ConnDemo.java:37)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at com.intellij.rt.execution.application.AppMain.main(AppMain.java:140)
文章版權歸作者所有，未經允許請勿轉載,若此文章存在違規行為，您可以聯系管理員刪除。
轉載請注明本文地址：http://specialneedsforspecialkids.com/yun/64712.html
