From 2ce12525566f5204e0b6f609843c3935fe7cb02a Mon Sep 17 00:00:00 2001 From: liu Date: Wed, 20 Dec 2023 14:03:19 +0800 Subject: [PATCH] =?UTF-8?q?=E6=8F=90=E4=BA=A4websocket=E7=9B=B8=E5=85=B3?= =?UTF-8?q?=E4=BB=A3=E7=A0=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/supervision/usermanage/KickUserListener.java | 6 +----- .../java/com/supervision/usermanage/UserResourceCheck.java | 2 +- 2 files changed, 2 insertions(+), 6 deletions(-) diff --git a/virtual-patient-web/src/main/java/com/supervision/usermanage/KickUserListener.java b/virtual-patient-web/src/main/java/com/supervision/usermanage/KickUserListener.java index 99c57aa0..3a7a54d9 100644 --- a/virtual-patient-web/src/main/java/com/supervision/usermanage/KickUserListener.java +++ b/virtual-patient-web/src/main/java/com/supervision/usermanage/KickUserListener.java @@ -24,10 +24,6 @@ public class KickUserListener implements MessageListener { String messageString = message.toString(); UserWebSocketDTO user = JSONUtil.toBean(messageString, UserWebSocketDTO.class); log.info("Redis的Channel:{}收到踢用户{}下线消息", UserTokenConstant.KICK_CHANNEL, user.getUserId()); - try { - userResourceCheck.kickUser(user.getUserId(), user.getIgnoreSessionId()); - } catch (IOException e) { - throw new RuntimeException(e); - } + userResourceCheck.kickUser(user.getUserId(), user.getIgnoreSessionId()); } } diff --git a/virtual-patient-web/src/main/java/com/supervision/usermanage/UserResourceCheck.java b/virtual-patient-web/src/main/java/com/supervision/usermanage/UserResourceCheck.java index 3be40b09..c0d66db6 100644 --- a/virtual-patient-web/src/main/java/com/supervision/usermanage/UserResourceCheck.java +++ b/virtual-patient-web/src/main/java/com/supervision/usermanage/UserResourceCheck.java @@ -55,7 +55,7 @@ public class UserResourceCheck { } /** - * websocket保活接口 + * websocket保活接口,每5秒钟发送一次消息 */ @Scheduled(fixedDelay = 5 * 1000L) public void keepalive() {