diff --git a/sec-beidou-fwd/src/main/java/com/imdroid/beidou_fwd/service/TCPClient.java b/sec-beidou-fwd/src/main/java/com/imdroid/beidou_fwd/service/TCPClient.java index 84508d9f..70b67973 100644 --- a/sec-beidou-fwd/src/main/java/com/imdroid/beidou_fwd/service/TCPClient.java +++ b/sec-beidou-fwd/src/main/java/com/imdroid/beidou_fwd/service/TCPClient.java @@ -54,7 +54,7 @@ public class TCPClient { } public void connect() { - logger.info("netty client starting"); + logger.info("{}:{} tcp connecting...",host,port); //启动客户端去连接服务器端 try { ChannelFuture cf = bootstrap.connect(host, port); @@ -62,9 +62,10 @@ public class TCPClient { @Override public void operationComplete(ChannelFuture future) throws Exception { if (!future.isSuccess()) { + logger.info("{}:{} tcp connect failed",host,port); //重连交给后端线程执行 future.channel().eventLoop().schedule(() -> { - logger.info("tcp client reconnect"); + logger.info("{}:{} tcp client reconnect",host,port); try { connect(); } catch (Exception e) { @@ -72,7 +73,7 @@ public class TCPClient { } }, 5000, TimeUnit.MILLISECONDS); } 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.closeFuture().sync(); } catch (Exception e) { - logger.error("netty client error:", e); + logger.error(host+":"+port+" tcp connect error:", e); } }