liusuyi
2025-11-29 a838f3ca9a44d4aaf810ab2271ca33ebc4819e7e
ard-work/src/main/java/com/ard/work/component/websocket/handler/TyMessageHandler.java
@@ -47,8 +47,8 @@
            String userIdStr = (String) session.getAttributes().get("userId");
            Long userId = Long.parseLong(userIdStr);
            String payload = message.getPayload();
            log.info("【cmd】Received message: {}", payload);
            log.info("【cmd】size: {}", WebSocketSessionManager.getOnlineUserCount());
            log.info("【cmd】Received【{}】message: {} size: {}", userId, payload,
                    WebSocketSessionManager.getOnlineUserCount());
            BaseMessage<?> baseMessage = JSON.parseObject(payload, BaseMessage.class);
            MessageType messageType = MessageType.fromString(baseMessage.getType());
            switch (messageType) {
@@ -295,7 +295,7 @@
        // 延迟10秒删除token(若期间没重连)
        CompletableFuture.runAsync(() -> {
            try {
                Thread.sleep(10_000); // 延迟10秒
                Thread.sleep(3_000); // 延迟3秒
            } catch (InterruptedException ignored) {
            }