|
@@ -30,24 +30,19 @@ public class JedisUtil implements Serializable {
|
|
|
|
|
|
try {
|
|
|
if (null == JedisPropertiesBuilder.instance()) {
|
|
|
- logger.error("jedis is not work......");
|
|
|
+ logger.error("jedis init is error.");
|
|
|
+ throw new Exception("jedis init is error.");
|
|
|
}
|
|
|
|
|
|
JedisProperties jp = JedisPropertiesBuilder.instance();
|
|
|
- logger.debug("1:" + jp.getPool().getMaxIdle());
|
|
|
- logger.debug("2:" + jp.getPool().getMaxWait());
|
|
|
- logger.debug("3:" + jp.getPool().getMaxTotal());
|
|
|
- logger.debug("4:" + jp.getPool().getTestOnBorrow());
|
|
|
- logger.debug("5:" + jp.getHost());
|
|
|
- logger.debug("6:" + jp.getPort());
|
|
|
|
|
|
- config.setMaxIdle(Integer.parseInt(JedisPropertiesBuilder.instance().getPool().getMaxIdle()));
|
|
|
+ config.setMaxIdle(Integer.parseInt(jp.getPool().getMaxIdle()));
|
|
|
|
|
|
- config.setMaxWaitMillis(Long.parseLong(JedisPropertiesBuilder.instance().getPool().getMaxWait()));
|
|
|
- config.setMaxTotal(Integer.parseInt(JedisPropertiesBuilder.instance().getPool().getMaxTotal()));
|
|
|
- config.setTestOnBorrow(Boolean.parseBoolean(JedisPropertiesBuilder.instance().getPool().getTestOnBorrow()));
|
|
|
- String redisIp = JedisPropertiesBuilder.instance().getHost();
|
|
|
- int port = Integer.parseInt(JedisPropertiesBuilder.instance().getPort());
|
|
|
+ config.setMaxWaitMillis(Long.parseLong(jp.getPool().getMaxWait()));
|
|
|
+ config.setMaxTotal(Integer.parseInt(jp.getPool().getMaxTotal()));
|
|
|
+ config.setTestOnBorrow(Boolean.parseBoolean(jp.getPool().getTestOnBorrow()));
|
|
|
+ String redisIp = jp.getHost();
|
|
|
+ int port = Integer.parseInt(jp.getPort());
|
|
|
jedisPool = new JedisPool(config, redisIp, port, 10000);
|
|
|
|
|
|
logger.info("redis连接成功: {}:{}, ", redisIp, port);
|