Netty高级利用与源码详解

万有斥力  金牌会员 | 2025-2-12 13:07:05 | 来自手机 | 显示全部楼层 | 阅读模式
打印 上一主题 下一主题
楼主

主题 869|帖子 869|积分 2607

粘包与半包

粘包现象

粘包的问题出现是因为不知道一个用户消息的边界在哪，如果知道了边界在哪，吸收方就可以通过边界来划分出有效的用户消息。
服务端代码
  1. public class HelloWorldServer {
  2.     static final Logger log = LoggerFactory.getLogger(HelloWorldServer.class);
  3.     void start() {
  4.         NioEventLoopGroup boss = new NioEventLoopGroup(1);
  5.         NioEventLoopGroup worker = new NioEventLoopGroup();
  6.         try {
  7.             ServerBootstrap serverBootstrap = new ServerBootstrap();
  8.             serverBootstrap.channel(NioServerSocketChannel.class);
  9.             serverBootstrap.group(boss, worker);
  10.             serverBootstrap.childHandler(new ChannelInitializer<SocketChannel>() {
  11.                 @Override
  12.                 protected void initChannel(SocketChannel ch) throws Exception {
  13.                     ch.pipeline().addLast(new LoggingHandler(LogLevel.DEBUG));
  14.                     ch.pipeline().addLast(new ChannelInboundHandlerAdapter() {
  15.                         @Override
  16.                         public void channelActive(ChannelHandlerContext ctx) throws Exception {
  17.                             log.debug("connected {}", ctx.channel());
  18.                             super.channelActive(ctx);
  19.                         }
  21.                         @Override
  22.                         public void channelInactive(ChannelHandlerContext ctx) throws Exception {
  23.                             log.debug("disconnect {}", ctx.channel());
  24.                             super.channelInactive(ctx);
  25.                         }
  26.                     });
  27.                 }
  28.             });
  29.             ChannelFuture channelFuture = serverBootstrap.bind(8080);
  30.             log.debug("{} binding...", channelFuture.channel());
  31.             channelFuture.sync();
  32.             log.debug("{} bound...", channelFuture.channel());
  33.             channelFuture.channel().closeFuture().sync();
  34.         } catch (InterruptedException e) {
  35.             log.error("server error", e);
  36.         } finally {
  37.             boss.shutdownGracefully();
  38.             worker.shutdownGracefully();
  39.             log.debug("stoped");
  40.         }
  41.     }
  43.     public static void main(String[] args) {
  44.         new HelloWorldServer().start();
  45.     }
  46. }
复制代码
客户端代码盼望发送 10 个消息，每个消息是 16 字节
  1. public class HelloWorldClient {
  2.     static final Logger log = LoggerFactory.getLogger(HelloWorldClient.class);
  3.     public static void main(String[] args) {
  4.         NioEventLoopGroup worker = new NioEventLoopGroup();
  5.         try {
  6.             Bootstrap bootstrap = new Bootstrap();
  7.             bootstrap.channel(NioSocketChannel.class);
  8.             bootstrap.group(worker);
  9.             bootstrap.handler(new ChannelInitializer<SocketChannel>() {
  10.                 @Override
  11.                 protected void initChannel(SocketChannel ch) throws Exception {
  12.                     log.debug("connetted...");
  13.                     ch.pipeline().addLast(new ChannelInboundHandlerAdapter() {
  14.                         @Override
  15.                         //会在连接channel建立成功后，会触发Active事件
  16.                         public void channelActive(ChannelHandlerContext ctx) throws Exception {
  17.                             log.debug("sending...");
  18.                             Random r = new Random();
  19.                             char c = 'a';
  20.                             for (int i = 0; i < 10; i++) {
  21.                                 ByteBuf buffer = ctx.alloc().buffer();
  22.                                 buffer.writeBytes(new byte[]{0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15});
  23.                                 ctx.writeAndFlush(buffer);
  24.                             }
  25.                         }
  26.                     });
  27.                 }
  28.             });
  29.             ChannelFuture channelFuture = bootstrap.connect("127.0.0.1", 8080).sync();
  30.             channelFuture.channel().closeFuture().sync();
  32.         } catch (InterruptedException e) {
  33.             log.error("client error", e);
  34.         } finally {
  35.             worker.shutdownGracefully();
  36.         }
  37.     }
  38. }
