From c31ce6f3f0af9edd2cbd7e67d6470595b2d7e443 Mon Sep 17 00:00:00 2001
From: ludj <ldj_willow@163.com>
Date: Tue, 31 Jan 2023 21:09:28 +0800
Subject: [PATCH] =?UTF-8?q?ACS=E8=87=AA=E5=8A=A8=E9=87=8D=E8=BF=9E?=
 =?UTF-8?q?=E6=8F=90=E4=BA=A4?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../src/main/java/org/nl/acs/opc/OpcServerUtl.java       | 3 ++-
 .../src/main/java/org/nl/acs/opc/OpcUtl.java             | 9 +++++++++
 2 files changed, 11 insertions(+), 1 deletion(-)

diff --git a/acs/nladmin-system/src/main/java/org/nl/acs/opc/OpcServerUtl.java b/acs/nladmin-system/src/main/java/org/nl/acs/opc/OpcServerUtl.java
index 5cdc7eda2..3c693dca0 100644
--- a/acs/nladmin-system/src/main/java/org/nl/acs/opc/OpcServerUtl.java
+++ b/acs/nladmin-system/src/main/java/org/nl/acs/opc/OpcServerUtl.java
@@ -11,7 +11,8 @@ public class OpcServerUtl {
             if (domain == null) {
                 domain = "";
             }
-            return OpcUtl.getServer(host, clsid, user, password, domain);
+//            return OpcUtl.getServer(host, clsid, user, password, domain);
+            return OpcUtl.getAutoServer(host, clsid, user, password, domain);
         } else {
             return null;
         }
diff --git a/acs/nladmin-system/src/main/java/org/nl/acs/opc/OpcUtl.java b/acs/nladmin-system/src/main/java/org/nl/acs/opc/OpcUtl.java
index 2ec809262..6c8bc199d 100644
--- a/acs/nladmin-system/src/main/java/org/nl/acs/opc/OpcUtl.java
+++ b/acs/nladmin-system/src/main/java/org/nl/acs/opc/OpcUtl.java
@@ -159,6 +159,15 @@ public class OpcUtl {
         }
     }
 
+    public static Server getAutoServer(String host, String clsid, String user, String password, String domain) throws WDKException {
+        checkTimeout();
+        Server server = null;
+        server = new Server(getConnection(host, clsid, user, password, domain), Executors.newSingleThreadScheduledExecutor());
+        AutoReconnectController autoReconnectController = new AutoReconnectController(server);
+        autoReconnectController.connect();
+        return server;
+    }
+
     public static ConnectionInformation getConnection(String host, String clsid, String user, String password,
                                                       String domain) {
         ConnectionInformation connection = new ConnectionInformation();