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;