From 8c3c81d523ae96b7fe843de736ac1bad64509fed Mon Sep 17 00:00:00 2001
From: liyj <1617420630@qq.com>
Date: Thu, 13 Nov 2025 18:47:03 +0800
Subject: [PATCH] =?UTF-8?q?im=E5=AE=A2=E6=9C=8D=E9=97=AE=E9=A2=98=E4=BF=AE?=
 =?UTF-8?q?=E6=94=B9?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../websocket/service/onchat/MallsuiteImSocketHandler.java  | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/mall-im/src/main/java/com/suisung/mall/im/common/websocket/service/onchat/MallsuiteImSocketHandler.java b/mall-im/src/main/java/com/suisung/mall/im/common/websocket/service/onchat/MallsuiteImSocketHandler.java
index 38fb372e..e1acddba 100644
--- a/mall-im/src/main/java/com/suisung/mall/im/common/websocket/service/onchat/MallsuiteImSocketHandler.java
+++ b/mall-im/src/main/java/com/suisung/mall/im/common/websocket/service/onchat/MallsuiteImSocketHandler.java
@@ -1,11 +1,9 @@
 package com.suisung.mall.im.common.websocket.service.onchat;
 
-import cn.hutool.core.collection.CollUtil;
 import cn.hutool.core.convert.Convert;
 import cn.hutool.core.util.IdUtil;
 import cn.hutool.json.JSONUtil;
 import com.suisung.mall.common.feignService.AccountService;
-import com.suisung.mall.common.utils.CheckUtil;
 import com.suisung.mall.im.common.websocket.service.DistributedMessageService;
 import com.suisung.mall.im.common.websocket.service.DistributedSessionService;
 import com.suisung.mall.im.common.websocket.service.LocalSessionManager;
@@ -65,6 +63,8 @@ public class MallsuiteImSocketHandler implements WebSocketHandler {
         // 存储到本地会话管理
         localSessionManager.addUserSession(loginUserId, session);
 
+        logger.info("添加会话到本地成功：{}", localSessionManager.userSessions.values());
+
         // 注册到分布式会话服务
         Map<String, Object> attributes = new HashMap<>();
         attributes.put("user_id", session.getAttributes().get("user_id"));
@@ -306,7 +306,7 @@ public class MallsuiteImSocketHandler implements WebSocketHandler {
         // 获取本地所有用户会话
         for (List<WebSocketSession> sessions : localSessionManager.userSessions.values()) {
             for (WebSocketSession session : sessions) {
-                if (session.isOpen()) {
+                if (session!=null&&session.isOpen()) {
                     try {
                         session.sendMessage(new TextMessage(message.toString()));
                     } catch (IOException e) {