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 642e6477..84491bc1 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
@@ -47,7 +47,12 @@ public class GZYMQTTForwarder extends Forwarder {
     void registerMe() throws MqttException {
         init(FORWARDER_NAME, "MQTT "+brokerUrl,2,FWD_DEVICE_ALIAS_NAME,30);
         mqttClient = new MQTTClient(brokerUrl, username, password,clientid);
-        mqttClient.connect();
+        try{
+            mqttClient.connect();
+        }
+        catch (Exception e){
+            logger.error("gzy mqtt connect failed: {}",e.toString());
+        }
     }
 
     /**
@@ -57,8 +62,18 @@ public class GZYMQTTForwarder extends Forwarder {
     //@Scheduled(cron = "0 0/5 * * * ?") // 每30分钟执行一次
     private void forwardGnss() {
         logger.debug("gzy mqtt forwardGnss");
-        forwardCurrentGnss();
-        //forwardAngleData();
+        if(mqttClient.isConnected()) {
+            forwardCurrentGnss();
+            //forwardAngleData();
+        }
+        else{
+            try{
+                mqttClient.connect();
+            }
+            catch (Exception e){
+                logger.error("gzy mqtt connect failed: {}",e.toString());
+            }
+        }
     }
 
     @Override
diff --git a/sec-beidou-fwd/src/main/java/com/imdroid/beidou_fwd/task/ZNYMQTTForwarder.java b/sec-beidou-fwd/src/main/java/com/imdroid/beidou_fwd/task/ZNYMQTTForwarder.java
index 9bb9e550..7010a9c0 100644
--- a/sec-beidou-fwd/src/main/java/com/imdroid/beidou_fwd/task/ZNYMQTTForwarder.java
+++ b/sec-beidou-fwd/src/main/java/com/imdroid/beidou_fwd/task/ZNYMQTTForwarder.java
@@ -49,7 +49,12 @@ public class ZNYMQTTForwarder extends Forwarder {
     void registerMe() throws MqttException {
         init(FORWARDER_NAME, "MQTT "+brokerUrl,4,FWD_DEVICE_ALIAS_NAME,30);
         mqttClient = new MQTTClient(brokerUrl, username, password,clientid);
-        mqttClient.connect();
+        try{
+            mqttClient.connect();
+        }
+        catch (Exception e){
+            logger.error("zny mqtt connect failed: {}",e.toString());
+        }
     }
 
     /**
@@ -59,8 +64,15 @@ public class ZNYMQTTForwarder extends Forwarder {
     @Scheduled(cron = "0 0/30 * * * ?") // 每30分钟执行一次
     private void forwardGnss() {
         logger.debug("zny mqtt forwardGnss");
-        forwardCurrentGnss();
-        //forwardAngleData();
+        if(mqttClient.isConnected()) forwardCurrentGnss();
+        else{
+            try{
+                mqttClient.connect();
+            }
+            catch (Exception e){
+                logger.error("zny mqtt connect failed: {}",e.toString());
+            }
+        }
     }
 
     @Override