From 87d6f6073d6904437c306c9c46c31a33951965c3 Mon Sep 17 00:00:00 2001
From: weidong <weidong@im-droid.com>
Date: Sat, 19 Jul 2025 09:49:26 +0800
Subject: [PATCH] =?UTF-8?q?1=E3=80=81=E5=A2=9E=E5=8A=A0TCP=E8=BF=9E?=
 =?UTF-8?q?=E6=8E=A5=E8=BF=87=E7=A8=8B=E6=89=93=E5=8D=B0=EF=BC=8C=E4=BB=A5?=
 =?UTF-8?q?=E4=BE=BF=E6=9F=A5=E7=9C=8B=E8=BF=9E=E6=8E=A5=E5=A4=B1=E8=B4=A5?=
 =?UTF-8?q?=E5=8E=9F=E5=9B=A0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../java/com/imdroid/beidou_fwd/service/TCPClient.java   | 9 +++++----
 1 file changed, 5 insertions(+), 4 deletions(-)

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);
         }
     }