From 82de5a307466894bbb0258f8a63a26a7bb96d80d Mon Sep 17 00:00:00 2001
From: zhang <zc857179121@qq.com>
Date: 星期四, 16 十月 2025 09:55:35 +0800
Subject: [PATCH] 13
---
src/main/java/com/zy/common/config/WebSocketServer.java | 11 +++++++++--
1 files changed, 9 insertions(+), 2 deletions(-)
diff --git a/src/main/java/com/zy/common/config/WebSocketServer.java b/src/main/java/com/zy/common/config/WebSocketServer.java
index 393fc16..dbc2cdf 100644
--- a/src/main/java/com/zy/common/config/WebSocketServer.java
+++ b/src/main/java/com/zy/common/config/WebSocketServer.java
@@ -23,6 +23,7 @@
* 璁板綍褰撳墠鍦ㄧ嚎杩炴帴鏁�
*/
public static final Map<String, Session> sessionMap = new ConcurrentHashMap<>();
+
/**
* 杩炴帴寤虹珛鎴愬姛璋冪敤鐨勬柟娉�
*/
@@ -42,6 +43,7 @@
// {"users": [{"username": "zhang"},{ "username": "admin"}]}
sendAllMessage(JSONUtil.toJsonStr(result)); // 鍚庡彴鍙戦�佹秷鎭粰鎵�鏈夌殑瀹㈡埛绔�
}
+
/**
* 杩炴帴鍏抽棴璋冪敤鐨勬柟娉�
*/
@@ -50,11 +52,13 @@
sessionMap.remove(username);
log.info("鏈変竴杩炴帴鍏抽棴锛岀Щ闄sername={}鐨勭敤鎴穝ession, 褰撳墠鍦ㄧ嚎浜烘暟涓猴細{}", username, sessionMap.size());
}
+
/**
* 鏀跺埌瀹㈡埛绔秷鎭悗璋冪敤鐨勬柟娉�
* 鍚庡彴鏀跺埌瀹㈡埛绔彂閫佽繃鏉ョ殑娑堟伅
* onMessage 鏄竴涓秷鎭殑涓浆绔�
* 鎺ュ彈 娴忚鍣ㄧ socket.send 鍙戦�佽繃鏉ョ殑 json鏁版嵁
+ *
* @param message 瀹㈡埛绔彂閫佽繃鏉ョ殑娑堟伅
*/
@OnMessage
@@ -66,9 +70,9 @@
// {"to": "admin", "text": "鑱婂ぉ鏂囨湰"}
if ("heartBeat".equals(toUsername)) {
log.info("蹇冭烦");
- }else if ("all".equals(toUsername)) {
+ } else if ("all".equals(toUsername)) {
sendAllMessage(text);
- }else {
+ } else {
Session toSession = sessionMap.get(toUsername); // 鏍规嵁 to鐢ㄦ埛鍚嶆潵鑾峰彇 session锛屽啀閫氳繃session鍙戦�佹秷鎭枃鏈�
if (toSession != null) {
// 鏈嶅姟鍣ㄧ 鍐嶆妸娑堟伅缁勮涓�涓嬶紝缁勮鍚庣殑娑堟伅鍖呭惈鍙戦�佷汉鍜屽彂閫佺殑鏂囨湰鍐呭
@@ -84,11 +88,13 @@
}
}
+
@OnError
public void onError(Session session, Throwable error) {
log.error("鍙戠敓閿欒");
error.printStackTrace();
}
+
/**
* 鏈嶅姟绔彂閫佹秷鎭粰瀹㈡埛绔�
*/
@@ -100,6 +106,7 @@
log.error("鏈嶅姟绔彂閫佹秷鎭粰瀹㈡埛绔け璐�", e);
}
}
+
/**
* 鏈嶅姟绔彂閫佹秷鎭粰鎵�鏈夊鎴风
*/
--
Gitblit v1.9.1