1

njzscloud-localizer-svr/src/main/java/com/njzscloud/localizer/config/OnStarted.java

@@ -165,7 +165,7 @@ public class OnStarted {
 
                         List<TruckLocationTrackEntity> records = resultPage.getRecords();
                         if (records.isEmpty()) {
-                            if (errCount >= 200 * 5) {
+                            if (errCount >= 300) {
                                 log.error("暂无实时数据, 车牌号: {}, 时间: {}", licensePlate, startTime);
                                 Websocket.publish(new WsMsg()
                                         .setEvent("down/truck_location_track/realtime")
@@ -175,11 +175,11 @@ public class OnStarted {
                                 return;
                             }
                             errCount++;
-                            if (!ThreadUtil.sleep(300)) {
+                            if (!ThreadUtil.sleep(1000)) {
                                 log.info("任务被取消");
                                 return;
                             } else {
-                                startTime = LocalDateTime.now();
+                                // startTime = startTime.plusSeconds(1);
                                 continue;
                             }
                         }

z-doc/websocket-tester.html

@@ -369,6 +369,7 @@
 
   // WebSocket实例
   let websocket = null;
+  let ii = null;
 
   // 连接WebSocket
   connectBtn.addEventListener('click', () => {
@@ -389,7 +390,7 @@
     try {
       // 创建WebSocket连接
       url = `${url}`;
-      websocket = new WebSocket(url);
+      websocket = new WebSocket("wss://admin.dzzszy.com/api/fdx");
 
       // 连接成功
       websocket.onopen = () => {
@@ -398,6 +399,9 @@
 
         // 显示连接详情
         connectionDetails.textContent = `地址: ${url}`;
+        ii = setInterval(() => {
+          websocket.send("{\"action\":\"ping\",\"event\":\"ping\"}")
+        }, 10000)
       };
 
       // 接收消息
@@ -410,15 +414,27 @@
         updateConnectionStatus(false);
         addSystemMessage(`连接已关闭 (代码: ${event.code}, 原因: ${event.reason || '无'})`);
         connectionDetails.textContent = '未连接到服务器';
+        if (ii != null) {
+          clearInterval(ii)
+          ii = null
+        }
       };
 
       // 连接错误
       websocket.onerror = (error) => {
         addSystemMessage(`发生错误: ${error.message || '未知错误'}`, true);
+        if (ii != null) {
+          clearInterval(ii)
+          ii = null
+        }
       };
     } catch (error) {
       alert(`连接失败: ${error.message}`);
       updateConnectionStatus(false);
+      if (ii != null) {
+        clearInterval(ii)
+        ii = null
+      }
     }
   });