netty拆包器

enjoyCoding666 · enjoyCoding666 · commit 14f0c181137c · 2023-10-24T13:04:18.000+08:00
diff --git a/src/main/java/com/netty/decoder/ClientNoDecoderHandler.java b/src/main/java/com/netty/decoder/ClientNoDecoderHandler.java
@@ -0,0 +1,24 @@
+package com.netty.decoder;
+
+import io.netty.buffer.ByteBuf;
+import io.netty.channel.ChannelHandlerContext;
+import io.netty.channel.ChannelInboundHandlerAdapter;
+
+import java.nio.charset.StandardCharsets;
+
+public class ClientNoDecoderHandler extends ChannelInboundHandlerAdapter {
+    @Override
+    public void channelActive(ChannelHandlerContext ctx) {
+        for (int i = 0; i < 1000; i++) {
+            ByteBuf buffer = getByteBuf(ctx);
+            ctx.channel().writeAndFlush(buffer);
+        }
+    }
+
+    private ByteBuf getByteBuf(ChannelHandlerContext ctx) {
+        byte[] bytes = "粘包拆包测试.".getBytes(StandardCharsets.UTF_8);
+        ByteBuf buffer = ctx.alloc().buffer();
+        buffer.writeBytes(bytes);
+        return buffer;
+    }
+}
diff --git a/src/main/java/com/netty/echo/EchoClient.java b/src/main/java/com/netty/echo/EchoClient.java
@@ -1,13 +1,15 @@
 package com.netty.echo;
 
+import com.netty.decoder.ClientNoDecoderHandler;
 import io.netty.bootstrap.Bootstrap;
 import io.netty.channel.*;
 import io.netty.channel.nio.NioEventLoopGroup;
 import io.netty.channel.socket.SocketChannel;
 import io.netty.channel.socket.nio.NioSocketChannel;
+import io.netty.handler.codec.FixedLengthFrameDecoder;
 
 /**
- * 客户端。发送数据给服务端，并接收服务端的响应。
+ * 客户端。发送消息给服务端，并接收服务端的响应。
  *
  */
 public final class EchoClient {
@@ -27,9 +29,11 @@ public static void main(String[] args) throws Exception {
                         @Override
                         public void initChannel(SocketChannel socketChannel) throws Exception {
                             ChannelPipeline channelPipeline = socketChannel.pipeline();
-                            //channelPipeline.addLast(new LoggingHandler(LogLevel.INFO));
                             //ChannelHandler，用于处理 channel，实现对接收的数据的处理，实现业务逻辑。
-                            channelPipeline.addLast(new EchoClientHandler());
+                            //固定长度的拆包器 FixedLengthFrameDecoder
+                            channelPipeline.addLast(new FixedLengthFrameDecoder(19));
+                            channelPipeline.addLast(new ClientNoDecoderHandler());
+//                            channelPipeline.addLast(new EchoClientHandler());
                         }
                     });
 
@@ -42,4 +46,3 @@ public void initChannel(SocketChannel socketChannel) throws Exception {
         }
     }
 }
-
diff --git a/src/main/java/com/netty/echo/EchoServer.java b/src/main/java/com/netty/echo/EchoServer.java
@@ -5,6 +5,7 @@
 import io.netty.channel.nio.NioEventLoopGroup;
 import io.netty.channel.socket.SocketChannel;
 import io.netty.channel.socket.nio.NioServerSocketChannel;
+import io.netty.handler.codec.FixedLengthFrameDecoder;
 import io.netty.handler.logging.LogLevel;
 import io.netty.handler.logging.LoggingHandler;
 
@@ -30,15 +31,16 @@ public static void main(String[] args) throws Exception {
                     //指定 channel
                     .channel(NioServerSocketChannel.class)
                     .option(ChannelOption.SO_BACKLOG, 100)
-                    //指定 ChannelHandler，用于处理 channel
+                    //指定 ChannelHandler，用于处理 Channel
                     .handler(new LoggingHandler(LogLevel.INFO))
                     .childHandler(new ChannelInitializer<SocketChannel>() {
                         @Override
                         public void initChannel(SocketChannel ch) throws Exception {
                             //ChannelPipeline，基于责任链模式，可以添加多个 ChannelHandler
                             ChannelPipeline channelPipeline = ch.pipeline();
-                            //channelPipeline.addLast(new LoggingHandler(LogLevel.INFO));
                             //ChannelHandler，用于处理 channel，实现对接收的数据的处理，实现业务逻辑。
+                            //固定长度的拆包器 FixedLengthFrameDecoder
+                            channelPipeline.addLast(new FixedLengthFrameDecoder(19));
                             channelPipeline.addLast(new EchoServerHandler());
                         }
                     });
@@ -55,5 +57,3 @@ public void initChannel(SocketChannel ch) throws Exception {
         }
     }
 }
-
-
