websocket日志增加

soc-modules/soc-modules-mediator/src/main/java/com/xunmei/mediator/websocket/handler/SocWebSocketHandler.java

@@ -66,7 +66,7 @@ public class SocWebSocketHandler extends AbstractWebSocketHandler {
             }
             WebsocketResult register = createWebsocketResult(null, "register", map);
             WebSocketUtils.sendMessage(session, JacksonUtils.toJSONString(register));
-            log.info("[建立注册连接] sessionId: {},registerCode:{}", session.getId(), registerCode);
+            LogUtils.WEBSOCKET_MSG.info("[建立注册连接] sessionId: {},registerCode:{}", session.getId(), registerCode);
             session.close();
             return;
         }
@@ -83,7 +83,7 @@ public class SocWebSocketHandler extends AbstractWebSocketHandler {
             map.put("statusCode", WebsocketStatus.SUCCESS.getStatusCode());
             WebsocketResult result = createWebsocketResult(null, "login", map);
             WebSocketUtils.sendMessage(session, JacksonUtils.toJSONString(result));
-            log.info("[建立连接] sessionId: {},token:{}", session.getId(), token);
+            LogUtils.WEBSOCKET_MSG.info("[建立连接] sessionId: {},token:{}", session.getId(), token);
             return;
         }
         session.close();

soc-modules/soc-modules-mediator/src/main/java/com/xunmei/mediator/websocket/interceptor/WebSocketInterceptor.java

@@ -1,8 +1,6 @@
 package com.xunmei.mediator.websocket.interceptor;
 
-import com.xunmei.common.core.utils.StringUtils;
-import com.xunmei.mediator.websocket.holder.WebSocketSessionHolder;
-import com.xunmei.mediator.websocket.utils.WebSocketUtils;
+import com.xunmei.system.api.util.LogUtils;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.http.server.ServerHttpRequest;
 import org.springframework.http.server.ServerHttpResponse;
@@ -37,6 +35,7 @@ public class WebSocketInterceptor implements HandshakeInterceptor {
      */
     @Override
     public boolean beforeHandshake(ServerHttpRequest request, ServerHttpResponse response, WebSocketHandler wsHandler, Map<String, Object> attributes) throws Exception {
+        LogUtils.WEBSOCKET_MSG.info("接收到链接请求");
         // 从请求中获取查询参数并存入attributes中
         String queryString = request.getURI().getQuery();
         if (queryString != null) {
@@ -62,6 +61,6 @@ public class WebSocketInterceptor implements HandshakeInterceptor {
     @Override
     public void afterHandshake(ServerHttpRequest request, ServerHttpResponse response, WebSocketHandler wsHandler, Exception exception) {
         // 在这个方法中可以执行一些握手成功后的后续处理逻辑，比如记录日志或者其他操作
-        log.info("WebSocket握手成功");
+        LogUtils.WEBSOCKET_MSG.info("WebSocket握手成功");
     }
 }