From e828d99f25ba6736cdb0c31128aa4d976348bcb3 Mon Sep 17 00:00:00 2001
From: tqs <56479841@qq.com>
Date: 星期三, 12 十月 2022 17:39:34 +0800
Subject: [PATCH] Merge remote-tracking branch 'gitbit/gzynwcs' into gzynwcs
---
src/main/java/com/zy/core/netty/handle/ProtocolDecoder.java | 12 +++---------
1 files changed, 3 insertions(+), 9 deletions(-)
diff --git a/src/main/java/com/zy/core/netty/handle/ProtocolDecoder.java b/src/main/java/com/zy/core/netty/handle/ProtocolDecoder.java
index c265083..4b9cdeb 100644
--- a/src/main/java/com/zy/core/netty/handle/ProtocolDecoder.java
+++ b/src/main/java/com/zy/core/netty/handle/ProtocolDecoder.java
@@ -7,6 +7,7 @@
import io.netty.buffer.ByteBufUtil;
import io.netty.channel.ChannelHandlerContext;
import io.netty.handler.codec.ByteToMessageDecoder;
+import lombok.extern.slf4j.Slf4j;
import java.net.InetSocketAddress;
import java.nio.charset.StandardCharsets;
@@ -15,6 +16,7 @@
/**
* Created by vincent on 2019-04-10
*/
+@Slf4j
public class ProtocolDecoder extends ByteToMessageDecoder {
private final SnowflakeIdWorker snowflakeIdWorker;
@@ -26,22 +28,14 @@
@Override
protected void decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> list) throws Exception {
- byte[] bytes = new byte[in.readableBytes()];
- in.readBytes(bytes);
-
// 鐢熸垚鍜屽垵濮嬪寲娑堟伅鍖呰绫�
-
String ip = ((InetSocketAddress) ctx.channel().remoteAddress()).getAddress().getHostAddress();
ChPackage pac = ChPackage.valueOfEmpty(String.valueOf(snowflakeIdWorker.nextId()), ip);
pac.setSourceBuff(in);
- pac.setBytes(bytes);
-
- list.add(pac);
-
// 瑙ｆ瀽
-// list.add(analyzeProtocol(pac));
+ list.add(analyzeProtocol(pac));
}
public ChPackage analyzeProtocol(ChPackage pac){
--
Gitblit v1.9.1