diff --git a/zheng-common/src/main/java/com/zheng/common/util/RedisUtil.java b/zheng-common/src/main/java/com/zheng/common/util/RedisUtil.java index 7da5d0e3..97cfe0b9 100644 --- a/zheng-common/src/main/java/com/zheng/common/util/RedisUtil.java +++ b/zheng-common/src/main/java/com/zheng/common/util/RedisUtil.java @@ -107,13 +107,18 @@ public class RedisUtil { * @param value */ public synchronized static void set(String key, String value) { + Jedis jedis = null; try { value = StringUtils.isBlank(value) ? "" : value; - Jedis jedis = getJedis(); + jedis = getJedis(); jedis.set(key, value); - jedis.close(); + } catch (Exception e) { _log.error("Set key error : " + e); + } finally { + if(jedis != null) { + jedis.close(); + } } } @@ -123,12 +128,17 @@ public class RedisUtil { * @param value */ public synchronized static void set(byte[] key, byte[] value) { + Jedis jedis = null; try { - Jedis jedis = getJedis(); + jedis = getJedis(); jedis.set(key, value); - jedis.close(); + } catch (Exception e) { _log.error("Set key error : " + e); + } finally { + if(jedis != null) { + jedis.close(); + } } } @@ -139,13 +149,18 @@ public class RedisUtil { * @param seconds 以秒为单位 */ public synchronized static void set(String key, String value, int seconds) { + Jedis jedis = null; try { value = StringUtils.isBlank(value) ? "" : value; - Jedis jedis = getJedis(); + jedis = getJedis(); jedis.setex(key, seconds, value); - jedis.close(); + } catch (Exception e) { _log.error("Set keyex error : " + e); + } finally { + if(jedis != null) { + jedis.close(); + } } } @@ -156,13 +171,18 @@ public class RedisUtil { * @param seconds 以秒为单位 */ public synchronized static void set(byte[] key, byte[] value, int seconds) { + Jedis jedis = null; try { - Jedis jedis = getJedis(); + jedis = getJedis(); jedis.set(key, value); jedis.expire(key, seconds); - jedis.close(); + } catch (Exception e) { _log.error("Set key error : " + e); + } finally { + if(jedis != null) { + jedis.close(); + } } } @@ -172,12 +192,22 @@ public class RedisUtil { * @return value */ public synchronized static String get(String key) { - Jedis jedis = getJedis(); - if (null == jedis) { - return null; + Jedis jedis = null; + String value = null; + try { + jedis = getJedis(); + if (null == jedis) { + return null; + } + value = jedis.get(key); + + } catch (Exception e) { + _log.error("Get value error : " + e); + } finally { + if(jedis != null) { + jedis.close(); + } } - String value = jedis.get(key); - jedis.close(); return value; } @@ -187,12 +217,24 @@ public class RedisUtil { * @return value */ public synchronized static byte[] get(byte[] key) { - Jedis jedis = getJedis(); - if (null == jedis) { - return null; + Jedis jedis = null; + byte[] value = null; + + try { + jedis = getJedis(); + if (null == jedis) { + return null; + } + value = jedis.get(key); + + } catch (Exception e) { + _log.error("Get byte value error : " + e); + } finally { + if(jedis != null) { + jedis.close(); + } } - byte[] value = jedis.get(key); - jedis.close(); + return value; } @@ -201,12 +243,17 @@ public class RedisUtil { * @param key */ public synchronized static void remove(String key) { + Jedis jedis = null; try { - Jedis jedis = getJedis(); + jedis = getJedis(); jedis.del(key); - jedis.close(); + } catch (Exception e) { - _log.error("Remove keyex error : " + e); + _log.error("Remove string key error : " + e); + } finally { + if(jedis != null) { + jedis.close(); + } } } @@ -215,12 +262,17 @@ public class RedisUtil { * @param key */ public synchronized static void remove(byte[] key) { + Jedis jedis = null; try { - Jedis jedis = getJedis(); + jedis = getJedis(); jedis.del(key); - jedis.close(); + } catch (Exception e) { - _log.error("Remove keyex error : " + e); + _log.error("Remove byte[] key error : " + e); + } finally { + if(jedis != null) { + jedis.close(); + } } } @@ -230,12 +282,17 @@ public class RedisUtil { * @param key */ public synchronized static void lpush(String key, String... strings) { + Jedis jedis = null; try { - Jedis jedis = RedisUtil.getJedis(); + jedis = RedisUtil.getJedis(); jedis.lpush(key, strings); - jedis.close(); + } catch (Exception e) { _log.error("lpush error : " + e); + } finally { + if(jedis != null) { + jedis.close(); + } } } @@ -246,12 +303,17 @@ public class RedisUtil { * @param value */ public synchronized static void lrem(String key, long count, String value) { + Jedis jedis = null; try { - Jedis jedis = RedisUtil.getJedis(); + jedis = RedisUtil.getJedis(); jedis.lrem(key, count, value); - jedis.close(); + } catch (Exception e) { - _log.error("lpush error : " + e); + _log.error("lrem error : " + e); + } finally { + if(jedis != null) { + jedis.close(); + } } } @@ -262,13 +324,18 @@ public class RedisUtil { * @param seconds */ public synchronized static void sadd(String key, String value, int seconds) { + Jedis jedis = null; try { - Jedis jedis = RedisUtil.getJedis(); + jedis = RedisUtil.getJedis(); jedis.sadd(key, value); jedis.expire(key, seconds); jedis.close(); } catch (Exception e) { _log.error("sadd error : " + e); + } finally { + if(jedis != null) { + jedis.close(); + } } }