root/lanzhouhailiang_one
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

ACS自动重连提交

Browse Source
This commit is contained in:
ludj
2023-01-31 21:09:28 +08:00
parent c73e27a3c6
commit c31ce6f3f0
2 changed files with 11 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
acs/nladmin-system/src/main/java/org/nl/acs/opc/OpcServerUtl.java
View File

@@ -11,7 +11,8 @@ public class OpcServerUtl {
if (domain == null) { if (domain == null) {
domain = ""; 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 { } else {
return null; return null;
} }

9
acs/nladmin-system/src/main/java/org/nl/acs/opc/OpcUtl.java
View File

@@ -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, public static ConnectionInformation getConnection(String host, String clsid, String user, String password,
String domain) { String domain) {
ConnectionInformation connection = new ConnectionInformation(); ConnectionInformation connection = new ConnectionInformation();