From ab24dfa1d1d24a4fd9117fdc30ef5510b68776b3 Mon Sep 17 00:00:00 2001 From: wzp Date: Tue, 17 Dec 2024 12:46:10 +0800 Subject: [PATCH] feat: adding close reason --- .../java/org/mmga/clubs/controller/ChessController.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/src/main/java/org/mmga/clubs/controller/ChessController.java b/src/main/java/org/mmga/clubs/controller/ChessController.java index ebc46da..deeabf7 100644 --- a/src/main/java/org/mmga/clubs/controller/ChessController.java +++ b/src/main/java/org/mmga/clubs/controller/ChessController.java @@ -64,7 +64,7 @@ public class ChessController { if (i.isEmpty()) { WebSocketUtils.sendPacket(new ErrorPacket("token验证失败!"), session); log.info("closed by token verifier"); - session.close(); + session.close(new CloseReason(CloseReason.CloseCodes.CANNOT_ACCEPT, "token验证失败!")); messageQueue.clear(); return; } @@ -93,7 +93,7 @@ public class ChessController { } Session remove = sessions.remove(existsUser); log.info("session closed by another session"); - remove.close(); + remove.close(new CloseReason(CloseReason.CloseCodes.NOT_CONSISTENT, "你的账号已在别处登录")); } for (String s : messageQueue) { this.onMessage(s, session); @@ -226,7 +226,7 @@ public class ChessController { for (Session value : sessions.values()) { if (!pingPong.getOrDefault(value, true)) { log.info("closed by connectionManager"); - value.close(); + value.close(new CloseReason(CloseReason.CloseCodes.CLOSED_ABNORMALLY, "链接延迟过高")); continue; } pingPong.put(value, false);