From 91e4ba507f9806c975a4273154d79f1a43b836c4 Mon Sep 17 00:00:00 2001
From: ZengTao <2773468879@qq.com>
Date: 星期一, 29 四月 2024 13:42:29 +0800
Subject: [PATCH] Merge branch 'master' of http://10.153.19.25:10101/r/HangZhouMes
---
hangzhoumesParent/moduleService/CacheGlassModule/src/main/java/com/mes/common/WebSocketServer.java | 18 +++++++-----------
1 files changed, 7 insertions(+), 11 deletions(-)
diff --git a/UnLoadGlassModule/src/main/java/com/mes/tools/WebSocketServer.java b/hangzhoumesParent/moduleService/CacheGlassModule/src/main/java/com/mes/common/WebSocketServer.java
similarity index 96%
rename from UnLoadGlassModule/src/main/java/com/mes/tools/WebSocketServer.java
rename to hangzhoumesParent/moduleService/CacheGlassModule/src/main/java/com/mes/common/WebSocketServer.java
index 13a3bde..5fabafa 100644
--- a/UnLoadGlassModule/src/main/java/com/mes/tools/WebSocketServer.java
+++ b/hangzhoumesParent/moduleService/CacheGlassModule/src/main/java/com/mes/common/WebSocketServer.java
@@ -1,4 +1,4 @@
-package com.mes.tools;
+package com.mes.common;
import cn.hutool.json.JSONObject;
import cn.hutool.json.JSONUtil;
@@ -19,8 +19,6 @@
@Component("webSocketServer")
public class WebSocketServer {
- // @Autowired
- // HomeMapper homeMapper;
public static ConfigurableApplicationContext applicationContext;
@@ -59,7 +57,7 @@
} else {
webSocketServers.add(this);
}
-
+
log.info("鏈夋柊鐢ㄦ埛鍔犲叆锛寀sername={}, 褰撳墠鍦ㄧ嚎浜烘暟涓猴細{}", username, sessionMap.get(username).size());
// JSONObject result = new JSONObject();
@@ -81,19 +79,19 @@
public void onClose(Session session, @PathParam("username") String username) {
List<WebSocketServer> webSocketServers = sessionMap.get(username);
ArrayList<WebSocketServer> arrayListwebserver = new ArrayList<WebSocketServer>();
- if (webSocketServers.size()>1) {
+ if (webSocketServers.size() > 1) {
for (WebSocketServer webSocketServer : webSocketServers) {
- if(webSocketServer!=this){
+ if (webSocketServer != this) {
arrayListwebserver.add(webSocketServer);
}
}
sessionMap.put(username, arrayListwebserver);
log.info("绉婚櫎username={}涓�鍚嶇敤鎴穝ession, {}鐨勫綋鍓嶅湪绾夸汉鏁颁负锛歿}", username, username, sessionMap.get(username).size());
- }else{
+ } else {
sessionMap.remove(username);
log.info("绉婚櫎username={}涓�鍚嶇敤鎴穝ession, {}杩炴帴鍏抽棴, 褰撳墠杩炴帴鏁颁负锛歿}", username, username, sessionMap.size());
}
-
+
}
/**
@@ -101,7 +99,7 @@
* 鍚庡彴鏀跺埌瀹㈡埛绔彂閫佽繃鏉ョ殑娑堟伅
* onMessage 鏄竴涓秷鎭殑涓浆绔�
* 鎺ュ彈 娴忚鍣ㄧ socket.send 鍙戦�佽繃鏉ョ殑 json鏁版嵁
- *
+ *
* @param message 瀹㈡埛绔彂閫佽繃鏉ョ殑娑堟伅
*/
@OnMessage
@@ -157,8 +155,6 @@
public void clearMessages() {
messages.clear();
}
-
-
}
--
Gitblit v1.8.0