From e286c355ff83fc57b3cfae4c8ef381298391763f Mon Sep 17 00:00:00 2001 From: weidong Date: Sun, 20 Jul 2025 21:26:41 +0800 Subject: [PATCH] =?UTF-8?q?1=E3=80=81=E5=A2=9E=E5=8A=A0log=E6=9F=A5?= =?UTF-8?q?=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/imdroid/beidou_fwd/service/TCPClient.java | 1 + .../com/imdroid/beidou_fwd/task/GXXfzForwarder.java | 12 ++++++------ 2 files changed, 7 insertions(+), 6 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 a3b05a1d..4576454f 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 @@ -92,6 +92,7 @@ public class TCPClient { public void writeAndFlush(String json) { ByteBuf sendBuffer = Unpooled.buffer(); sendBuffer.writeBytes(json.getBytes(StandardCharsets.UTF_8)); + logger.info("send to {}: {}",host,json); channel.writeAndFlush(sendBuffer).addListener(future -> { if (future.isSuccess()) { logger.info("send to tcp:"+host+" succeed."); diff --git a/sec-beidou-fwd/src/main/java/com/imdroid/beidou_fwd/task/GXXfzForwarder.java b/sec-beidou-fwd/src/main/java/com/imdroid/beidou_fwd/task/GXXfzForwarder.java index 668c78df..fb644827 100644 --- a/sec-beidou-fwd/src/main/java/com/imdroid/beidou_fwd/task/GXXfzForwarder.java +++ b/sec-beidou-fwd/src/main/java/com/imdroid/beidou_fwd/task/GXXfzForwarder.java @@ -73,8 +73,8 @@ public class GXXfzForwarder extends Forwarder{ if(batchNum==50){ String json = "#" + GsonUtil.toJson(xfzTcpMessage) + "!"; - logger.debug("project {}: forwad {} gnss records to {}",projectId, dataList.size(),fwdGroupId); - logger.debug(json); + //logger.debug("project {}: forwad {} gnss records to {}",projectId, dataList.size(),fwdGroupId); + //logger.debug(json); try { listener.clear(); xfzTcpClient.writeAndFlush(json); @@ -91,8 +91,8 @@ public class GXXfzForwarder extends Forwarder{ if(batchNum>0){ String json = "#" + GsonUtil.toJson(xfzTcpMessage) + "!"; - logger.debug("project {}: forwad {} gnss records to {}",projectId, dataList.size(),fwdGroupId); - logger.debug(json); + //logger.debug("project {}: forwad {} gnss records to {}",projectId, dataList.size(),fwdGroupId); + //logger.debug(json); try { listener.clear(); xfzTcpClient.writeAndFlush(json); @@ -107,8 +107,8 @@ public class GXXfzForwarder extends Forwarder{ } boolean checkResult() throws InterruptedException { - // 等待应答，最多等1s - for(int i=0; i<20; i++){ + // 等待应答，最多等500ms + for(int i=0; i<10; i++){ Thread.sleep(50); if(listener.state == XFZTCPListener.STATE_OK) return true; else if(listener.state == XFZTCPListener.STATE_FAILED) return false;