From c83e56fc80fbfbd90e37dbcca8ca2535a0cd2980 Mon Sep 17 00:00:00 2001 From: zhangshuai Date: Fri, 8 Nov 2024 12:27:38 +0800 Subject: [PATCH] =?UTF-8?q?fix:=20ASW-148=20=E4=BD=BF=E7=94=A8=E8=99=9A?= =?UTF-8?q?=E6=8B=9F=E7=BA=BF=E7=A8=8B=E6=A3=80=E6=9F=A5=20session=20?= =?UTF-8?q?=E8=B6=85=E6=97=B6?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../websocket/EnvironmentNovncWebSocketHandler.java | 10 ---------- 1 file changed, 10 deletions(-) diff --git a/src/main/java/net/geedge/asw/common/config/websocket/EnvironmentNovncWebSocketHandler.java b/src/main/java/net/geedge/asw/common/config/websocket/EnvironmentNovncWebSocketHandler.java index 4d75453..cf377ea 100644 --- a/src/main/java/net/geedge/asw/common/config/websocket/EnvironmentNovncWebSocketHandler.java +++ b/src/main/java/net/geedge/asw/common/config/websocket/EnvironmentNovncWebSocketHandler.java @@ -23,9 +23,6 @@ import java.net.http.HttpClient; import java.net.http.WebSocket; import java.nio.ByteBuffer; import java.util.concurrent.CompletionStage; -import java.util.concurrent.Executors; -import java.util.concurrent.ScheduledExecutorService; -import java.util.concurrent.TimeUnit; @Component public class EnvironmentNovncWebSocketHandler extends TextWebSocketHandler { @@ -53,15 +50,12 @@ public class EnvironmentNovncWebSocketHandler extends TextWebSocketHandler { private IEnvironmentSessionService environmentSessionService; - private ScheduledExecutorService scheduler; - public EnvironmentNovncWebSocketHandler() { } public EnvironmentNovncWebSocketHandler(IEnvironmentService deviceService, IEnvironmentSessionService environmentSessionService, Integer sessionTimeout) { this.environmentService = deviceService; this.environmentSessionService = environmentSessionService; this.sessionTimeout = sessionTimeout; - this.scheduler = Executors.newSingleThreadScheduledExecutor(); } private void initFieldVal(WebSocketSession session) { @@ -195,10 +189,6 @@ public class EnvironmentNovncWebSocketHandler extends TextWebSocketHandler { envWebsocket.sendClose(WebSocket.NORMAL_CLOSURE, "Normal closure"); } Constants.ENV_NOVNC_WEBSOCKET_SESSION.remove(sessionId); - if (scheduler != null && !scheduler.isShutdown()) { - scheduler.shutdownNow(); // 停止调度器 - scheduler.close(); - } super.afterConnectionClosed(session, status); }