From 85b0ee4bae215560010d0e6d0641705923a1aaa3 Mon Sep 17 00:00:00 2001
From: ‘liusuyi’ <1951119284@qq.com>
Date: 星期五, 03 十一月 2023 10:42:53 +0800
Subject: [PATCH] 优化工具类
---
src/main/java/com/ard/utils/tcp/ClientInitialize.java | 10 ++++++----
1 files changed, 6 insertions(+), 4 deletions(-)
diff --git a/src/main/java/com/ard/utils/tcp/ClientInitialize.java b/src/main/java/com/ard/utils/tcp/ClientInitialize.java
index 384e007..dfc0ca8 100644
--- a/src/main/java/com/ard/utils/tcp/ClientInitialize.java
+++ b/src/main/java/com/ard/utils/tcp/ClientInitialize.java
@@ -49,7 +49,7 @@
private Bootstrap bootstrap;
public static CopyOnWriteArraySet<ArdEquipRadar> falseConnectSet = new CopyOnWriteArraySet();
public static ConcurrentHashMap<ChannelId, ArdEquipRadar> tureConnectMap = new ConcurrentHashMap();
-
+ public static ConcurrentHashMap<String, Object> SuccessConnectMap = new ConcurrentHashMap();
/**
* Netty鍒濆鍖栭厤缃�
*/
@@ -104,18 +104,20 @@
// 寮傛杩炴帴tcp鏈嶅姟绔�
bootstrap.remoteAddress(host, port).connect().addListener((ChannelFuture futureListener) -> {
if (!futureListener.isSuccess()) {
- log.error("闆疯揪銆�" + host + ":" + port + "銆戣繛鎺ュけ璐�");
+ log.debug("闆疯揪銆�" + host + ":" + port + "銆戣繛鎺ュけ璐�");
futureListener.channel().close();
// 杩炴帴澶辫触淇℃伅鎻掑叆Set
falseConnectSet.add(ardEquipRadar);
// 杩炴帴澶辫触淇℃伅浠巑ap绉婚櫎
tureConnectMap.remove(futureListener.channel().id());
+ SuccessConnectMap.remove(ardEquipRadar.getId());
} else {
- log.info("闆疯揪銆�" + host + ":" + port + "銆戣繛鎺ユ垚鍔�");
+ log.debug("闆疯揪銆�" + host + ":" + port + "銆戣繛鎺ユ垚鍔�");
// 杩炴帴鎴愬姛淇℃伅浠嶴et鎷旈櫎
falseConnectSet.remove(ardEquipRadar);
// 杩炴帴鎴愬姛淇℃伅鍐欏叆map
tureConnectMap.put(futureListener.channel().id(), ardEquipRadar);
+ SuccessConnectMap.put(ardEquipRadar.getId(),futureListener.channel());
}
});
}
@@ -124,7 +126,7 @@
* 鍒濆鍖栨柟娉�
*/
@Override
- public void run(ApplicationArguments args) throws Exception {
+ public void run(ApplicationArguments args) {
if (!tcpClientEnable) {
return;
}
--
Gitblit v1.9.3