From 396d93123c7afa3979694b6af20bd368c23135cf Mon Sep 17 00:00:00 2001
From: chanbook <648715275@qq.com>
Date: Fri, 5 Aug 2022 20:22:16 +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

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

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 8af3324..be45400 100644
--- a/src/main/java/com/zhangshu/chat/demo/websocket/ChatRoom.java
+++ b/src/main/java/com/zhangshu/chat/demo/websocket/ChatRoom.java
@@ -82,6 +82,7 @@ public class ChatRoom {
                 .map(RoomUserVo::getId)
                 .map(userSessionCache::get)
                 .map(sessionCache::get)
+                .filter(Objects::nonNull)
                 .forEach(v -> {
                     this.sendMessage(text, v);
                 });
@@ -96,6 +97,9 @@ public class ChatRoom {
      */
 
     private void sendMessage(String message, Session session) {
+        if (!session.isOpen()) {
+            return;
+        }
         try {
             session.getBasicRemote().sendText(message);
         } catch (IOException e) {