From c2940417ad7d410e0619e34e56e52de7cdc89ebe Mon Sep 17 00:00:00 2001 From: duhui Date: Thu, 20 Oct 2022 10:34:21 +0800 Subject: [PATCH] =?UTF-8?q?redisutil=E5=8A=A0=E5=BC=82=E5=B8=B8=E6=8D=95?= =?UTF-8?q?=E6=8D=89=E5=92=8C=E6=97=A5=E5=BF=97?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/ljsd/jieling/db/redis/RedisUtil.java | 46 +++++++++++-------- 1 file changed, 28 insertions(+), 18 deletions(-) diff --git a/serverlogic/src/main/java/com/ljsd/jieling/db/redis/RedisUtil.java b/serverlogic/src/main/java/com/ljsd/jieling/db/redis/RedisUtil.java index 0857487a6..2f744059c 100644 --- a/serverlogic/src/main/java/com/ljsd/jieling/db/redis/RedisUtil.java +++ b/serverlogic/src/main/java/com/ljsd/jieling/db/redis/RedisUtil.java @@ -155,12 +155,16 @@ public class RedisUtil { */ @SuppressWarnings("unchecked") public void del(String... key) { - if (key != null && key.length > 0) { - if (key.length == 1) { - redisTemplate.delete(key[0]); - } else { - redisTemplate.delete(CollectionUtils.arrayToList(key)); + try { + if (key != null && key.length > 0) { + if (key.length == 1) { + redisTemplate.delete(key[0]); + } else { + redisTemplate.delete(CollectionUtils.arrayToList(key)); + } } + }catch (Exception e){ + LOGGER.error("redis删除key失败,key:{},error:{}",key,e.getMessage()); } } @@ -195,22 +199,28 @@ public class RedisUtil { * @param key,数组 */ public void rename(long time,String postfix,String[] key) { - if (key != null && key.length > 0) { - for (int i = 0; i < key.length; i++) { - // 旧名字 - String oldName = key[i]; - // 新名字 - String newName = getKey(oldName,postfix,false); - // key是否存在 - boolean aBoolean = hasKey(oldName); - if (aBoolean){ - // 重命名 - redisTemplate.rename(oldName,newName); - // 设置过期时间 - expire(newName,time); + try { + if (key != null && key.length > 0) { + for (int i = 0; i < key.length; i++) { + // 旧名字 + String oldName = key[i]; + // 新名字 + String newName = getKey(oldName,postfix,false); + // key是否存在 + boolean aBoolean = hasKey(oldName); + if (aBoolean){ + // 重命名 + redisTemplate.rename(oldName,newName); + // 设置过期时间 + expire(newName,time); + } } + return; } + }catch (Exception e){ + LOGGER.error("redis重命名key失败,key:{},error:{}",key,e.getMessage()); } + del(key); } // ============================String=============================