增加websocket

Author: BookshelfBlog

springboot-websocket/src/main/java/com/dev/websocket/config/SendMessage.java

@@ -51,7 +51,7 @@ public void onOpen(Session session, @PathParam("userId") String userId) {
         } catch (IOException e) {
             e.printStackTrace();
         }
-        log.info("有新连接加入：{}，当前在线人数为：{}", session.getId(), onlineCount.get());
+        log.info("用户：{}加入连接，当前在线人数为：{}", userId, onlineCount.get());
     }
 
     /**
@@ -86,7 +86,7 @@ public void onMessage(String message, Session session) throws IOException {
             }
         }
 
-        log.info("服务端收到客户端[{}]的消息:{}", session.getId(), message);
+        log.info("服务端收到客户端[{}]的消息:{}", userId, message);
     }
 
     @OnError

springboot-websocket/src/main/java/com/dev/websocket/config/SendObjectMessage.java

@@ -39,7 +39,7 @@ public void onOpen(Session session) {
         } catch (IOException e) {
             e.printStackTrace();
         }
-        log.info("有新连接加入：{}，当前在线人数为：{}", session.getId(), onlineCount.get());
+        log.info("有新连接加入，当前在线人数为：{}", onlineCount.get());
     }
 
     /**
@@ -50,7 +50,7 @@ public void onClose(Session session) {
         socket.remove(this);
         // 在线数减1
         onlineCount.decrementAndGet();
-        log.info("用户退出，当前在线人数为：{}", session.getId(), onlineCount.get());
+        log.info("用户退出，当前在线人数为：{}", onlineCount.get());
     }
 
     /**
@@ -66,7 +66,7 @@ public void onMessage(String message, Session session) throws IOException {
                 sendObjectMessage.sendMessage(message);
             }
         }
-        log.info("服务端收到客户端[{}]的消息:{}", session.getId(), message);
+        log.info("服务端收到客户端的消息:{}", message);
     }
 
     @OnError