EmbeddedChannel 可以使用一个特殊的 EmbeddedChannel 模拟消息的入站和出站操作，在不真实创建连接的情况下测试 ChannelHandler 是否能正常工作。 假设 Netty 的 Pipline 包含这几个常用的 Handler： LengthFieldBasedFrameDecoder，将长度+消息内容的帧读取 LengthFieldPrepender，将消息帧添加长度 StringDecoder，将字节解码为字符串 StringEncoder，将字符串编码为字节 添加Embedde…

黏包 在 Netty 中向通道写入并刷新一段数据，并不意味着客户端会立即将数据打包发送给服务端，因为底层的 TCP/IP 协议为了优化数据传输，往往会在数据量较小时，将多个数据包合并成一个数据包进行发送，或者在数量较大时，拆分成多个数据包进行发送。因此服务端收到数据包并使用 ByteBuf 读取数据时，会读到不完整或连在一起的多次发送的数据。这就是所谓的黏包/半包问题。 解决黏包/半包通常有这么几种方式： 用换行符分隔 用指定特殊字符分隔 用指定长度的字节数组传输数据 使用一个4字节整型指定数据体长度 Netty …

本文的两个示例来自 Netty 官方示例，由笔者用 Maven 实现。 回写服务器 Netty 封装了 NIO 的大多数处理步骤，我们只需要将精力集中在业务代码编写上，比如，如果要创建一个最简单的服务端，只打印并丢弃客户端发送来的内容。 public class DiscardServerHandler extends ChannelInboundHandlerAdapter {    @Override    public void channelRead(ChannelHandlerContext ctx, O…