复制代码
服务器端的某次输出，可以看到一次就吸收了 160 个字节，而期望的是一次16字节，分 10 次吸收。这就出现了粘包现象
  1. 08:24:46 [DEBUG] [main] c.i.n.HelloWorldServer - [id: 0x81e0fda5] binding...
  2. 08:24:46 [DEBUG] [main] c.i.n.HelloWorldServer - [id: 0x81e0fda5, L:/0:0:0:0:0:0:0:0:8080] bound...
  3. 08:24:55 [DEBUG] [nioEventLoopGroup-3-1] i.n.h.l.LoggingHandler - [id: 0x94132411, L:/127.0.0.1:8080 - R:/127.0.0.1:58177] REGISTERED
  4. 08:24:55 [DEBUG] [nioEventLoopGroup-3-1] i.n.h.l.LoggingHandler - [id: 0x94132411, L:/127.0.0.1:8080 - R:/127.0.0.1:58177] ACTIVE
  5. 08:24:55 [DEBUG] [nioEventLoopGroup-3-1] c.i.n.HelloWorldServer - connected [id: 0x94132411, L:/127.0.0.1:8080 - R:/127.0.0.1:58177]
  6. 08:24:55 [DEBUG] [nioEventLoopGroup-3-1] i.n.h.l.LoggingHandler - [id: 0x94132411, L:/127.0.0.1:8080 - R:/127.0.0.1:58177] READ: 160B
  7.          +-------------------------------------------------+
  8.          |  0  1  2  3  4  5  6  7  8  9  a  b  c  d  e  f |
  9. +--------+-------------------------------------------------+----------------+
  10. |00000000| 00 01 02 03 04 05 06 07 08 09 0a 0b 0c 0d 0e 0f |................|
  11. |00000010| 00 01 02 03 04 05 06 07 08 09 0a 0b 0c 0d 0e 0f |................|
  12. |00000020| 00 01 02 03 04 05 06 07 08 09 0a 0b 0c 0d 0e 0f |................|
  13. |00000030| 00 01 02 03 04 05 06 07 08 09 0a 0b 0c 0d 0e 0f |................|
  14. |00000040| 00 01 02 03 04 05 06 07 08 09 0a 0b 0c 0d 0e 0f |................|
  15. |00000050| 00 01 02 03 04 05 06 07 08 09 0a 0b 0c 0d 0e 0f |................|
  16. |00000060| 00 01 02 03 04 05 06 07 08 09 0a 0b 0c 0d 0e 0f |................|
  17. |00000070| 00 01 02 03 04 05 06 07 08 09 0a 0b 0c 0d 0e 0f |................|
  18. |00000080| 00 01 02 03 04 05 06 07 08 09 0a 0b 0c 0d 0e 0f |................|
  19. |00000090| 00 01 02 03 04 05 06 07 08 09 0a 0b 0c 0d 0e 0f |................|
  20. +--------+-------------------------------------------------+----------------+
  21. 08:24:55 [DEBUG] [nioEventLoopGroup-3-1] i.n.h.l.LoggingHandler - [id: 0x94132411, L:/127.0.0.1:8080 - R:/127.0.0.1:58177] READ COMPLETE
复制代码
半包现象

半包是指 吸收端只收到了部门数据，而非完备的数据的情况
客户端代码盼望发送 1 个消息，这个消息是 160 字节，代码改为
  1. ByteBuf buffer = ctx.alloc().buffer();
  2. for (int i = 0; i < 10; i++) {
  3.     buffer.writeBytes(new byte[]{0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15});
  4. }
  5. ctx.writeAndFlush(buffer);
复制代码
为现象显着，服务端修改一下吸收缓冲区，其它代码不变
  1. serverBootstrap.option(ChannelOption.SO_RCVBUF, 10);
复制代码
服务器端的某次输出，可以看到吸收的消息被分为两节，如 第一次 20 字节，第二次 140 字节
  1. 08:43:49 [DEBUG] [main] c.i.n.HelloWorldServer - [id: 0x4d6c6a84] binding...
  2. 08:43:49 [DEBUG] [main] c.i.n.HelloWorldServer - [id: 0x4d6c6a84, L:/0:0:0:0:0:0:0:0:8080] bound...
  3. 08:44:23 [DEBUG] [nioEventLoopGroup-3-1] i.n.h.l.LoggingHandler - [id: 0x1719abf7, L:/127.0.0.1:8080 - R:/127.0.0.1:59221] REGISTERED
  4. 08:44:23 [DEBUG] [nioEventLoopGroup-3-1] i.n.h.l.LoggingHandler - [id: 0x1719abf7, L:/127.0.0.1:8080 - R:/127.0.0.1:59221] ACTIVE
  5. 08:44:23 [DEBUG] [nioEventLoopGroup-3-1] c.i.n.HelloWorldServer - connected [id: 0x1719abf7, L:/127.0.0.1:8080 - R:/127.0.0.1:59221]
  6. 08:44:24 [DEBUG] [nioEventLoopGroup-3-1] i.n.h.l.LoggingHandler - [id: 0x1719abf7, L:/127.0.0.1:8080 - R:/127.0.0.1:59221] READ: 20B
  7.          +-------------------------------------------------+
  8.          |  0  1  2  3  4  5  6  7  8  9  a  b  c  d  e  f |
  9. +--------+-------------------------------------------------+----------------+
  10. |00000000| 00 01 02 03 04 05 06 07 08 09 0a 0b 0c 0d 0e 0f |................|
  11. |00000010| 00 01 02 03                                     |....            |
  12. +--------+-------------------------------------------------+----------------+
  13. 08:44:24 [DEBUG] [nioEventLoopGroup-3-1] i.n.h.l.LoggingHandler - [id: 0x1719abf7, L:/127.0.0.1:8080 - R:/127.0.0.1:59221] READ COMPLETE
  14. 08:44:24 [DEBUG] [nioEventLoopGroup-3-1] i.n.h.l.LoggingHandler - [id: 0x1719abf7, L:/127.0.0.1:8080 - R:/127.0.0.1:59221] READ: 140B
  15.          +-------------------------------------------------+
  16.          |  0  1  2  3  4  5  6  7  8  9  a  b  c  d  e  f |
  17. +--------+-------------------------------------------------+----------------+
  18. |00000000| 04 05 06 07 08 09 0a 0b 0c 0d 0e 0f 00 01 02 03 |................|
  19. |00000010| 04 05 06 07 08 09 0a 0b 0c 0d 0e 0f 00 01 02 03 |................|
  20. |00000020| 04 05 06 07 08 09 0a 0b 0c 0d 0e 0f 00 01 02 03 |................|
  21. |00000030| 04 05 06 07 08 09 0a 0b 0c 0d 0e 0f 00 01 02 03 |................|
  22. |00000040| 04 05 06 07 08 09 0a 0b 0c 0d 0e 0f 00 01 02 03 |................|
  23. |00000050| 04 05 06 07 08 09 0a 0b 0c 0d 0e 0f 00 01 02 03 |................|
  24. |00000060| 04 05 06 07 08 09 0a 0b 0c 0d 0e 0f 00 01 02 03 |................|
  25. |00000070| 04 05 06 07 08 09 0a 0b 0c 0d 0e 0f 00 01 02 03 |................|
  26. |00000080| 04 05 06 07 08 09 0a 0b 0c 0d 0e 0f             |............    |
  27. +--------+-------------------------------------------------+----------------+
  28. 08:44:24 [DEBUG] [nioEventLoopGroup-3-1] i.n.h.l.LoggingHandler - [id: 0x1719abf7, L:/127.0.0.1:8080 - R:/127.0.0.1:59221] READ COMPLETE
