common-pool2 使用

since1986 發(fā)布于2019-08-14 12:48 / 2842人閱讀

摘要：使用提供了中對象池管理方式，它們的使用方式基本一樣，這里以對象池為例介紹其使用方式，一般實現(xiàn)自己的對象池需要經(jīng)過個步驟實現(xiàn)接口該接口是一種工廠模式，實現(xiàn)其目的是讓對象池通過該工廠模式創(chuàng)建管理的對象創(chuàng)建對象池實例創(chuàng)建對象池我們假設(shè)對象是一

common-pool2 使用

common-pool2提供了3中對象池管理方式，它們的使用方式基本一樣，這里以GenericObjectPool對象池為例介紹其使用方式，一般實現(xiàn)自己的對象池需要經(jīng)過2個步驟

實現(xiàn)PooledObjectFactory接口:該接口是一種工廠模式，實現(xiàn)其目的是讓對象池通過該工廠模式創(chuàng)建管理的對象

創(chuàng)建對象池(GenericObjectPool(PooledObjectFactory))實例

創(chuàng)建Conn對象池

我們假設(shè)Conn對象是一個建立TCP連接的對象，該對象的初始化時間平均為500ms，為了避免在程序中頻繁創(chuàng)建Conn對象，我們需要借助對象池管理Conn對象實例

import org.slf4j.LoggerFactory;

/**
 * common-pool2 使用方式
 * 
 * 假設(shè)這是一個建立TCP連接的對象，該對象的初始化時間平均為500ms，為了避免在程序中頻繁創(chuàng)建Conn對象，我們需要借助對象池管理Conn對象實例
 *
 * @author WangJun 
 * @version 1.0 15/10/28
 * @since 1.6
 */

public class Conn {

    /**
     * 記錄對象的創(chuàng)建時間
     */
    private long createTime;


    /**
     * 初始化Conn對象，模擬創(chuàng)建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);
    }
}

利用工廠模式，使對象池通過該工廠模式創(chuàng)建管理的對象

    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對象池管理，我們必須實現(xiàn){@link org.apache.commons.pool2.PooledObjectFactory}或者其子類
     * 這是一個工廠模式，告訴對象池怎樣去創(chuàng)建要管理的對象
     * 

     * BasePooledObjectFactory 是對{@link org.apache.commons.pool2.PooledObjectFactory}的一個基本實現(xiàn)，我們可以繼承該類，減少一些方法的實現(xiàn)
     * 

     * 在實現(xiàn){@link org.apache.commons.pool2.PooledObjectFactory}接口時，我們一定要實現(xiàn)的接口方法是{@link PooledObjectFactory#makeObject()}方法。
     *
     * @author WangJun 
     * @version 1.0 15/10/28
     * @since 1.6
     */
    
    public class ConnFactory extends BasePooledObjectFactory {
    
    
        /**
         * 間接實現(xiàn){@link PooledObjectFactory#makeObject()}方法，表明怎樣創(chuàng)建需要管理對象
         */
        @Override
        public Conn create() throws Exception {
            return new Conn();
        }
    
    
        /**
         * 在common-pool2中為了統(tǒng)計管理的對象的一些信息，比如調(diào)用次數(shù)，空閑時間，上次使用時間等，需要對管理的對象進(jìn)行包裝，然后在放入到對象池中
         *
         * @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}支持個性化配置，我們可以配置對象池中總共的對象數(shù)，最大、最小空閑對象數(shù)等等
     * 這邊繼承{@link GenericObjectPoolConfig}是為了ConnPool也可以進(jìn)行個性化的配置
     *
     * @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);
        }
    
    }

有了創(chuàng)建對象的工廠，我們就可以創(chuàng)建一個對象池實例

    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 {
    
    
        /**
         * 調(diào)用{@link GenericObjectPool}的構(gòu)造方法，構(gòu)造ConnPool
         */
        public ConnPool() {
            super(new ConnFactory(), new ConnPoolConfig());
        }
    
        /**
         * 調(diào)用{@link GenericObjectPool}的構(gòu)造方法，構(gòu)造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的運(yùn)行結(jié)果

[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)

GPU云服務(wù)器云服務(wù)器 asp數(shù)組使用2 java quartz2 2 1使用 thinkphp3.2 使用阿里云發(fā)送短信 android 4 2 2

文章版權(quán)歸作者所有，未經(jīng)允許請勿轉(zhuǎn)載,若此文章存在違規(guī)行為，您可以聯(lián)系管理員刪除。

轉(zhuǎn)載請注明本文地址：http://systransis.cn/yun/64712.html

發(fā)表評論

登陸后可評論

0條評論

since1986

男|高級講師

我要關(guān)注我要私信

TA的文章

騰訊云：優(yōu)惠，爆款1核2G云服務(wù)器首年74元，可選機(jī)房，北京/廣州/成都/上海/重慶/中國香港/新加

閱讀 3590·2021-08-31 09:39
用CSS畫簡單圖標(biāo)

閱讀 1885·2019-08-30 13:14
關(guān)于字體大小px與rem混用的個人經(jīng)驗

閱讀 2955·2019-08-30 13:02
CSS3 實現(xiàn)多個動畫效果

閱讀 2799·2019-08-29 13:22
vuecli3 vant rem 移動端框架方案

閱讀 2375·2019-08-26 13:54
小程序圖片上傳 wx.uploadFile 后臺java PHP兩個版本

閱讀 800·2019-08-26 13:45
cocos creator 事件

閱讀 1615·2019-08-26 11:00
JavaScript之柯里化

閱讀 1013·2019-08-26 10:58

成人国产在线小视频_日韩寡妇人妻调教在线播放_色成人www永久在线观看_2018国产精品久久_亚洲欧美高清在线30p_亚洲少妇综合一区_黄色在线播放国产_亚洲另类技巧小说校园_国产主播xx日韩_a级毛片在线免费

資訊專欄INFORMATION COLUMN

上云采購季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺、長期優(yōu)惠，快來選購！

common-pool2 使用

相關(guān)文章

common pool2

Java四種引用類型

JAVA數(shù)據(jù)庫連接池總結(jié)

hudson+gradle+git+maven(非必選)持續(xù)集成 (二)

發(fā)表評論

0條評論

since1986

男|高級講師

TA的文章

騰訊云：優(yōu)惠，爆款1核2G云服務(wù)器首年74元，可選機(jī)房，北京/廣州/成都/上海/重慶/中國香港/新加

用CSS畫簡單圖標(biāo)

關(guān)于字體大小px與rem混用的個人經(jīng)驗

CSS3 實現(xiàn)多個動畫效果

vuecli3 vant rem 移動端框架方案

小程序圖片上傳 wx.uploadFile 后臺java PHP兩個版本

cocos creator 事件

JavaScript之柯里化

最新活動

資訊專欄INFORMATION COLUMN

上云采購季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺、長期優(yōu)惠，快來選購！

common-pool2 使用

相關(guān)文章

發(fā)表評論

0條評論

男|高級講師

TA的文章

最新活動

上云采購季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺、長期優(yōu)惠，快來選購！