...
|
...
|
@@ -71,7 +71,13 @@ public class OneJob implements Callable { |
|
|
|
|
|
protected void fecthJedis() {
|
|
|
JedisPool jedisPool = JEDIS_POOL_MAP.get(jedisUrl);
|
|
|
if(jedisUrl.indexOf("172.31.16.99")>=0){
|
|
|
DEBUG.error("begin fetch redis url {} ",jedisUrl);
|
|
|
}
|
|
|
if (null == jedisPool) {
|
|
|
if(jedisUrl.indexOf("172.31.16.99")>=0){
|
|
|
DEBUG.error("begin fetch redis jedisPool is null ");
|
|
|
}
|
|
|
JedisPoolConfig jedisPoolConfig = new JedisPoolConfig();
|
|
|
jedisPoolConfig.setMaxIdle(2);
|
|
|
jedisPoolConfig.setMaxTotal(2);
|
...
|
...
|
@@ -79,6 +85,14 @@ public class OneJob implements Callable { |
|
|
JEDIS_POOL_MAP.put(jedisUrl, jedisPool);
|
|
|
}
|
|
|
|
|
|
else{
|
|
|
if(jedisUrl.indexOf("172.31.16.99")>=0){
|
|
|
DEBUG.error("begin fetch redis jedisPool is existed ");}
|
|
|
}
|
|
|
if(jedisUrl.indexOf("172.31.16.99")>=0){
|
|
|
DEBUG.error("begin fetch redis after jedisPool {} ",jedisPool);
|
|
|
}
|
|
|
|
|
|
try {
|
|
|
this.jedis = jedisPool.getResource();
|
|
|
} catch (Exception e) {
|
...
|
...
|
|