From cc90152bc8eab5e26bd997a0fc5b06ae78bd2b0b Mon Sep 17 00:00:00 2001
From: zj <1772600164@qq.com>
Date: Thu, 01 Aug 2024 17:52:26 +0800
Subject: [PATCH] 1
---
websocketSerivce/src/main/java/org/example/websocket/server/WsServer.java | 4 ++--
1 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/websocketSerivce/src/main/java/org/example/websocket/server/WsServer.java b/websocketSerivce/src/main/java/org/example/websocket/server/WsServer.java
index 18e0dcc..ea4cce4 100644
--- a/websocketSerivce/src/main/java/org/example/websocket/server/WsServer.java
+++ b/websocketSerivce/src/main/java/org/example/websocket/server/WsServer.java
@@ -69,7 +69,7 @@
public void onOpen(Session session) {
WsBo wsBo = getWsBoForSession(session.getId());
String s = RedisUtil.get("user_" + wsBo.getUserId());
- if(null == s || s.isEmpty()){
+ if(null == s || s.isEmpty() && !wsBo.getToken().equals(s)){
closeSession(session, "用户未登录");
}
this.session = session;
@@ -88,7 +88,7 @@
private boolean hasReceivedSubscription(Session session) {
WsBo wsBo = getWsBoForSession(session.getId());
- return wsBo != null; // 简化逻辑
+ return wsBo != null;
}
@OnError
--
Gitblit v1.9.3