websocket 心跳

src/main/java/com/izouma/nineth/websocket/WebSocket.java

@@ -135,6 +135,11 @@ public class WebSocket extends WebsocketCommon{
             log.error("Illegal parameter : message can not be null");
             return;
         }
+        if ("META_PING".equals(message)) {
+            log.info(String.format("sessionId:[%S] userId:[%S] 连接正常", session.getId(), userId));
+            sendMessageTo(clients, "META_PONG", REDIS_PREFIX.concat(userId));
+            return;
+        }
         JSONObject jsonObject = JSON.parseObject(message);
         MetaServiceResult result = checkParams(jsonObject);
         if (!result.isSuccess()) {