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) { + } + } } /**