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 6937706..f4f03c6 100644 --- a/src/main/java/com/zhangshu/chat/demo/websocket/ChatRoom.java +++ b/src/main/java/com/zhangshu/chat/demo/websocket/ChatRoom.java @@ -39,7 +39,7 @@ public class ChatRoom { */ @OnOpen public void onOpen(Session session, @PathParam("roomId") String roomId) { - if (getRoomCache().createSuccess(roomId)) { + if (!getRoomCache().createSuccess(roomId)) { this.sendMessage("无此房间,拒绝连接", session); return; }