From dfdc6bdfda10de4c01fb1cfe43cabf050e71f8c3 Mon Sep 17 00:00:00 2001
From: ‘liusuyi’ <1951119284@qq.com>
Date: 星期四, 28 十二月 2023 14:50:54 +0800
Subject: [PATCH] 优化雷达tcp客户端
---
src/main/java/com/ard/utils/netty/tcp/BootNettyChannelInboundHandlerAdapter.java | 20 +++++++++++---------
1 files changed, 11 insertions(+), 9 deletions(-)
diff --git a/src/main/java/com/ard/utils/netty/tcp/BootNettyChannelInboundHandlerAdapter.java b/src/main/java/com/ard/utils/netty/tcp/BootNettyChannelInboundHandlerAdapter.java
index 561d287..5e49218 100644
--- a/src/main/java/com/ard/utils/netty/tcp/BootNettyChannelInboundHandlerAdapter.java
+++ b/src/main/java/com/ard/utils/netty/tcp/BootNettyChannelInboundHandlerAdapter.java
@@ -10,6 +10,7 @@
import io.netty.buffer.ByteBuf;
import io.netty.buffer.EmptyByteBuf;
import io.netty.channel.*;
+import io.netty.util.CharsetUtil;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
@@ -33,17 +34,18 @@
InetSocketAddress inSocket = (InetSocketAddress) ctx.channel().remoteAddress();
String host = inSocket.getAddress().getHostAddress();
int port = inSocket.getPort();
+ //log.info("鏀跺埌鏉ヨ嚜 {}:{} 鐨勬暟鎹畕}", host, port,msg.toString(CharsetUtil.UTF_8));
ArdEquipRadar ardEquipRadar = BootNettyClientChannelCache.getRadar(host + ":" + port);
if (ardEquipRadar != null) {
- // 鍒涘缓缂撳啿涓瓧鑺傛暟鐨勫瓧鑺傛暟缁�
- byte[] byteArray = new byte[msg.readableBytes()];
- // 鍐欏叆鏁扮粍
- msg.readBytes(byteArray);
- // 澶勭悊鎺ユ敹鍒扮殑娑堟伅
- byte[] bytes = MessageParsing.receiveCompletePacket(byteArray);
- if (bytes != null) {
- processData(ardEquipRadar, bytes);
- }
+ //// 鍒涘缓缂撳啿涓瓧鑺傛暟鐨勫瓧鑺傛暟缁�
+ //byte[] byteArray = new byte[msg.readableBytes()];
+ //// 鍐欏叆鏁扮粍
+ //msg.readBytes(byteArray);
+ //// 澶勭悊鎺ユ敹鍒扮殑娑堟伅
+ //byte[] bytes = MessageParsing.receiveCompletePacket(byteArray);
+ //if (bytes != null) {
+ // processData(ardEquipRadar, bytes);
+ //}
}
}
--
Gitblit v1.9.3