diff --git a/src/main/java/com/zhangshu/chat/demo/websocket/ChatRoom.java b/src/main/java/com/zhangshu/chat/demo/websocket/ChatRoom.java index 4a7cda0..89abb4e 100644 --- a/src/main/java/com/zhangshu/chat/demo/websocket/ChatRoom.java +++ b/src/main/java/com/zhangshu/chat/demo/websocket/ChatRoom.java @@ -38,7 +38,7 @@ public class ChatRoom { */ @OnOpen public void onOpen(Session session, @PathParam("userId") Long userId) { - if (roomCache.isExistUser(userId)) { + if (!roomCache.isExistUser(userId)) { sendMessage("用户不在房间中,拒绝连接", session); return; }