fix : Websocket 增加心跳

game-module/game-module-manage/src/main/java/com/zanxiang/game/module/manage/ManageApplication.java

@@ -23,7 +23,7 @@ public class ManageApplication {
 
     public static void main(String[] args) {
         SpringApplication.run(ManageApplication.class, args);
-        System.out.println("赞象Manage服务启动成功 <长连接测试> ( ´･･)ﾉ(._.`) \n" +
+        System.out.println("赞象Manage服务启动成功 <Websocket增加心跳机制> ( ´･･)ﾉ(._.`) \n" +
                 "___  ___  ___   _   _   ___  _____  _____ \n" +
                 "|  \\/  | / _ \\ | \\ | | / _ \\|  __ \\|  ___|\n" +
                 "| .  . |/ /_\\ \\|  \\| |/ /_\\ \\ |  \\/| |__  \n" +

game-module/game-module-manage/src/main/java/com/zanxiang/game/module/manage/enums/KfWebSocketMsgEnum.java

@@ -12,6 +12,11 @@ import lombok.Getter;
 @AllArgsConstructor
 public enum KfWebSocketMsgEnum {
 
+    /**
+     * 心跳
+     */
+    WEBSOCKET_MSG_CONNECT_HEART_BEAT("WEBSOCKET_MSG_CONNECT_HEART_BEAT"),
+
     /**
      * 握手, 接收前端消息, 返回游戏列表
      */

game-module/game-module-manage/src/main/java/com/zanxiang/game/module/manage/websocket/KfMsgWebsocketHandler.java

@@ -86,6 +86,11 @@ public class KfMsgWebsocketHandler implements WebSocketHandler {
             log.error("token验证失败, token : {}", token);
             return;
         }
+        //心跳
+        if (Objects.equals(webSocketMsgType, KfWebSocketMsgEnum.WEBSOCKET_MSG_CONNECT_HEART_BEAT)) {
+            log.error("收到客户端心跳消息, param : {}", JsonUtil.toString(param));
+            return;
+        }
         //握手-消息处理
         if (Objects.equals(webSocketMsgType, KfWebSocketMsgEnum.WEBSOCKET_MSG_KF_HAND_SHAKE)) {
             log.error("首次握手, kfUserId : {}", SecurityUtil.getUserId());