复制代码
留意：serverBootstrap.option(ChannelOption.SO_RCVBUF, 10) 影响的底层吸收缓冲区（即滑动窗口）大小，仅决定了 netty 读取的最小单位，netty 实际每次读取的一般是它的整数倍
现象分析

这里出现的粘包半包问题，并非是JavaNIO或Netty的问题，本质是TCP是流失协议，消息无边界。
粘包：

  • 现象，发送 abc def，吸收 abcdef
  • 原因

    • 应用层：吸收方 ByteBuf 设置太大（Netty 默认 1024）
    • 滑动窗口：假设发送方 256 bytes 表现一个完备报文，但由于吸收方处置惩罚不及时且窗口大小足够大，这 256 bytes 字节就会缓冲在吸收方的滑动窗口中，当滑动窗口中缓冲了多个报文就会粘包
    • Nagle 算法：会造成粘包

半包

  • 现象，发送 abcdef，吸收 abc def
  • 原因

    • 应用层：吸收方 ByteBuf 小于实际发送数据量
    • 滑动窗口：假设吸收方的窗口只剩了 128 bytes，发送方的报文大小是 256 bytes，这时放不下了，只能先发送前 128 bytes，等待 ack 后才能发送剩余部门，这就造成了半包
    • MSS 限制：当发送的数据凌驾 MSS 限制后，会将数据切分发送，就会造成半包

解决方案

接下来看下Netty如何解决以上问题的：

  • 短链接，发一个包建立一次连接，这样连接建立到连接断开之间就是消息的边界，缺点效率太低
  • 每一条消息接纳固定长度，缺点浪费空间
  • 每一条消息接纳分隔符，例如 \n，缺点需要转义
  • 每一条消息分为 head 和 body，head 中包罗 body 的长度
方法1：短链接（极不保举）

以解决粘包为例
  1. public class HelloWorldClient {
  2.     static final Logger log = LoggerFactory.getLogger(HelloWorldClient.class);
  4.     public static void main(String[] args) {
  5.         // 分 10 次发送
  6.         for (int i = 0; i < 10; i++) {
  7.             send();
  8.         }
  9.     }
  11.     private static void send() {
  12.         NioEventLoopGroup worker = new NioEventLoopGroup();
  13.         try {
  14.             Bootstrap bootstrap = new Bootstrap();
  15.             bootstrap.channel(NioSocketChannel.class);
  16.             bootstrap.group(worker);
  17.             bootstrap.handler(new ChannelInitializer<SocketChannel>() {
  18.                 @Override
  19.                 protected void initChannel(SocketChannel ch) throws Exception {
  20.                     log.debug("conneted...");
  21.                     ch.pipeline().addLast(new LoggingHandler(LogLevel.DEBUG));
  22.                     ch.pipeline().addLast(new ChannelInboundHandlerAdapter() {
  23.                         @Override
  24.                         public void channelActive(ChannelHandlerContext ctx) throws Exception {
  25.                             log.debug("sending...");
  26.                             ByteBuf buffer = ctx.alloc().buffer();
  27.                             buffer.writeBytes(new byte[]{0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15});
  28.                             ctx.writeAndFlush(buffer);
  29.                             // 发完即关
  30.                             ctx.close();
  31.                         }
  32.                     });
  33.                 }
  34.             });
  35.             ChannelFuture channelFuture = bootstrap.connect("localhost", 8080).sync();
  36.             channelFuture.channel().closeFuture().sync();
  38.         } catch (InterruptedException e) {
  39.             log.error("client error", e);
  40.         } finally {
  41.             worker.shutdownGracefully();
  42.         }
  43.     }
  44. }
