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 10d5858..b2795c0 100644 --- a/yq-common/src/main/java/yq/common/webSocket/MyWebSocketHandler.java +++ b/yq-common/src/main/java/yq/common/webSocket/MyWebSocketHandler.java @@ -53,18 +53,7 @@ public class MyWebSocketHandler implements WebSocketHandler { // session.sendMessage(new TextMessage("我收到了你的消息,感谢你的来信")); if(id.contains("dk")){ Map object = JSON.toJavaObject(msg, Map.class); - if(redisCache.hasKey(id)){ - Double temp = Convert.toDouble(object.get("temp")); - Map cacheMap = redisCache.getCacheMap(id); - Double temp1 = Convert.toDouble(cacheMap.get("temp"),0.0); - if(temp>temp1){ - System.out.println("存入到redis" + object); - redisCache.setCacheMap(id,object); - } - }else { - System.out.println("存入到redis" + object); - redisCache.setCacheMap(id,object); - } + redisCache.setCacheMap(id,object); redisCache.expire(id,5,TimeUnit.SECONDS); } }