From 796b44ea813a1133beae4f3a67f1c0263510c0c7 Mon Sep 17 00:00:00 2001
From: 13693261870 <252740454@qq.com>
Date: 星期日, 17 十一月 2024 09:45:07 +0800
Subject: [PATCH] 1
---
src/main/java/com/moon/server/service/all/WebSocketService.java | 33 ++-------------------------------
1 files changed, 2 insertions(+), 31 deletions(-)
diff --git a/src/main/java/com/moon/server/service/all/WebSocketService.java b/src/main/java/com/moon/server/service/all/WebSocketService.java
index 6066f89..97126c8 100644
--- a/src/main/java/com/moon/server/service/all/WebSocketService.java
+++ b/src/main/java/com/moon/server/service/all/WebSocketService.java
@@ -11,12 +11,9 @@
import java.util.concurrent.CopyOnWriteArraySet;
import java.util.concurrent.atomic.AtomicInteger;
-/**
- * WebSocket鏈嶅姟绫�
- * @author WWW
- */
-@ServerEndpoint(value = "/ws/select")
@Component
+@SuppressWarnings("ALL")
+@ServerEndpoint(value = "/ws/select")
public class WebSocketService {
@PostConstruct
public void init() {
@@ -27,14 +24,8 @@
private static final AtomicInteger ONLINE_COUNT = new AtomicInteger(0);
- /**
- * 鐢ㄦ潵瀛樻斁姣忎釜瀹㈡埛绔搴旂殑Session瀵硅薄锛堢嚎绋嬪畨鍏⊿et锛�
- */
private final static CopyOnWriteArraySet<Session> SESSION_SET = new CopyOnWriteArraySet<Session>();
- /**
- * 杩炴帴寤虹珛鎴愬姛璋冪敤鐨勬柟娉�
- */
@OnOpen
public void onOpen(Session session) {
SESSION_SET.add(session);
@@ -44,9 +35,6 @@
sendMessage(session, "杩炴帴鎴愬姛");
}
- /**
- * 杩炴帴鍏抽棴璋冪敤鐨勬柟娉�
- */
@OnClose
public void onClose(Session session) {
SESSION_SET.remove(session);
@@ -55,28 +43,17 @@
log.info("鏈夎繛鎺ュ叧闂紝褰撳墠杩炴帴鏁颁负锛歿}", cnt);
}
- /**
- * 鏀跺埌瀹㈡埛绔秷鎭悗璋冪敤鐨勬柟娉�
- *
- * @param message 瀹㈡埛绔彂閫佽繃鏉ョ殑娑堟伅
- */
@OnMessage
public void onMessage(String message, Session session) {
log.info("鏉ヨ嚜瀹㈡埛绔殑娑堟伅锛歿}", message);
sendMessage(session, "鏀跺埌娑堟伅锛屾秷鎭唴瀹癸細" + message);
}
- /**
- * 鍑虹幇閿欒
- */
@OnError
public void onError(Session session, Throwable error) {
log.error("鍙戠敓閿欒锛歿}锛孲ession ID锛� {}", error.getMessage(), session.getId());
}
- /**
- * 鍙戦�佹秷鎭紝瀹炶返琛ㄦ槑锛屾瘡娆℃祻瑙堝櫒鍒锋柊锛宻ession浼氬彂鐢熷彉鍖栥��
- */
public static void sendMessage(Session session, String message) {
try {
// session.getAsyncRemote().sendText(message)
@@ -88,9 +65,6 @@
}
}
- /**
- * 缇ゅ彂娑堟伅
- */
public static void broadCastInfo(String message) throws IOException {
for (Session session : SESSION_SET) {
if (session.isOpen()) {
@@ -99,9 +73,6 @@
}
}
- /**
- * 鎸囧畾Session鍙戦�佹秷鎭�
- */
public static void sendMessage(String message, String sessionId) throws IOException {
Session session = null;
for (Session s : SESSION_SET) {
--
Gitblit v1.9.3