复制代码
输出，略
半包用这种办法照旧欠好解决，因为吸收方的缓冲区大小是有限的
方法2：固定长度

让所有数据包长度固定（假设长度为 8 字节），服务器端参加
  1. ch.pipeline().addLast(new FixedLengthFrameDecoder(8));
复制代码
客户端测试代码，留意, 接纳这种方法后，客户端什么时候 flush 都可以
  1. public class HelloWorldClient {
  2.     static final Logger log = LoggerFactory.getLogger(HelloWorldClient.class);
  4.     public static void main(String[] args) {
  5.         NioEventLoopGroup worker = new NioEventLoopGroup();
  6.         try {
  7.             Bootstrap bootstrap = new Bootstrap();
  8.             bootstrap.channel(NioSocketChannel.class);
  9.             bootstrap.group(worker);
  10.             bootstrap.handler(new ChannelInitializer<SocketChannel>() {
  11.                 @Override
  12.                 protected void initChannel(SocketChannel ch) throws Exception {
  13.                     log.debug("connetted...");
  14.                     ch.pipeline().addLast(new LoggingHandler(LogLevel.DEBUG));
  15.                     ch.pipeline().addLast(new ChannelInboundHandlerAdapter() {
  16.                         @Override
  17.                         public void channelActive(ChannelHandlerContext ctx) throws Exception {
  18.                             log.debug("sending...");
  19.                             // 发送内容随机的数据包
  20.                             Random r = new Random();
  21.                             char c = 'a';
  22.                             ByteBuf buffer = ctx.alloc().buffer();
  23.                             for (int i = 0; i < 10; i++) {
  24.                                 byte[] bytes = new byte[8];
  25.                                 for (int j = 0; j < r.nextInt(8); j++) {
  26.                                     bytes[j] = (byte) c;
  27.                                 }
  28.                                 c++;
  29.                                 buffer.writeBytes(bytes);
  30.                             }
  31.                             ctx.writeAndFlush(buffer);
  32.                         }
  33.                     });
  34.                 }
  35.             });
  36.             ChannelFuture channelFuture = bootstrap.connect("192.168.0.103", 9090).sync();
  37.             channelFuture.channel().closeFuture().sync();
  39.         } catch (InterruptedException e) {
  40.             log.error("client error", e);
  41.         } finally {
  42.             worker.shutdownGracefully();
  43.         }
  44.     }
  45. }
复制代码
客户端输出
  1. 12:07:00 [DEBUG] [nioEventLoopGroup-2-1] c.i.n.HelloWorldClient - connetted...
  2. 12:07:00 [DEBUG] [nioEventLoopGroup-2-1] i.n.h.l.LoggingHandler - [id: 0x3c2ef3c2] REGISTERED
  3. 12:07:00 [DEBUG] [nioEventLoopGroup-2-1] i.n.h.l.LoggingHandler - [id: 0x3c2ef3c2] CONNECT: /192.168.0.103:9090
  4. 12:07:00 [DEBUG] [nioEventLoopGroup-2-1] i.n.h.l.LoggingHandler - [id: 0x3c2ef3c2, L:/192.168.0.103:53155 - R:/192.168.0.103:9090] ACTIVE
  5. 12:07:00 [DEBUG] [nioEventLoopGroup-2-1] c.i.n.HelloWorldClient - sending...
  6. 12:07:00 [DEBUG] [nioEventLoopGroup-2-1] i.n.h.l.LoggingHandler - [id: 0x3c2ef3c2, L:/192.168.0.103:53155 - R:/192.168.0.103:9090] WRITE: 80B
  7.          +-------------------------------------------------+
  8.          |  0  1  2  3  4  5  6  7  8  9  a  b  c  d  e  f |
  9. +--------+-------------------------------------------------+----------------+
  10. |00000000| 61 61 61 61 00 00 00 00 62 00 00 00 00 00 00 00 |aaaa....b.......|
  11. |00000010| 63 63 00 00 00 00 00 00 64 00 00 00 00 00 00 00 |cc......d.......|
  12. |00000020| 00 00 00 00 00 00 00 00 66 66 66 66 00 00 00 00 |........ffff....|
  13. |00000030| 67 67 67 00 00 00 00 00 68 00 00 00 00 00 00 00 |ggg.....h.......|
  14. |00000040| 69 69 69 69 69 00 00 00 6a 6a 6a 6a 00 00 00 00 |iiiii...jjjj....|
  15. +--------+-------------------------------------------------+----------------+
  16. 12:07:00 [DEBUG] [nioEventLoopGroup-2-1] i.n.h.l.LoggingHandler - [id: 0x3c2ef3c2, L:/192.168.0.103:53155 - R:/192.168.0.103:9090] FLUSH
