From 9ac3094404d1d77f4993dea9c7b5ced7bb2aacb0 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E7=99=BD=E5=87=A4=E5=90=89?= Date: Sun, 15 Jun 2025 12:18:32 +0800 Subject: [PATCH] =?UTF-8?q?fix:Endpoint=E4=B8=8D=E8=83=BD=E7=9B=B4?= =?UTF-8?q?=E6=8E=A5=E6=B3=A8=E5=85=A5bean?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/iflytop/gd/app/ws/server/WebSocketServer.java | 14 ++------------ 1 file changed, 2 insertions(+), 12 deletions(-) diff --git a/src/main/java/com/iflytop/gd/app/ws/server/WebSocketServer.java b/src/main/java/com/iflytop/gd/app/ws/server/WebSocketServer.java index bd27ede..e957d97 100644 --- a/src/main/java/com/iflytop/gd/app/ws/server/WebSocketServer.java +++ b/src/main/java/com/iflytop/gd/app/ws/server/WebSocketServer.java @@ -1,9 +1,7 @@ package com.iflytop.gd.app.ws.server; -import com.iflytop.gd.app.service.device.DeviceStateService; import jakarta.websocket.*; import jakarta.websocket.server.ServerEndpoint; -import lombok.RequiredArgsConstructor; import lombok.extern.slf4j.Slf4j; import org.springframework.stereotype.Component; @@ -14,10 +12,7 @@ import java.util.Set; @Slf4j @ServerEndpoint("/ws") @Component -@RequiredArgsConstructor public class WebSocketServer { - private final DeviceStateService deviceStateService; - private static final Set sessions = Collections.synchronizedSet(new HashSet<>()); public static void sendMessageToClients(String message) { @@ -45,13 +40,8 @@ public class WebSocketServer { @OnClose public void onClose(Session session) { - try { - sessions.remove(session); - log.info("连接已关闭，清空当前登录用户，sessionId={}", session.getId()); - deviceStateService.getDeviceState().setCurrentUser(null); - } catch (Exception e) { - log.error("WS链接断开清空登录信息错误", e); - } + sessions.remove(session); + log.info("连接已关闭，sessionId={}", session.getId()); } @OnError