redis线程问题相关配置

今天遇到一个问题  老提示redis线程未打开&＃xff0c;

搜了一下  整理了一把redis配置如下&＃xff1a;

public class RedisClient {
//Redis服务器IP
private static String ADDR &＃61; "127.0.0.1";

//Redis的端口号
private static int PORT &＃61; 6379;

//访问密码
private static String AUTH &＃61; "123456";

//可用连接实例的最大数目&＃xff0c;默认值为8&＃xff1b;
//如果赋值为-1&＃xff0c;则表示不限制&＃xff1b;如果pool已经分配了maxActive个jedis实例&＃xff0c;则此时pool的状态为exhausted(耗尽)。
private static int MAX_ACTIVE &＃61; 1024;

//控制一个pool最多有多少个状态为idle(空闲的)的jedis实例&＃xff0c;默认值也是8。
private static int MAX_IDLE &＃61; 200;

//等待可用连接的最大时间&＃xff0c;单位毫秒&＃xff0c;默认值为-1&＃xff0c;表示永不超时。如果超过等待时间&＃xff0c;则直接抛出JedisConnectionException&＃xff1b;
private static int MAX_WAIT &＃61; 10000;

private static int TIMEOUT &＃61; 10000;

//在borrow一个jedis实例时&＃xff0c;是否提前进行validate操作&＃xff1b;如果为true&＃xff0c;则得到的jedis实例均是可用的&＃xff1b;
private static boolean TEST_ON_BORROW &＃61; true;

private static JedisPool pool;

private List resultList;
/**
* 初始化Redis连接池
*/
private static void initializePool() {
try {
JedisPoolConfig config &＃61; new JedisPoolConfig();
config.setMaxTotal(MAX_ACTIVE);
config.setMaxIdle(MAX_IDLE);
config.setMaxWaitMillis(MAX_WAIT);
config.setTestOnBorrow(TEST_ON_BORROW);
//在将连接放回池中前&＃xff0c;自动检验连接是否有效
config.setTestOnReturn(true);
//自动测试池中的空闲连接是否都是可用连接
config.setTestWhileIdle(true);
pool &＃61; new JedisPool(config, ADDR, PORT,TIMEOUT,AUTH);
} catch (Exception e) {
e.printStackTrace();
}
}

/**
* 多线程环境同步初始化&＃xff08;保证项目中有且仅有一个连接池&＃xff09;
*/
private static synchronized void poolInit() {
if (null &＃61;&＃61; pool) {
initializePool();
}
}
/**
* 获取Jedis实例
* &＃64;return
*/
public synchronized static Jedis getJedis() {
if (null &＃61;&＃61; pool) {
poolInit();
}

int timeoutCount &＃61; 0;
while (true) {
try {
if (null !&＃61; pool) {
return pool.getResource();
}
} catch (Exception e) {
if (e instanceof JedisConnectionException) {
timeoutCount&＃43;&＃43;;
if (timeoutCount > 3) {
break;
}
} else {
System.out.println("jedisInfo ... NumActive&＃61;" &＃43; pool.getNumActive()
&＃43; ", NumIdle&＃61;" &＃43; pool.getNumIdle()
&＃43; ", NumWaiters&＃61;" &＃43; pool.getNumWaiters()
&＃43; ", isClosed&＃61;" &＃43; pool.isClosed());
break;
}
}
break;
}
return null;
}

/**
* 释放jedis资源
* &＃64;param jedis
*/
public static void returnResource(final Jedis jedis) {
if (jedis !&＃61; null) {
pool.close();
}
}

/以下为资料  &＃xff0c;本人没用&＃xff0c;只用了上面的getredis方法///

/测试main方法///

public static void main(String[] args) {
try {
testJedisPool();
} catch (Exception e) {
e.printStackTrace();
}
}
public static void testJedisPool() throws Exception {
//创建一个连接池对象
//系统中应该是单例的。
JedisPool jedisPool &＃61; null;
//从连接池中获得一个连接
Jedis jedis &＃61; null;
try {
jedisPool &＃61; new JedisPool("60.205.59.98", 6379);
jedis &＃61; jedisPool.getResource();
jedis.auth("changdee8068");
jedis.set("name", "ceshi");
System.out.println(jedis.get("name"));
} catch (Exception e) {
e.printStackTrace();
}finally{
//jedis必须关闭
jedis.close();
//系统关闭时关闭连接池
jedisPool.close();
}
}
}