复制代码
服务端输出
  1. 12:06:51 [DEBUG] [main] c.i.n.HelloWorldServer - [id: 0xe3d9713f] binding...
  2. 12:06:51 [DEBUG] [main] c.i.n.HelloWorldServer - [id: 0xe3d9713f, L:/192.168.0.103:9090] bound...
  3. 12:07:00 [DEBUG] [nioEventLoopGroup-3-1] i.n.h.l.LoggingHandler - [id: 0xd739f137, L:/192.168.0.103:9090 - R:/192.168.0.103:53155] REGISTERED
  4. 12:07:00 [DEBUG] [nioEventLoopGroup-3-1] i.n.h.l.LoggingHandler - [id: 0xd739f137, L:/192.168.0.103:9090 - R:/192.168.0.103:53155] ACTIVE
  5. 12:07:00 [DEBUG] [nioEventLoopGroup-3-1] c.i.n.HelloWorldServer - connected [id: 0xd739f137, L:/192.168.0.103:9090 - R:/192.168.0.103:53155]
  6. 12:07:00 [DEBUG] [nioEventLoopGroup-3-1] i.n.h.l.LoggingHandler - [id: 0xd739f137, L:/192.168.0.103:9090 - R:/192.168.0.103:53155] READ: 8B
  7.          +-------------------------------------------------+
  8.          |  0  1  2  3  4  5  6  7  8  9  a  b  c  d  e  f |
  9. +--------+-------------------------------------------------+----------------+
  10. |00000000| 61 61 61 61 00 00 00 00                         |aaaa....        |
  11. +--------+-------------------------------------------------+----------------+
  12. 12:07:00 [DEBUG] [nioEventLoopGroup-3-1] i.n.h.l.LoggingHandler - [id: 0xd739f137, L:/192.168.0.103:9090 - R:/192.168.0.103:53155] READ: 8B
  13.          +-------------------------------------------------+
  14.          |  0  1  2  3  4  5  6  7  8  9  a  b  c  d  e  f |
  15. +--------+-------------------------------------------------+----------------+
  16. |00000000| 62 00 00 00 00 00 00 00                         |b.......        |
  17. +--------+-------------------------------------------------+----------------+
  18. 12:07:00 [DEBUG] [nioEventLoopGroup-3-1] i.n.h.l.LoggingHandler - [id: 0xd739f137, L:/192.168.0.103:9090 - R:/192.168.0.103:53155] READ: 8B
  19.          +-------------------------------------------------+
  20.          |  0  1  2  3  4  5  6  7  8  9  a  b  c  d  e  f |
  21. +--------+-------------------------------------------------+----------------+
  22. |00000000| 63 63 00 00 00 00 00 00                         |cc......        |
  23. +--------+-------------------------------------------------+----------------+
  24. 12:07:00 [DEBUG] [nioEventLoopGroup-3-1] i.n.h.l.LoggingHandler - [id: 0xd739f137, L:/192.168.0.103:9090 - R:/192.168.0.103:53155] READ: 8B
  25.          +-------------------------------------------------+
  26.          |  0  1  2  3  4  5  6  7  8  9  a  b  c  d  e  f |
  27. +--------+-------------------------------------------------+----------------+
  28. |00000000| 64 00 00 00 00 00 00 00                         |d.......        |
  29. +--------+-------------------------------------------------+----------------+
  30. 12:07:00 [DEBUG] [nioEventLoopGroup-3-1] i.n.h.l.LoggingHandler - [id: 0xd739f137, L:/192.168.0.103:9090 - R:/192.168.0.103:53155] READ: 8B
  31.          +-------------------------------------------------+
  32.          |  0  1  2  3  4  5  6  7  8  9  a  b  c  d  e  f |
  33. +--------+-------------------------------------------------+----------------+
  34. |00000000| 00 00 00 00 00 00 00 00                         |........        |
  35. +--------+-------------------------------------------------+----------------+
  36. 12:07:00 [DEBUG] [nioEventLoopGroup-3-1] i.n.h.l.LoggingHandler - [id: 0xd739f137, L:/192.168.0.103:9090 - R:/192.168.0.103:53155] READ: 8B
  37.          +-------------------------------------------------+
  38.          |  0  1  2  3  4  5  6  7  8  9  a  b  c  d  e  f |
  39. +--------+-------------------------------------------------+----------------+
  40. |00000000| 66 66 66 66 00 00 00 00                         |ffff....        |
  41. +--------+-------------------------------------------------+----------------+
  42. 12:07:00 [DEBUG] [nioEventLoopGroup-3-1] i.n.h.l.LoggingHandler - [id: 0xd739f137, L:/192.168.0.103:9090 - R:/192.168.0.103:53155] READ: 8B
  43.          +-------------------------------------------------+
  44.          |  0  1  2  3  4  5  6  7  8  9  a  b  c  d  e  f |
  45. +--------+-------------------------------------------------+----------------+
  46. |00000000| 67 67 67 00 00 00 00 00                         |ggg.....        |
  47. +--------+-------------------------------------------------+----------------+
  48. 12:07:00 [DEBUG] [nioEventLoopGroup-3-1] i.n.h.l.LoggingHandler - [id: 0xd739f137, L:/192.168.0.103:9090 - R:/192.168.0.103:53155] READ: 8B
  49.          +-------------------------------------------------+
  50.          |  0  1  2  3  4  5  6  7  8  9  a  b  c  d  e  f |
  51. +--------+-------------------------------------------------+----------------+
  52. |00000000| 68 00 00 00 00 00 00 00                         |h.......        |
  53. +--------+-------------------------------------------------+----------------+
  54. 12:07:00 [DEBUG] [nioEventLoopGroup-3-1] i.n.h.l.LoggingHandler - [id: 0xd739f137, L:/192.168.0.103:9090 - R:/192.168.0.103:53155] READ: 8B
  55.          +-------------------------------------------------+
  56.          |  0  1  2  3  4  5  6  7  8  9  a  b  c  d  e  f |
  57. +--------+-------------------------------------------------+----------------+
  58. |00000000| 69 69 69 69 69 00 00 00                         |iiiii...        |
  59. +--------+-------------------------------------------------+----------------+
  60. 12:07:00 [DEBUG] [nioEventLoopGroup-3-1] i.n.h.l.LoggingHandler - [id: 0xd739f137, L:/192.168.0.103:9090 - R:/192.168.0.103:53155] READ: 8B
  61.          +-------------------------------------------------+
  62.          |  0  1  2  3  4  5  6  7  8  9  a  b  c  d  e  f |
  63. +--------+-------------------------------------------------+----------------+
  64. |00000000| 6a 6a 6a 6a 00 00 00 00                         |jjjj....        |
  65. +--------+-------------------------------------------------+----------------+
  66. 12:07:00 [DEBUG] [nioEventLoopGroup-3-1] i.n.h.l.LoggingHandler - [id: 0xd739f137, L:/192.168.0.103:9090 - R:/192.168.0.103:53155] READ COMPLETE
