1

zj

2024-08-01 cc90152bc8eab5e26bd997a0fc5b06ae78bd2b0b

 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