From c324f00db69c760b0c4c577425214d4ab2e34d9c Mon Sep 17 00:00:00 2001
From: ‘liusuyi’ <1951119284@qq.com>
Date: 星期四, 28 十二月 2023 13:17:16 +0800
Subject: [PATCH] 更改雷达tcp客户端
---
src/main/java/com/ard/utils/netty/tcp/BootNettyChannelInboundHandlerAdapter.java | 14 +++++++++-----
1 files changed, 9 insertions(+), 5 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 8d42a2d..d0bf436 100644
--- a/src/main/java/com/ard/utils/netty/tcp/BootNettyChannelInboundHandlerAdapter.java
+++ b/src/main/java/com/ard/utils/netty/tcp/BootNettyChannelInboundHandlerAdapter.java
@@ -8,6 +8,7 @@
import com.ard.utils.util.ByteUtils;
import com.ard.utils.util.GisUtils;
import io.netty.buffer.ByteBuf;
+import io.netty.buffer.EmptyByteBuf;
import io.netty.channel.ChannelHandler;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelId;
@@ -34,8 +35,8 @@
* 浠庢湇鍔＄鏀跺埌鏂扮殑鏁版嵁鏃讹紝杩欎釜鏂规硶浼氬湪鏀跺埌娑堟伅鏃惰璋冪敤
*/
@Override
- public void channelRead(ChannelHandlerContext ctx, Object msg1) throws Exception, IOException {
- if(msg1 == null){
+ public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception, IOException {
+ if(msg == null){
return;
}
@@ -49,10 +50,13 @@
String host = inSocket.getAddress().getHostAddress();
int port = inSocket.getPort();
ArdEquipRadar ardEquipRadar = ClientInitialize.tureConnectMap.get(host+":"+port);
+ // msg杞珺uf
+ ByteBuf buf = (ByteBuf) msg;
+ // 鍒涘缓缂撳啿涓瓧鑺傛暟鐨勫瓧鑺傛暟缁�
+ byte[] byteArray = new byte[buf.readableBytes()];
+ // 鍐欏叆鏁扮粍
+ buf.readBytes(byteArray);
// 澶勭悊鎺ユ敹鍒扮殑娑堟伅
- ByteBuf msg= (ByteBuf)msg1;
- byte[] byteArray = new byte[msg.readableBytes()];
- msg.getBytes(msg.readerIndex(), byteArray);
byte[] bytes = MessageParsing.receiveCompletePacket(byteArray);
if (bytes != null) {
processData(ardEquipRadar, bytes);
--
Gitblit v1.9.3