修改实时数据超时时间

2026-04-09 19:54:07 +08:00
parent c31d91074d
commit 234ba26bbe
1 changed files with 1 additions and 1 deletions
--- a/message/message-boot/src/main/java/com/njcn/message/websocket/WebSocketServer.java
+++ b/message/message-boot/src/main/java/com/njcn/message/websocket/WebSocketServer.java
@@ -132,7 +132,7 @@ public class WebSocketServer  {
        baseMessage.setMessageBody(JSONObject.toJSONString(askRealDataMessage));
        // 发送消息到topic1
        askRealDataMessaggeTemplate.sendMember(baseMessage,data.getNodeId());
-        redisUtil.saveByKeyWithExpire(RedisKeyPrefix.ASK_REAL_DATA.concat(split[1]),RedisKeyPrefix.ASK_REAL_DATA.concat(split[1]),20L);
+        redisUtil.saveByKeyWithExpire(RedisKeyPrefix.ASK_REAL_DATA.concat(split[1]),RedisKeyPrefix.ASK_REAL_DATA.concat(split[1]),30L);
        log.info("监测点连接:" + userIdAndLineIdAndDevId + ",当前在线监测点数为:" + getOnlineCount());

    }