feat: adding close reason

This commit is contained in:
wzp 2024-12-17 12:46:10 +08:00
parent 70eff21bd9
commit ab24dfa1d1

View File

@ -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);