Imdroid/security-monitor
2
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

1、增加TCP连接过程打印，以便查看连接失败原因

Browse Source
This commit is contained in:
weidong 2025-07-19 09:49:26 +08:00
parent cef333b56b
commit 87d6f6073d
1 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
sec-beidou-fwd/src/main/java/com/imdroid/beidou_fwd/service/TCPClient.java
View File

@ -54,7 +54,7 @@ public class TCPClient {
} }
public void connect() { public void connect() {
logger.info("netty client starting"); logger.info("{}:{} tcp connecting...",host,port);
//启动客户端去连接服务器端 //启动客户端去连接服务器端
try { try {
ChannelFuture cf = bootstrap.connect(host, port); ChannelFuture cf = bootstrap.connect(host, port);
@ -62,9 +62,10 @@ public class TCPClient {
@Override @Override
public void operationComplete(ChannelFuture future) throws Exception { public void operationComplete(ChannelFuture future) throws Exception {
if (!future.isSuccess()) { if (!future.isSuccess()) {
logger.info("{}:{} tcp connect failed",host,port);
//重连交给后端线程执行 //重连交给后端线程执行
future.channel().eventLoop().schedule(() -> { future.channel().eventLoop().schedule(() -> {
logger.info("tcp client reconnect"); logger.info("{}:{} tcp client reconnect",host,port);
try { try {
connect(); connect();
} catch (Exception e) { } catch (Exception e) {
@ -72,7 +73,7 @@ public class TCPClient {
} }
}, 5000, TimeUnit.MILLISECONDS); }, 5000, TimeUnit.MILLISECONDS);
} else { } else {
logger.info("tcp client start success!"); logger.info("{}:{} tcp client start success!",host,port);
} }
} }
}); });
@ -80,7 +81,7 @@ public class TCPClient {
this.channel = cf.channel(); this.channel = cf.channel();
this.channel.closeFuture().sync(); this.channel.closeFuture().sync();
} catch (Exception e) { } catch (Exception e) {
logger.error("netty client error:", e); logger.error(host+":"+port+" tcp connect error:", e);
} }
} }