diff --git a/yq-common/src/main/java/yq/common/webSocket/MyWebSocketHandler.java b/yq-common/src/main/java/yq/common/webSocket/MyWebSocketHandler.java index e8022ad..39f8218 100644 --- a/yq-common/src/main/java/yq/common/webSocket/MyWebSocketHandler.java +++ b/yq-common/src/main/java/yq/common/webSocket/MyWebSocketHandler.java @@ -59,9 +59,11 @@ public class MyWebSocketHandler implements WebSocketHandler { Double temp1 = Convert.toDouble(cacheMap.get("temp")); if(temp>temp1){ redisCache.setCacheMap(id,object); + redisCache.expire(id,120,TimeUnit.SECONDS); } }else { redisCache.setCacheMap(id,object); + redisCache.expire(id,120,TimeUnit.SECONDS); } }