diff --git a/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/message/handle/AnalysisHandler.java b/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/message/handle/AnalysisHandler.java
index b6fde5bf..a7bf1dee 100644
--- a/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/message/handle/AnalysisHandler.java
+++ b/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/message/handle/AnalysisHandler.java
@@ -1,6 +1,7 @@
 package org.jeecg.modules.message.handle;
 
 import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.ObjectUtils;
 import org.jeecg.common.base.BaseMap;
 import org.jeecg.common.constant.WebSocketHandlerConst;
 import org.jeecg.common.modules.redis.listener.JeecgRedisListener;
@@ -24,6 +25,9 @@ public class AnalysisHandler implements JeecgRedisListener {
 
     @Override
     public void onMessage(BaseMap message) {
+        if (ObjectUtils.isEmpty(message.get("userId"))) {
+            return;
+        }
         webSocket.sendMessage(message.get("userId").toString(), message.get("message"));
     }