Imdroid/security-monitor
2
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

1、修改TCP推送的bug

Browse Source
This commit is contained in:
weidong 2024-01-16 12:52:27 +08:00
parent d7bb69c185
commit b85daf498d
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
sec-beidou-fwd/src/main/java/com/imdroid/beidou_fwd/service/TCPClient.java
View File

@ -34,7 +34,7 @@ public class TCPClient {
public void init(String dest_addr, int dest_port) { public void init(String dest_addr, int dest_port) {
host = dest_addr; host = dest_addr;
port = dest_port; port = dest_port;
sendBuffer = Unpooled.buffer();
//客户端需要一个事件循环组 //客户端需要一个事件循环组
group = new NioEventLoopGroup(); group = new NioEventLoopGroup();
//创建客户端启动对象 //创建客户端启动对象
@ -83,6 +83,7 @@ public class TCPClient {
} }
public void writeAndFlush(String json) { public void writeAndFlush(String json) {
sendBuffer = Unpooled.buffer();
sendBuffer.writeBytes(json.getBytes(StandardCharsets.UTF_8)); sendBuffer.writeBytes(json.getBytes(StandardCharsets.UTF_8));
if(channel.isActive()) flush(); if(channel.isActive()) flush();
else connect(); else connect();
@ -97,7 +98,7 @@ public class TCPClient {
channel.writeAndFlush(sendBuffer).addListener(future -> { channel.writeAndFlush(sendBuffer).addListener(future -> {
if (future.isSuccess()) { if (future.isSuccess()) {
logger.info("send to xfz server succeed."); logger.info("send to xfz server succeed.");
sendBuffer.clear(); sendBuffer.release();
} else { } else {
logger.info("send to xfz server failed."); logger.info("send to xfz server failed.");
} }