From 70c4d6ea0bb88c249aeac160d596ce9d8da93032 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E7=99=BD=E5=87=A4=E5=90=89?= <baifengji@163.com>
Date: Wed, 19 Mar 2025 20:06:35 +0800
Subject: [PATCH] feat:ping pong

---
 src/main/java/com/qyft/ms/system/core/server/WebSocketServer.java | 8 +++++++-
 1 file changed, 7 insertions(+), 1 deletion(-)

diff --git a/src/main/java/com/qyft/ms/system/core/server/WebSocketServer.java b/src/main/java/com/qyft/ms/system/core/server/WebSocketServer.java
index 7c6dcf1..e5387f8 100644
--- a/src/main/java/com/qyft/ms/system/core/server/WebSocketServer.java
+++ b/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) {
+            }
+        }
     }
 
     /**