diff --git a/src/main/java/com/spring/modules/cdc/task/GatherDataTask.java b/src/main/java/com/spring/modules/cdc/task/GatherDataTask.java
index 208b878c..08a180fc 100644
--- a/src/main/java/com/spring/modules/cdc/task/GatherDataTask.java
+++ b/src/main/java/com/spring/modules/cdc/task/GatherDataTask.java
@@ -101,6 +101,7 @@ public class GatherDataTask {
                         collectRecordService.insertCollectRecord(collectRecord);
                         collectRecordService.updateCollectCurrentValue(collectRecord);
                     }
+                    siemensS7Net.ConnectClose();
                 }else {
                     log.info("IP:{} 连接失败",ip);
                     for (Device device : deviceList) {
@@ -126,6 +127,7 @@ public class GatherDataTask {
                         collectRecordService.insertCollectRecord(collectRecord);
                         collectRecordService.updateCollectCurrentValue(collectRecord);
                     }
+                    melsecMcNet.ConnectClose();
                 }else {
                     log.info("IP:{} 连接失败",ip);
                     for (Device device : deviceList) {