复制代码
缺点是，数据包的大小欠好把握

  • 长度定的太大，浪费
  • 长度定的太小，对某些数据包又显得不够
方法3：固定分隔符

服务端参加，默认以 \n 或 \r\n 作为分隔符，如果超出指定长度仍未出现分隔符，则抛出异常
  1. ch.pipeline().addLast(new LineBasedFrameDecoder(1024));
复制代码
客户端在每条消息之后，参加 \n 分隔符
  1. public class HelloWorldClient {
  2.     static final Logger log = LoggerFactory.getLogger(HelloWorldClient.class);
  4.     public static void main(String[] args) {
  5.         NioEventLoopGroup worker = new NioEventLoopGroup();
  6.         try {
  7.             Bootstrap bootstrap = new Bootstrap();
  8.             bootstrap.channel(NioSocketChannel.class);
  9.             bootstrap.group(worker);
  10.             bootstrap.handler(new ChannelInitializer<SocketChannel>() {
  11.                 @Override
  12.                 protected void initChannel(SocketChannel ch) throws Exception {
  13.                     log.debug("connetted...");
  14.                     ch.pipeline().addLast(new LoggingHandler(LogLevel.DEBUG));
  15.                     ch.pipeline().addLast(new ChannelInboundHandlerAdapter() {
  16.                         @Override
  17.                         public void channelActive(ChannelHandlerContext ctx) throws Exception {
  18.                             log.debug("sending...");
  19.                             Random r = new Random();
  20.                             char c = 'a';
  21.                             ByteBuf buffer = ctx.alloc().buffer();
  22.                             for (int i = 0; i < 10; i++) {
  23.                                 for (int j = 1; j <= r.nextInt(16)+1; j++) {
  24.                                     buffer.writeByte((byte) c);
  25.                                 }
  26.                                 buffer.writeByte(10);
  27.                                 c++;
  28.                             }
  29.                             ctx.writeAndFlush(buffer);
  30.                         }
  31.                     });
  32.                 }
  33.             });
  34.             ChannelFuture channelFuture = bootstrap.connect("192.168.0.103", 9090).sync();
  35.             channelFuture.channel().closeFuture().sync();
  37.         } catch (InterruptedException e) {
  38.             log.error("client error", e);
  39.         } finally {
  40.             worker.shutdownGracefully();
  41.         }
  42.     }
  43. }
