feat:ping pong

src/main/java/com/qyft/ms/system/core/server/WebSocketServer.java

@@ -5,6 +5,7 @@ import jakarta.websocket.server.ServerEndpoint;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Component;
 
+import java.io.IOException;
 import java.util.Set;
 import java.util.concurrent.CopyOnWriteArraySet;
 
@@ -51,8 +52,13 @@ public class WebSocketServer {
      */
     @OnMessage
     public void onMessage(String message, Session session) {
-        log.info("接收到来自客户端(sessionId={})的消息：{}", session.getId(), message);
         // 根据业务需求处理消息，此处可添加进一步的处理逻辑
+        if("{\"type\":\"ping\"}".equals(message)) {
+            try {
+                session.getBasicRemote().sendText("{\"type\":\"pong\"}");
+            } catch (IOException ignored) {
+            }
+        }
     }
 
     /**