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;