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 72997c9c..590a27e9 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 @@ -73,6 +73,10 @@ public class TCPClient { } }, 5000, TimeUnit.MILLISECONDS); } else { + future.channel().config().setWriteBufferWaterMark(new WriteBufferWaterMark( + 1024 * 1024, // low + 4 *1024*1024 // high + )); logger.info("{}:{} tcp client start success!",host,port); } }