From 1f69ad0de4a0abf9b50599146d8f9b6a22e803a3 Mon Sep 17 00:00:00 2001
From: huangzhen <867217663@qq.com>
Date: 星期四, 19 十月 2023 08:57:03 +0800
Subject: [PATCH] 第一版-20231019
---
src/main/java/com/gkhy/fourierSpecialGasMonitor/websocket/GasConcentrationExcWebsocketServer.java | 17 +++++++++--------
1 files changed, 9 insertions(+), 8 deletions(-)
diff --git a/src/main/java/com/gkhy/fourierSpecialGasMonitor/websocket/GasConcentrationExcWebsocketServer.java b/src/main/java/com/gkhy/fourierSpecialGasMonitor/websocket/GasConcentrationExcWebsocketServer.java
index 6a52921..1ce6205 100644
--- a/src/main/java/com/gkhy/fourierSpecialGasMonitor/websocket/GasConcentrationExcWebsocketServer.java
+++ b/src/main/java/com/gkhy/fourierSpecialGasMonitor/websocket/GasConcentrationExcWebsocketServer.java
@@ -14,9 +14,10 @@
import java.util.Iterator;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
+import java.util.concurrent.TimeUnit;
@Slf4j
-@ServerEndpoint("/gas/exc/{userId}")
+@ServerEndpoint("/ws/gas/exc/{userId}")
@Component
public class GasConcentrationExcWebsocketServer {
@@ -54,10 +55,10 @@
this.userId = userId;
webSocketMap.put(userId, this);
- log.info("webSocketMap -> " + JSON.toJSONString(webSocketMap));
+ //log.info("webSocketMap -> " + JSON.toJSONString(webSocketMap));
addOnlineCount(); // 在线数 +1
- log.info("【气体浓度异常】有新窗口开始监听:" + userId + ",当前在线人数为" + getOnlineCount());
+ //log.info("【气体浓度异常】有新窗口开始监听:" + userId + ",当前在线人数为" + getOnlineCount());
try {
sendMessage(JSON.toJSONString("【气体浓度异常】连接成功"));
@@ -77,7 +78,7 @@
if (webSocketMap.get(this.userId) != null) {
webSocketMap.remove(this.userId);
subOnlineCount(); // 人数 -1
- log.info("【气体浓度异常】有一连接关闭，当前在线人数为：" + getOnlineCount());
+ //log.info("【气体浓度异常】有一连接关闭，当前在线人数为：" + getOnlineCount());
}
}
@@ -89,7 +90,7 @@
*/
@OnMessage
public void onMessage(String message, Session session) {
- log.info("收到来自窗口" + userId + "的信息：" + message);
+ //log.info("收到来自窗口" + userId + "的信息：" + message);
if (StringUtils.isNotBlank(message)) {
try {
@@ -118,7 +119,7 @@
@OnError
public void onError(Session session, Throwable error) {
log.error("用户错误：" + this.userId + "，原因：" + error.getMessage());
- error.printStackTrace();
+ //error.printStackTrace();
}
/**
@@ -147,10 +148,10 @@
if (userId == null) {
webSocketMap.get(entry.getKey()).sendMessage(message);
- log.info("【气体浓度异常】发送消息到：" + entry.getKey() + "，消息：" + message);
+ //log.info("【气体浓度异常】发送消息到：" + entry.getKey() + "，消息：" + message);
} else if (entry.getKey().equals(userId)) {
webSocketMap.get(entry.getKey()).sendMessage(message);
- log.info("【气体浓度异常】发送消息到：" + entry.getKey() + "，消息：" + message);
+ //log.info("【气体浓度异常】发送消息到：" + entry.getKey() + "，消息：" + message);
}
}
--
Gitblit v1.9.2