ruoyi-common/ruoyi-common-redis/src/main/java/org/dromara/common/redis/utils/RedisUtils.java
@@ -65,6 +65,12 @@ consumer.accept(msg); } /** * 发布消息到指定的频道 * * @param channelKey 通道key * @param msg 发送数据 */ public static <T> void publish(String channelKey, T msg) { RTopic topic = CLIENT.getTopic(channelKey); topic.publish(msg); @@ -107,8 +113,12 @@ bucket.setAndKeepTTL(value); } catch (Exception e) { long timeToLive = bucket.remainTimeToLive(); if (timeToLive == -1) { setCacheObject(key, value); } else { setCacheObject(key, value, Duration.ofMillis(timeToLive)); } } } else { bucket.set(value); }