使用apache common pool2 封裝redis連接池

 

 

package redis;





import org.apache.commons.pool2.BasePooledObjectFactory;
import org.apache.commons.pool2.PooledObject;
import org.apache.commons.pool2.impl.DefaultPooledObject;
import org.apache.commons.pool2.impl.GenericObjectPool;
import org.apache.commons.pool2.impl.GenericObjectPoolConfig;
import redis.clients.jedis.Jedis;

import java.util.ArrayList;
import java.util.Date;
import java.util.List;


/**
 *
 * EWrapper連接池工廠
 * @author shane
 *
 */
public class JedisPoolFactory extends BasePooledObjectFactory<Jedis>{

	private String ip;
	private int port;
    private String pass;

    public JedisPoolFactory() {
        ip = "10.161.228.88";
        port = 6379;
        pass = "test";
    }

    public static void main(String[] args) throws InterruptedException {
        GenericObjectPoolConfig config = new GenericObjectPoolConfig();
		config.setMaxWaitMillis(2000);
		config.setMinIdle(1);
		config.setMaxIdle(3);
		config.setMaxTotal(5);

        /**
         * 銷毀到minidle
         */
        config.setSoftMinEvictableIdleTimeMillis(3000);

        /**
         * 銷毀所有
         */
     //   config.setMinEvictableIdleTimeMillis(3000);

        // 詞句是必須的，否則（Soft）MinEvictableIdleTimeMillis不生效
        config.setTimeBetweenEvictionRunsMillis(100);

        GenericObjectPool<Jedis> objectPool = new GenericObjectPool<Jedis>(new JedisPoolFactory(), config);

        List<Jedis> list = new ArrayList<>();

        /**
         * 等待第一個連接初始化，因為minidle＝1
         */
        Thread.sleep(5000);

        /**
         * 申請六個資源，且不歸還，等待報錯
         */
        try {
            for(int i=0; i<6; ++i) {
                Jedis jedis = objectPool.borrowObject();
            //    objectPool.returnObject(jedis);
                list.add(jedis);
            }

        } catch (Exception e) {
            System.out.println(e.getMessage() + new Date());
        }

        /**
         * 清理，查看clear－destroy情況
         */
        // 不歸還的話，clear無效
        for(Jedis jedis : list) {
            objectPool.returnObject(jedis);
        }
        objectPool.clear();
        list.clear();

        /**
         * 休息5s
         */
        Thread.sleep(5000);

        /**
         * 申請5個連接，然后一起歸還，5大於maxidle＝3的2個對象應該被立即銷毀，然后等3s后，到minidle＝1的2個對象被銷毀
         */
        try {
            for(int i=0; i<5; ++i) {
                Jedis jedis = objectPool.borrowObject();
                list.add(jedis);
                //    objectPool.returnObject(jedis);
            }

            for(Jedis jedis : list) {
                objectPool.returnObject(jedis);
            }

            // 等待對象銷毀
            Thread.sleep(10000);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

	public JedisPoolFactory(String ip, int port, String pass) {
		this.ip = ip;
		this.port = port;
        this.pass = pass;
	}

	@Override
	public Jedis create() throws Exception {
        Jedis jedis = new Jedis(ip, port, 10000);
        jedis.auth("test");

        return jedis;
	}

    @Override
    public PooledObject<Jedis> wrap(Jedis jedis) {
        System.out.println("創建" + new Date());
        return new DefaultPooledObject<Jedis>(jedis);
    }
//
//    @Override
//	public PooledObject<AbstractWrapper> wrap(AbstractWrapper wrapper) {
//		return new DefaultPooledObject<AbstractWrapper>(wrapper);
//	}
//
    /**
     * 對象激活(borrowObject時觸發）
     *
     * @param pooledObject
     */
    @Override
    public void activateObject(PooledObject<Jedis> pooledObject) throws Exception {
        System.out.println("申請" + new Date());
        super.activateObject(pooledObject);
    }


    /**
     * 對象銷毀
     * @param pooledObject
     */
    @Override
    public void destroyObject(PooledObject<Jedis> pooledObject) throws Exception {
        System.out.println("銷毀" + new Date());
        Jedis jedis = pooledObject.getObject();
        jedis.close();
        super.destroyObject(pooledObject);
    }


//    /**
//     * 驗證對象有效性
//     * @param
//     * @return
//     */
//    @Override
//    public boolean validateObject(PooledObject<Jedis> pooledObject) {
//        System.out.println("validate");
//        return true;
//    }
//
//    public void passivateObject(PooledObject<Jedis> p) throws Exception {
//        System.out.println("passivate");
//        super.passivateObject(p);
//    }

}

 

 

1）

config.setSoftMinEvictableIdleTimeMillis(3000);

 

2）

config.setMinEvictableIdleTimeMillis(3000);

 

 

timeBetweenEvictionRunsMillis和minEvictableIdleTimeMillis一起使用,每 timeBetweenEvictionRunsMillis毫秒秒檢查一次連接池中空閑的連接,把空閑時間超過SoftMinEvictableIdleTimeMillis毫秒的連接斷開,  直到連接池中的連接數到minIdle為止；對於minEvictableIdleTimeMillis，則全部銷毀。

 

https://www.jianshu.com/p/b0189e01de35

https://www.cnblogs.com/softidea/p/5759457.html

 

 

// 創建一個新對象;當對象池中的對象個數不足時,將會使用此方法來"輸出"一個新的"對象",並交付給對象池管理 PooledObject<T> makeObject() throws Exception; // 銷毀對象,如果對象池中檢測到某個"對象"idle的時間超時,或者操作者向對象池"歸還對象"時檢測到"對象"已經無效,那么此時將會導致"對象銷毀"; // "銷毀對象"的操作設計相差甚遠,但是必須明確:當調用此方法時,"對象"的生命周期必須結束.如果object是線程,那么此時線程必須退出; // 如果object是socket操作,那么此時socket必須關閉;如果object是文件流操作,那么此時"數據flush"且正常關閉. void destroyObject(PooledObject<T> p) throws Exception; // 檢測對象是否"有效";Pool中不能保存無效的"對象",因此"后台檢測線程"會周期性的檢測Pool中"對象"的有效性,如果對象無效則會導致此對象從Pool中移除,並destroy; // 此外在調用者從Pool獲取一個"對象"時,也會檢測"對象"的有效性,確保不能講"無效"的對象輸出給調用者;testOnBorrow // 當調用者使用完畢將"對象歸還"到Pool時,仍然會檢測對象的有效性.所謂有效性,就是此"對象"的狀態是否符合預期,是否可以對調用者直接使用;testOnReturn // 如果對象是Socket,那么它的有效性就是socket的通道是否暢通/阻塞是否超時等. boolean validateObject(PooledObject<T> p); // "激活"對象,當Pool中決定移除一個對象交付給調用者時額外的"激活"操作,比如可以在activateObject方法中"重置"參數列表讓調用者使用時感覺像一個"新創建"的對象一樣;如果object是一個線程,可以在"激活"操作中重置"線程中斷標記",或者讓線程從阻塞中喚醒等; // 如果object是一個socket,那么可以在"激活操作"中刷新通道,或者對socket進行鏈接重建(假如socket意外關閉)等. void activateObject(PooledObject<T> p) throws Exception; // "鈍化"對象,當調用者"歸還對象"時,Pool將會"鈍化對象"；鈍化的言外之意,就是此"對象"暫且需要"休息"一下. // 如果object是一個socket,那么可以passivateObject中清除buffer,將socket阻塞;如果object是一個線程,可以在"鈍化"操作中將線程sleep或者將線程中的某個對象wait.需要注意的時,activateObject和passivateObject兩個方法需要對應,避免死鎖或者"對象"狀態的混亂. void passivateObject(PooledObject<T> p) throws Exception;

 

 

創建Tue Aug 13 13:52:12 CST 2019
申請Tue Aug 13 13:52:17 CST 2019
validate
創建Tue Aug 13 13:52:17 CST 2019
申請Tue Aug 13 13:52:17 CST 2019
validate
創建Tue Aug 13 13:52:17 CST 2019
創建Tue Aug 13 13:52:17 CST 2019
申請Tue Aug 13 13:52:17 CST 2019
validate
申請Tue Aug 13 13:52:17 CST 2019
validate
創建Tue Aug 13 13:52:17 CST 2019
申請Tue Aug 13 13:52:17 CST 2019
validate
Timeout waiting for idle objectTue Aug 13 13:52:19 CST 2019
validate
passivate
validate
passivate
validate
passivate
validate
passivate
銷毀Tue Aug 13 13:52:19 CST 2019
validate
passivate
銷毀Tue Aug 13 13:52:19 CST 2019
銷毀Tue Aug 13 13:52:19 CST 2019
銷毀Tue Aug 13 13:52:19 CST 2019
銷毀Tue Aug 13 13:52:19 CST 2019
創建Tue Aug 13 13:52:19 CST 2019
申請Tue Aug 13 13:52:24 CST 2019
validate
創建Tue Aug 13 13:52:24 CST 2019
申請Tue Aug 13 13:52:24 CST 2019
validate
創建Tue Aug 13 13:52:24 CST 2019
創建Tue Aug 13 13:52:24 CST 2019
申請Tue Aug 13 13:52:24 CST 2019
validate
申請Tue Aug 13 13:52:24 CST 2019
validate
創建Tue Aug 13 13:52:25 CST 2019
申請Tue Aug 13 13:52:25 CST 2019
validate
validate
passivate
validate
passivate
validate
passivate
validate
passivate
銷毀Tue Aug 13 13:52:25 CST 2019
validate
passivate
銷毀Tue Aug 13 13:52:25 CST 2019
銷毀Tue Aug 13 13:52:28 CST 2019
銷毀Tue Aug 13 13:52:28 CST 2019