复制代码
增长设置类和设置文件
  1. 14:08:18 [DEBUG] [nioEventLoopGroup-2-1] c.i.n.HelloWorldClient - connetted...
  2. 14:08:18 [DEBUG] [nioEventLoopGroup-2-1] i.n.h.l.LoggingHandler - [id: 0x1282d755] REGISTERED
  3. 14:08:18 [DEBUG] [nioEventLoopGroup-2-1] i.n.h.l.LoggingHandler - [id: 0x1282d755] CONNECT: /192.168.0.103:9090
  4. 14:08:18 [DEBUG] [nioEventLoopGroup-2-1] i.n.h.l.LoggingHandler - [id: 0x1282d755, L:/192.168.0.103:63641 - R:/192.168.0.103:9090] ACTIVE
  5. 14:08:18 [DEBUG] [nioEventLoopGroup-2-1] c.i.n.HelloWorldClient - sending...
  6. 14:08:18 [DEBUG] [nioEventLoopGroup-2-1] i.n.h.l.LoggingHandler - [id: 0x1282d755, L:/192.168.0.103:63641 - R:/192.168.0.103:9090] WRITE: 60B
  7.          +-------------------------------------------------+
  8.          |  0  1  2  3  4  5  6  7  8  9  a  b  c  d  e  f |
  9. +--------+-------------------------------------------------+----------------+
  10. |00000000| 61 0a 62 62 62 0a 63 63 63 0a 64 64 0a 65 65 65 |a.bbb.ccc.dd.eee|
  11. |00000010| 65 65 65 65 65 65 65 0a 66 66 0a 67 67 67 67 67 |eeeeeee.ff.ggggg|
  12. |00000020| 67 67 0a 68 68 68 68 0a 69 69 69 69 69 69 69 0a |gg.hhhh.iiiiiii.|
  13. |00000030| 6a 6a 6a 6a 6a 6a 6a 6a 6a 6a 6a 0a             |jjjjjjjjjjj.    |
  14. +--------+-------------------------------------------------+----------------+
  15. 14:08:18 [DEBUG] [nioEventLoopGroup-2-1] i.n.h.l.LoggingHandler - [id: 0x1282d755, L:/192.168.0.103:63641 - R:/192.168.0.103:9090] FLUSH
复制代码
设置文件
  1. 14:08:18 [DEBUG] [nioEventLoopGroup-3-5] c.i.n.HelloWorldServer - connected [id: 0xa4b3be43, L:/192.168.0.103:9090 - R:/192.168.0.103:63641]
  2. 14:08:18 [DEBUG] [nioEventLoopGroup-3-5] i.n.h.l.LoggingHandler - [id: 0xa4b3be43, L:/192.168.0.103:9090 - R:/192.168.0.103:63641] READ: 1B
  3.          +-------------------------------------------------+
  4.          |  0  1  2  3  4  5  6  7  8  9  a  b  c  d  e  f |
  5. +--------+-------------------------------------------------+----------------+
  6. |00000000| 61                                              |a               |
  7. +--------+-------------------------------------------------+----------------+
  8. 14:08:18 [DEBUG] [nioEventLoopGroup-3-5] i.n.h.l.LoggingHandler - [id: 0xa4b3be43, L:/192.168.0.103:9090 - R:/192.168.0.103:63641] READ: 3B
  9.          +-------------------------------------------------+
  10.          |  0  1  2  3  4  5  6  7  8  9  a  b  c  d  e  f |
  11. +--------+-------------------------------------------------+----------------+
  12. |00000000| 62 62 62                                        |bbb             |
  13. +--------+-------------------------------------------------+----------------+
  14. 14:08:18 [DEBUG] [nioEventLoopGroup-3-5] i.n.h.l.LoggingHandler - [id: 0xa4b3be43, L:/192.168.0.103:9090 - R:/192.168.0.103:63641] READ: 3B
  15.          +-------------------------------------------------+
  16.          |  0  1  2  3  4  5  6  7  8  9  a  b  c  d  e  f |
  17. +--------+-------------------------------------------------+----------------+
  18. |00000000| 63 63 63                                        |ccc             |
  19. +--------+-------------------------------------------------+----------------+
  20. 14:08:18 [DEBUG] [nioEventLoopGroup-3-5] i.n.h.l.LoggingHandler - [id: 0xa4b3be43, L:/192.168.0.103:9090 - R:/192.168.0.103:63641] READ: 2B
  21.          +-------------------------------------------------+
  22.          |  0  1  2  3  4  5  6  7  8  9  a  b  c  d  e  f |
  23. +--------+-------------------------------------------------+----------------+
  24. |00000000| 64 64                                           |dd              |
  25. +--------+-------------------------------------------------+----------------+
  26. 14:08:18 [DEBUG] [nioEventLoopGroup-3-5] i.n.h.l.LoggingHandler - [id: 0xa4b3be43, L:/192.168.0.103:9090 - R:/192.168.0.103:63641] READ: 10B
  27.          +-------------------------------------------------+
  28.          |  0  1  2  3  4  5  6  7  8  9  a  b  c  d  e  f |
  29. +--------+-------------------------------------------------+----------------+
  30. |00000000| 65 65 65 65 65 65 65 65 65 65                   |eeeeeeeeee      |
  31. +--------+-------------------------------------------------+----------------+
  32. 14:08:18 [DEBUG] [nioEventLoopGroup-3-5] i.n.h.l.LoggingHandler - [id: 0xa4b3be43, L:/192.168.0.103:9090 - R:/192.168.0.103:63641] READ: 2B
  33.          +-------------------------------------------------+
  34.          |  0  1  2  3  4  5  6  7  8  9  a  b  c  d  e  f |
  35. +--------+-------------------------------------------------+----------------+
  36. |00000000| 66 66                                           |ff              |
  37. +--------+-------------------------------------------------+----------------+
  38. 14:08:18 [DEBUG] [nioEventLoopGroup-3-5] i.n.h.l.LoggingHandler - [id: 0xa4b3be43, L:/192.168.0.103:9090 - R:/192.168.0.103:63641] READ: 7B
  39.          +-------------------------------------------------+
  40.          |  0  1  2  3  4  5  6  7  8  9  a  b  c  d  e  f |
  41. +--------+-------------------------------------------------+----------------+
  42. |00000000| 67 67 67 67 67 67 67                            |ggggggg         |
  43. +--------+-------------------------------------------------+----------------+
  44. 14:08:18 [DEBUG] [nioEventLoopGroup-3-5] i.n.h.l.LoggingHandler - [id: 0xa4b3be43, L:/192.168.0.103:9090 - R:/192.168.0.103:63641] READ: 4B
  45.          +-------------------------------------------------+
  46.          |  0  1  2  3  4  5  6  7  8  9  a  b  c  d  e  f |
  47. +--------+-------------------------------------------------+----------------+
  48. |00000000| 68 68 68 68                                     |hhhh            |
  49. +--------+-------------------------------------------------+----------------+
  50. 14:08:18 [DEBUG] [nioEventLoopGroup-3-5] i.n.h.l.LoggingHandler - [id: 0xa4b3be43, L:/192.168.0.103:9090 - R:/192.168.0.103:63641] READ: 7B
  51.          +-------------------------------------------------+
  52.          |  0  1  2  3  4  5  6  7  8  9  a  b  c  d  e  f |
  53. +--------+-------------------------------------------------+----------------+
  54. |00000000| 69 69 69 69 69 69 69                            |iiiiiii         |
  55. +--------+-------------------------------------------------+----------------+
  56. 14:08:18 [DEBUG] [nioEventLoopGroup-3-5] i.n.h.l.LoggingHandler - [id: 0xa4b3be43, L:/192.168.0.103:9090 - R:/192.168.0.103:63641] READ: 11B
  57.          +-------------------------------------------------+
  58.          |  0  1  2  3  4  5  6  7  8  9  a  b  c  d  e  f |
  59. +--------+-------------------------------------------------+----------------+
  60. |00000000| 6a 6a 6a 6a 6a 6a 6a 6a 6a 6a 6a                |jjjjjjjjjjj     |
  61. +--------+-------------------------------------------------+----------------+
  62. 14:08:18 [DEBUG] [nioEventLoopGroup-3-5] i.n.h.l.LoggingHandler - [id: 0xa4b3be43, L:/192.168.0.103:9090 - R:/192.168.0.103:63641] READ COMPLETE
