From a20fba56c57a6ab56390fa4dd1f7c70000a6f958 Mon Sep 17 00:00:00 2001
From: qiezi <15576055375@163.com>
Date: Fri, 25 Oct 2024 13:02:50 +0800
Subject: [PATCH] 20241025

---
 .../com/xujie/sys/modules/reader/config/TCPClient.java   | 9 ++++-----
 1 file changed, 4 insertions(+), 5 deletions(-)

diff --git a/src/main/java/com/xujie/sys/modules/reader/config/TCPClient.java b/src/main/java/com/xujie/sys/modules/reader/config/TCPClient.java
index 3abde8ef..5e3a400a 100644
--- a/src/main/java/com/xujie/sys/modules/reader/config/TCPClient.java
+++ b/src/main/java/com/xujie/sys/modules/reader/config/TCPClient.java
@@ -49,11 +49,9 @@ public class TCPClient {
         for (EquipmentFolderLocation config : serverConfigs) {
             executorService.submit(() -> connectAndRead(config));
             // 为每个设备配置一个定时任务，定期检测连接状态
-            if (false){
-                scheduler.scheduleWithFixedDelay(() -> {
-                    checkConnection(config);
-                }, CHECK_INTERVAL, CHECK_INTERVAL, TimeUnit.SECONDS);
-            }
+            scheduler.scheduleWithFixedDelay(() -> {
+                checkConnection(config);
+            }, CHECK_INTERVAL, CHECK_INTERVAL, TimeUnit.SECONDS);
         }
     }
 
@@ -98,6 +96,7 @@ public class TCPClient {
 
         } catch (IOException e) {
             log.error("连接设备失败或读取数据时发生错误, IP: {}, Port: {}", config.getIp(), config.getPort(), e);
+            closeConnection(key);
         } finally {
             try {
                 if (in != null) {