diff --git a/ruoyi-framework/src/main/java/com/ruoyi/framework/websocket/redisWebsocket/WebsocketEndpointImpl.java b/ruoyi-framework/src/main/java/com/ruoyi/framework/websocket/redisWebsocket/WebsocketEndpointImpl.java
index 56315b0..9c149c0 100644
--- a/ruoyi-framework/src/main/java/com/ruoyi/framework/websocket/redisWebsocket/WebsocketEndpointImpl.java
+++ b/ruoyi-framework/src/main/java/com/ruoyi/framework/websocket/redisWebsocket/WebsocketEndpointImpl.java
@@ -30,9 +30,13 @@ public class WebsocketEndpointImpl implements WebsocketEndpoint {
      */
     private static Map<String, Map<String, WebSocketBean>> webSocketInfo;
 
+    private static Map<String,WebSocketBean> concurrentHashMap;
+
     static {
         // concurrent包的线程安全map
         webSocketInfo = new ConcurrentHashMap<String, Map<String, WebSocketBean>>();
+
+        concurrentHashMap = new ConcurrentHashMap();
     }
 
 
@@ -40,19 +44,26 @@ public class WebsocketEndpointImpl implements WebsocketEndpoint {
     public void onOpen(Session session, EndpointConfig config, @PathParam("userId") String userId,@PathParam("projectId") String projectId) {
         WebSocketBean bean = new WebSocketBean();
         bean.setSession(session);
+/*
         Map<String,WebSocketBean> concurrentHashMap = new ConcurrentHashMap();
+*/
         concurrentHashMap.put(userId,bean);
         webSocketInfo.put(projectId, concurrentHashMap);
-        log.info("ws项目:"+projectId+",客户端连接服务器userId :" + userId + "当前连接数：" + countUser(projectId));
+        for (String userid:concurrentHashMap.keySet()){
+            log.info("ws项目:"+projectId+",客户端现连接userId :" + userid);
+        }
+        log.info("当前连接数：" + countUser(projectId));
     }
 
     @OnClose
     public void onClose(Session session, @PathParam("userId") String userId,@PathParam("projectId") String projectId) {
         // 客户端断开连接移除websocket对象
         Map<String,WebSocketBean> concurrentHashMap = webSocketInfo.get(projectId);
-        if(concurrentHashMap != null){concurrentHashMap.remove(userId);}
-        log.info("ws项目:"+projectId+",客户端断开连接，当前连接数：" + countUser(projectId));
-
+        if(concurrentHashMap != null){
+            concurrentHashMap.remove(userId);
+            log.info("ws项目:"+projectId+",客户端断开userId :" + userId);
+        }
+        log.info("当前连接数：" + countUser(projectId));
     }
 
     @OnMessage