天天看點

Redis連接配接池RedisPool使用

有關Redis 單機的具體配置,在前面的文章中已經有,非常簡單,

可以參考:https://blog.csdn.net/vtopqx/article/details/46832919

Redis 配置完成後,有的需要在Java中連接配接,

簡單的連接配接操作可以參考:

https://blog.csdn.net/vtopqx/article/details/49248245

除了使用簡單的連接配接之外,還可以使用Redis池RedisPool連接配接操作,

以下是使用RedisPool的相關連接配接代碼(單機版,非內建Spring):

package com;

import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;


/**
 * @ClassName: RedisPool
 * @Description: 單機RedisPool使用
 * @author sam
 * @date 2015-5-22 下午1:53:04
 * @version V1.0
 */
public class JRedisPoolTest {
	  /**
	   * 非切片連結池
	   */
	  private JedisPool jedisPool;

	  private String ip = "172.168.x.y";

	  private String pwd = "123456";
	  /**
	   * 構造函數
	   */
	  public JRedisPoolTest() {
	    initialPool();
	  }

	  private void initialPool() {
	    // 池基本配置
	    JedisPoolConfig config = new JedisPoolConfig();

	    //是否啟用後進先出, 預設true
	    config.setLifo(true);
	    //最大空閑連接配接數, 預設8個
	    config.setMaxIdle(8);
	    //最大連接配接數, 預設8個
	    config.setMaxTotal(8);
	    //擷取連接配接時的最大等待毫秒數(如果設定為阻塞時BlockWhenExhausted),如果逾時就抛異常, 小于零:阻塞不确定的時間,  預設-1
	    config.setMaxWaitMillis(-1);
	    //逐出連接配接的最小空閑時間 預設1800000毫秒(30分鐘)
	    config.setMinEvictableIdleTimeMillis(1800000);
	    //最小空閑連接配接數, 預設0
	    config.setMinIdle(0);
	    //每次逐出檢查時 逐出的最大數目 如果為負數就是 : 1/abs(n), 預設3
	    config.setNumTestsPerEvictionRun(3);
	    //對象空閑多久後逐出, 當空閑時間>該值 且 空閑連接配接>最大空閑數 時直接逐出,不再根據MinEvictableIdleTimeMillis判斷  (預設逐出政策)
	    config.setSoftMinEvictableIdleTimeMillis(1800000);
	    //在擷取連接配接的時候檢查有效性, 預設false
	    config.setTestOnBorrow(false);
	    //在空閑時檢查有效性, 預設false
	    config.setTestWhileIdle(false);


	    jedisPool = new JedisPool(config, ip, 6379);

	  }

	  private Jedis getResource(){
		  Jedis jedis = jedisPool.getResource();
		  jedis.auth(pwd);
		  return jedis;
	  }

	  /**
	   * @Description: 關閉連接配接
	   * @param jedis
	   */
	  private void returnResource(Jedis jedis){
		  if (jedis!=null) {
			  jedisPool.returnBrokenResource(jedis);
		}
	  }


	  //test
	  public static void main(String[] args) {
		JRedisPoolTest pool = new JRedisPoolTest();
		JRedisTest test = new JRedisTest();
		Jedis jedis = pool.getResource();
		test.setJedis(jedis);
		test.testString();
		pool.returnResource(jedis);
	}

}
           

以上代碼,便是簡單實作了Redis的池連接配接!

繼續閱讀