From be97e301f3bdd2f2d441085c2e9585e2fb14c616 Mon Sep 17 00:00:00 2001 From: wr <1754607820@qq.com> Date: Fri, 10 Nov 2023 16:37:57 +0800 Subject: [PATCH] =?UTF-8?q?1.=E4=BB=A3=E7=A0=81=E6=8F=90=E4=BA=A4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/njcn/redis/utils/RedisUtil.java | 24 +++++++++++++++++++ 1 file changed, 24 insertions(+) diff --git a/pqs-common/common-redis/src/main/java/com/njcn/redis/utils/RedisUtil.java b/pqs-common/common-redis/src/main/java/com/njcn/redis/utils/RedisUtil.java index 52a8d8eee..d05c422c4 100644 --- a/pqs-common/common-redis/src/main/java/com/njcn/redis/utils/RedisUtil.java +++ b/pqs-common/common-redis/src/main/java/com/njcn/redis/utils/RedisUtil.java @@ -36,6 +36,24 @@ public class RedisUtil { return Objects.isNull(expireTime) ? 0 : expireTime; } + /** + * 根据key获取过期时间(切库,切完之后自动换为原来库) + */ + public long getExpire(Integer dbIndex,String key) { + return getExpire(dbIndex,key,true); + } + + /** + * 根据key获取过期时间(切库)true:切回原库 false:不切回原库 + */ + public long getExpire(Integer dbIndex,String key,Boolean fly) { + Integer index = setDbIndex(dbIndex); + Long expireTime = redisTemplate.getExpire(key, TimeUnit.SECONDS); + if(fly){ + setDbIndex(index); + } + return Objects.isNull(expireTime) ? 0 : expireTime; + } /** * 判断key是否存在 */ @@ -299,6 +317,12 @@ public class RedisUtil { } return info; } + + /** + * 数据切库 + * @param dbIndex + * @return + */ private Integer setDbIndex(Integer dbIndex) { if (dbIndex == null || dbIndex > 15 || dbIndex < 0) { dbIndex = 0;