复制代码
修改编解码器
[code]/** * 必须和 LengthFieldBasedFrameDecoder 一起利用，确保接到的 ByteBuf 消息是完备的 */public class MessageCodecSharable extends MessageToMessageCodec {    @Override    public void encode(ChannelHandlerContext ctx, Message msg, List outList) throws Exception {        ByteBuf out = ctx.alloc().buffer();        // 1. 4 字节的魔数        out.writeBytes(new byte[]{1, 2, 3, 4});        // 2. 1 字节的版本,        out.writeByte(1);        // 3. 1 字节的序列化方式 jdk 0 , json 1        out.writeByte(Config.getSerializerAlgorithm().ordinal());        // 4. 1 字节的指令类型        out.writeByte(msg.getMessageType());        // 5. 4 个字节        out.writeInt(msg.getSequenceId());        // 无意义，对齐填充        out.writeByte(0xff);        // 6. 获取内容的字节数组        byte[] bytes = Config.getSerializerAlgorithm().serialize(msg);        // 7. 长度        out.writeInt(bytes.length);        // 8. 写入内容        out.writeBytes(bytes);        outList.add(out);    }    @Override    protected void decode(ChannelHandlerContext ctx, ByteBuf in, List out) throws Exception {        int magicNum = in.readInt();        byte version = in.readByte();        byte serializerAlgorithm = in.readByte(); // 0 或 1        byte messageType = in.readByte(); // 0,1,2...        int sequenceId = in.readInt();        in.readByte();        int length = in.readInt();        byte[] bytes = new byte[length];        in.readBytes(bytes, 0, length);        // 找到反序列化算法        Serializer.Algorithm algorithm = Serializer.Algorithm.values()[serializerAlgorithm];        // 确定具体消息类型        Class, Object> options = options0();    synchronized (options) {        setChannelOptions(channel, options, logger);    }    final Map, Object>[] currentChildOptions;    final Entry
回复

使用道具 举报

0 个回复

倒序浏览
返回列表

快速回复

高级模式
B Color Image Link Quote Code Smilies
您需要登录后才可以回帖 登录 or 立即注册

本版积分规则

万有斥力

金牌会员
这个人很懒什么都没写!

楼主热帖

标签云

挺好的 服务器
微信订阅号
微信服务号
微信客服
小程序
H5
关于我们 商务合作 网站地图
©Copyright 2022-2024 杭州祥升科技有限公司 版权所有 浙ICP备20004199号
快速回复 返回顶部 返回列表