image.png

1. 客户端和服务端的编解码对象有差异

if (client) {
    pipeline.addLast("decoder", new HttpResponseDecoder());
    pipeline.addLast("encoder", new HttpRequestEncoder());
} else {
    pipeline.addLast("decoder", new HttpRequestDecoder());
    pipeline.addLast("encoder", new HttpResponseEncoder());
}

2. Http消息聚合生成FullHttpRequest和FullHttpResponse

ChannelPipeline pipeline = ch.pipeline();
if (isClient) {
    pipeline.addLast("codec", new HttpClientCodec());
} else {
    pipeline.addLast("codec", new HttpServerCodec());
}
pipeline.addLast("aggregator",new HttpObjectAggregator(512 * 1024));

3. 开启压缩可减小传输数据的大小，支持gzip和deflate编码，客户端可以压缩请求但是服务端没有义务返回压缩数据

// 服务端压缩，客户端解压示例
ChannelPipeline pipeline = ch.pipeline();
if (isClient) {
    pipeline.addLast("codec", new HttpClientCodec());
    pipeline.addLast("decompressor", new HttpContentDecompressor());
} else {
    pipeline.addLast("codec", new HttpServerCodec());
    pipeline.addLast("compressor", new HttpContentCompressor());
}

4. HTTPS支持

ChannelPipeline pipeline = ch.pipeline();
SSLEngine engine = context.newEngine(ch.alloc());
pipeline.addFirst("ssl", new SslHandler(engine));
if (isClient) {
    pipeline.addLast("codec", new HttpClientCodec());
} else {
    pipeline.addLast("codec", new HttpServerCodec());
}

WebSocket 在客户端和服务器之间提供了真正的双向数据交换，先通过Http握手，再进行帧形式的WebSocket通信

image.png

1. BinaryWebSocketFrame：数据帧，二进制
2. TextWebSocketFrame：数据帧，文本数据
3. ContinuationWebSocketFrame：数据帧，属于上一个BinaryWebSocketFrame或者 TextWebSocketFrame的文本的或者二进制数据
4. BinaryWebSocketFrame：控制帧：一个 CLOSE 请求、关闭的状态码以及关闭的原因
5. PingWebSocketFrame：控制帧：请求一个 PongWebSocketFrame
6. PongWebSocketFrame：控制帧：对 PingWebSocketFrame 请求的响应

• IdleStateHandler：当连接空闲时间太长时，会触发IdleStateEvent事件。然后，可通过在ChannelInboundHandler中重写userEventTriggered()方法来处理该IdleStateEvent事件
• ReadTimeoutHandler：在指定时间间隔内没收到任何入站数据，则抛出ReadTimeoutException并关闭对应的Channel。可通过重写ChannelHandler中exceptionCaught()方法来检测该ReadTimeoutException
• WriteTimeoutHandler：在指定时间间隔内没任何出站数据写入，则抛出WriteTimeoutException并关闭对应的Channel 。可通过重写ChannelHandler的exceptionCaught()方法检测该 WriteTimeoutException

1. 基于分隔符的协议
   • DelimiterBasedFrameDecoder：使用任何由用户提供的分隔符来提取帧的通用解码器
   • LineBasedFrameDecoder提取由行尾符（ \n 或者 \r\n ）分隔的帧的解码器。这个解码器比 DelimiterBasedFrameDecoder更快
2. 基于长度的协议通过将长度编码到帧的头部来定义帧。
   • FixedLengthFrameDecoder：提取在调用构造函数时指定的定长帧
   • LengthFieldBasedFrameDecoder：根据编码进帧头部中的长度值提取帧；该字段的偏移量以及长度在构造函数中指定
     
     image.png

• CompatibleMarshallingDecoder、CompatibleMarshallingEncoder：与只使用 JDK 序列化的远程节点兼容
• MarshallingDecoder、MarshallingEncoder：适用于使用 JBoss Marshalling 的节点。这些类必须一起使用

• ProtobufDecoder：使用 protobuf 对消息进行解码
• ProtobufEncoder：使用 protobuf 对消息进行编码
• ProtobufVarint32FrameDecoder：根据消息中的Google Protocol Buffers 的“Base 128 Varints”整型长度字段值动态地分割所接收到的ByteBuf
• ProtobufVarint32LengthFieldPrepender：向ByteBuf前追加一个 Google Protocal Buffers 的“Base128 Varints”整型的长度字段值