From 082aedafdf74450d4b2bdaa28127d3689403b999 Mon Sep 17 00:00:00 2001
From: chanbook <648715275@qq.com>
Date: Mon, 8 Aug 2022 16:51:31 +0800
Subject: [PATCH] =?UTF-8?q?=E8=81=8A=E5=A4=A9=E5=AE=A4=E4=BF=A1=E6=81=AF?=
 =?UTF-8?q?=E5=8F=91=E9=80=81?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../java/com/zhangshu/chat/demo/websocket/ChatRoom.java   | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

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 3285974..6937706 100644
--- a/src/main/java/com/zhangshu/chat/demo/websocket/ChatRoom.java
+++ b/src/main/java/com/zhangshu/chat/demo/websocket/ChatRoom.java
@@ -39,10 +39,10 @@ public class ChatRoom {
      */
     @OnOpen
     public void onOpen(Session session, @PathParam("roomId") String roomId) {
-//        if (getRoomCache().createSuccess(roomId)) {
-//            this.sendMessage("无此房间，拒绝连接", session);
-//            return;
-//        }
+        if (getRoomCache().createSuccess(roomId)) {
+            this.sendMessage("无此房间，拒绝连接", session);
+            return;
+        }
         Principal userPrincipal = session.getUserPrincipal();
         if (Objects.isNull(userPrincipal)) {
             this.sendMessage("用户验证失败，拒绝连接", session);