From 8e0b2b23294ac1fdce43b9076b93e29e9aa51530 Mon Sep 17 00:00:00 2001
From: ‘liusuyi’ <1951119284@qq.com>
Date: 星期二, 12 三月 2024 09:37:25 +0800
Subject: [PATCH] 配置文件增加自定义tcp重连间隔时间
---
src/main/java/com/ard/utils/netty/tcp/ClientInitialize.java | 26 +++++++++++++-------------
1 files changed, 13 insertions(+), 13 deletions(-)
diff --git a/src/main/java/com/ard/utils/netty/tcp/ClientInitialize.java b/src/main/java/com/ard/utils/netty/tcp/ClientInitialize.java
index 131233a..db58ddb 100644
--- a/src/main/java/com/ard/utils/netty/tcp/ClientInitialize.java
+++ b/src/main/java/com/ard/utils/netty/tcp/ClientInitialize.java
@@ -74,7 +74,7 @@
}
});
}
- Thread.sleep(10000);
+ Thread.sleep(nettyTcpConfig.getReConnectInterval());
} catch (Exception e) {
log.error("Netty鍒濆鍖栭厤缃洃鍚湴鍧�鍑虹幇寮傚父");
e.printStackTrace();
@@ -135,22 +135,22 @@
/**
* 鐩戞祴闆疯揪杩炴帴鐘舵��
*/
- @Scheduled(cron = "0/5 * * * * ?")
+ @Scheduled(cron = "0/3 * * * * ?")
public void monitorConnectStatus() {
log.debug("瀹氭椂鐩戞祴闆疯揪杩炴帴鐘舵��");
List<ArdEquipRadar> ardEquipRadars = ardEquipRadarService.selectArdEquipRadarList(new ArdEquipRadar());
ardEquipRadars.stream().forEach(ardEquipRadar -> {
- if (ardEquipRadar.getState() == null || (ardEquipRadar.getState() != null && !ardEquipRadar.getState().equals("0"))) {
- ardEquipRadar.setState("0");
- ardEquipRadarService.updateArdEquipRadar(ardEquipRadar);
- }
- else
- {
- if (trueConnectMap.containsKey(ardEquipRadar.getIp() + ":" + ardEquipRadar.getPort())) {
- if (!ardEquipRadar.getState().equals("1")) {
- ardEquipRadar.setState("1");
- ardEquipRadarService.updateArdEquipRadar(ardEquipRadar);
- }
+
+ boolean online = trueConnectMap.containsKey(ardEquipRadar.getIp() + ":" + ardEquipRadar.getPort());
+ if (online) {
+ if (ardEquipRadar.getState() == null || !ardEquipRadar.getState().equals("1")) {
+ ardEquipRadar.setState("1");
+ ardEquipRadarService.updateArdEquipRadar(ardEquipRadar);
+ }
+ } else {
+ if (ardEquipRadar.getState() == null || !ardEquipRadar.getState().equals("0")) {
+ ardEquipRadar.setState("0");
+ ardEquipRadarService.updateArdEquipRadar(ardEquipRadar);
}
}
});
--
Gitblit v1.9.3