From c7b1438d02fa95b35c3533c62d82dd65ce59d96c Mon Sep 17 00:00:00 2001
From: weidong <weidong@im-droid.com>
Date: Fri, 20 Jun 2025 18:58:56 +0800
Subject: [PATCH] =?UTF-8?q?1=E3=80=81=E4=BC=98=E5=8C=96MQTT=E5=88=9D?=
 =?UTF-8?q?=E5=A7=8B=E8=BF=9E=E6=8E=A5?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../imdroid/beidou_fwd/service/MQTTClient.java  |  4 ++++
 .../imdroid/beidou_fwd/task/GXJKForwarder.java  | 17 +++++++++++++++--
 2 files changed, 19 insertions(+), 2 deletions(-)

diff --git a/sec-beidou-fwd/src/main/java/com/imdroid/beidou_fwd/service/MQTTClient.java b/sec-beidou-fwd/src/main/java/com/imdroid/beidou_fwd/service/MQTTClient.java
index 54a4fd59..8e739912 100644
--- a/sec-beidou-fwd/src/main/java/com/imdroid/beidou_fwd/service/MQTTClient.java
+++ b/sec-beidou-fwd/src/main/java/com/imdroid/beidou_fwd/service/MQTTClient.java
@@ -41,6 +41,10 @@ public class MQTTClient {
         client.connect(options);
     }
 
+    public boolean isConnected(){
+        return client.isConnected();
+    }
+
     public boolean publish(String topic, String message) {
         if(!client.isConnected()){
             logger.info("mqtt disconnected");
diff --git a/sec-beidou-fwd/src/main/java/com/imdroid/beidou_fwd/task/GXJKForwarder.java b/sec-beidou-fwd/src/main/java/com/imdroid/beidou_fwd/task/GXJKForwarder.java
index 55abb893..544afbb6 100644
--- a/sec-beidou-fwd/src/main/java/com/imdroid/beidou_fwd/task/GXJKForwarder.java
+++ b/sec-beidou-fwd/src/main/java/com/imdroid/beidou_fwd/task/GXJKForwarder.java
@@ -38,7 +38,12 @@ public class GXJKForwarder extends Forwarder {
     void registerMe() throws MqttException {
         init(FORWARDER_NAME, "MQTT "+brokerUrl,7,FWD_DEVICE_NAME,10);
         mqttClient = new MQTTClient(brokerUrl, username, password,clientid);
-        mqttClient.connect();
+        try{
+            mqttClient.connect();
+        }
+        catch (Exception e){
+
+        }
     }
 
     /**
@@ -47,7 +52,15 @@ public class GXJKForwarder extends Forwarder {
     @Scheduled(cron = "0 0/10 * * * ?") // 每30分钟执行一次
     private void forwardGnss() {
         logger.debug("gxjk forwardGnss");
-        forwardCurrentGnss();
+        if(mqttClient.isConnected()) forwardCurrentGnss();
+        else{
+            try{
+                mqttClient.connect();
+            }
+            catch (Exception e){
+
+            }
+        }
     }
 
     @Override