From 65b02c3e901dc25a98ecf7bcee989b4ea0998a8c Mon Sep 17 00:00:00 2001 From: weidong Date: Mon, 26 May 2025 09:40:49 +0800 Subject: [PATCH] =?UTF-8?q?1=E3=80=81=E5=9B=9E=E9=80=80=E5=8F=82=E6=95=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/imdroid/beidou_fwd/task/GXXfzForwarder.java | 6 +++--- .../java/com/imdroid/beidou_fwd/task/GZYMQTTForwarder.java | 4 ++-- 2 files changed, 5 insertions(+), 5 deletions(-) diff --git a/sec-beidou-fwd/src/main/java/com/imdroid/beidou_fwd/task/GXXfzForwarder.java b/sec-beidou-fwd/src/main/java/com/imdroid/beidou_fwd/task/GXXfzForwarder.java index 13382535..e185a2fd 100644 --- a/sec-beidou-fwd/src/main/java/com/imdroid/beidou_fwd/task/GXXfzForwarder.java +++ b/sec-beidou-fwd/src/main/java/com/imdroid/beidou_fwd/task/GXXfzForwarder.java @@ -122,9 +122,9 @@ public class GXXfzForwarder extends Forwarder{ } boolean checkResult() throws InterruptedException { - // 等待应答，最多等0.5s - for(int i=0; i<25; i++){ - Thread.sleep(20); + // 等待应答，最多等1s + for(int i=0; i<10; i++){ + Thread.sleep(100); if(listener.state == XFZTCPListener.STATE_OK) return true; else if(listener.state == XFZTCPListener.STATE_FAILED) return false; } diff --git a/sec-beidou-fwd/src/main/java/com/imdroid/beidou_fwd/task/GZYMQTTForwarder.java b/sec-beidou-fwd/src/main/java/com/imdroid/beidou_fwd/task/GZYMQTTForwarder.java index 7974a84f..9b95def6 100644 --- a/sec-beidou-fwd/src/main/java/com/imdroid/beidou_fwd/task/GZYMQTTForwarder.java +++ b/sec-beidou-fwd/src/main/java/com/imdroid/beidou_fwd/task/GZYMQTTForwarder.java @@ -80,7 +80,7 @@ public class GZYMQTTForwarder extends Forwarder { logger.info("forward to GZY mqtt: {}",json); try { if(!mqttClient.publish(topic, json)) break; - Thread.sleep(20); + Thread.sleep(50); } catch (Exception e1) { e1.printStackTrace(); } @@ -119,7 +119,7 @@ public class GZYMQTTForwarder extends Forwarder { logger.info("forward to GZY mqtt angles: {}",json); try { if(!mqttClient.publish(topic, json)) break; - Thread.sleep(20); + Thread.sleep(10); } catch (Exception e1) { e1.printStackTrace(); }