浏览代码

websocket新增心跳

zhoufan 2 年之前
父节点
当前提交
c872ce440a
共有 1 个文件被更改,包括 9 次插入0 次删除
  1. 9 0
      zxkf-service/src/main/java/api/service/websocket/WebSocket.java

+ 9 - 0
zxkf-service/src/main/java/api/service/websocket/WebSocket.java

@@ -133,6 +133,15 @@ public class WebSocket {
133 133
         MessageInput mv = JSON.parseObject(message, MessageInput.class);
134 134
         if (mv != null) {
135 135
             String type = mv.getType();
136
+            if(type.equals("heart")){
137
+                MessageView mvh = new MessageView();
138
+                mvh.setStatus("success");
139
+                mvh.setType(type);
140
+                mvh.setContent(mv.getContent());
141
+                session.getAsyncRemote().sendText(JSON.toJSONString(mvh));
142
+                return;
143
+            }
144
+
136 145
             String content = mv.getContent();
137 146
             Message msg = new Message();
138 147
             msg.setCreateTime(new Date());