xintiao

src/main/java/com/hzjt/handler/WebSocket.java

@@ -2,6 +2,7 @@ package com.hzjt.handler;
 
 import cn.hutool.json.JSONUtil;
 import com.hzjt.service.TraffFlowService;
+import com.hzjt.util.DateUtils;
 import com.hzjt.util.JsonUtil;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Component;
@@ -9,9 +10,7 @@ import org.springframework.stereotype.Component;
 import javax.websocket.*;
 import javax.websocket.server.PathParam;
 import javax.websocket.server.ServerEndpoint;
-import java.util.ArrayList;
-import java.util.List;
-import java.util.Map;
+import java.util.*;
 import java.util.concurrent.ConcurrentHashMap;
 
 @Slf4j
@@ -85,6 +84,13 @@ public class WebSocket {
             }
 
         }
+
+        if(message.indexOf("HEARTBEAT")>=0){
+            Map map=new HashMap();
+            map.put("type","HEARTBEAT");
+            map.put("ts",new Date().getTime());
+            AppointSending(name, JSONUtil.toJsonStr(map));
+        }
     }
 
     /**