diff --git a/cloud-modules/cloud-modules-protocol-analysis/src/main/java/com/muyu/analysis/parsing/MQTT/service/MqttClientService.java b/cloud-modules/cloud-modules-protocol-analysis/src/main/java/com/muyu/analysis/parsing/MQTT/service/MqttClientService.java
index 02e1396..2113df5 100644
--- a/cloud-modules/cloud-modules-protocol-analysis/src/main/java/com/muyu/analysis/parsing/MQTT/service/MqttClientService.java
+++ b/cloud-modules/cloud-modules-protocol-analysis/src/main/java/com/muyu/analysis/parsing/MQTT/service/MqttClientService.java
@@ -53,10 +53,10 @@ public class MqttClientService {
     }
 
     private void connectAndSubscribe(MqttProperties mqttProperties) throws MqttException, IOException {
-//        if (sampleClient != null && sampleClient.isConnected()) {
-//            log.info("MQTT客户端已经连接，跳过重新连接。");
-//            return;
-//        }
+        if (sampleClient != null && sampleClient.isConnected()) {
+            log.info("MQTT客户端已经连接，跳过重新连接。");
+            return;
+        }
 
         sampleClient = new MqttClient(mqttProperties.getBroker(), mqttProperties.getClientId());
         MqttConnectOptions connOpts = new MqttConnectOptions();