소스 검색

AgentWebSocketHandler 处理 PingMessage

reghao 1 년 전
부모
커밋
cdfb96a19c
1개의 변경된 파일3개의 추가작업 그리고 0개의 파일을 삭제
  1. 3 0
      web/src/main/java/cn/reghao/devops/web/ws/handler/AgentWebSocketHandler.java

+ 3 - 0
web/src/main/java/cn/reghao/devops/web/ws/handler/AgentWebSocketHandler.java

@@ -57,6 +57,9 @@ public class AgentWebSocketHandler implements WebSocketHandler {
                     EventMessage eventMessage = (EventMessage) obj;
                     eventCenter.dispatch(eventMessage);
                 }
+            } else if (webSocketMessage instanceof PingMessage) {
+                log.info("收到来自 {} 的 PingMessage 消息", webSocketSession.getId());
+                webSocketSession.sendMessage(new PongMessage());
             } else if (webSocketMessage instanceof PongMessage) {
                 log.info("收到来自 {} 的 PongMessage 消息", webSocketSession.getId());
             } else {