Netty HttpServerCodec和HttpObjectAggregator

2024 年 03 月 13 日

62 次浏览

2181字数

Netty是一个高性能的异步事件驱动的网络应用程序框架，用于快速开发可维护的高性能协议服务器和客户端。在处理HTTP协议时，Netty提供了 HttpServerCodec和 HttpObjectAggregator两个类以简化HTTP消息的处理过程。

HttpServerCodec

HttpServerCodec是一个编解码器，用于将字节流转换为HTTP消息对象，或将HTTP消息对象转换为字节流。简言之，它结合了 HttpRequestDecoder和 HttpResponseEncoder的功能，是一个方便的工具，用于HTTP服务器端的通道管道中，能够处理HTTP请求和响应的编码和解码。

在Netty的管道中加入 HttpServerCodec，实际上就是加入了两个单独的处理器：一个用于请求解码，一个用于响应编码。这个编解码器会将接收到的字节流分解成HTTP请求的各部分，例如 HttpRequest、HttpContent，以及 LastHttpContent这样的消息对象。同样地，在响应客户端时也能将 HttpResponse对象序列化成能在网络上发送的字节流。

HttpObjectAggregator

在HTTP通信中，一个HTTP消息可能由多个部分组成，具体可能包括一个 HttpRequest或 HttpResponse，跟随着一个或多个 HttpContent对象，最后以一个 LastHttpContent对象结束。如果希望以一个单一的对象来处理完整的HTTP消息，就需要用到 HttpObjectAggregator。

HttpObjectAggregator是一个通道处理器，在Netty的管道中主要用于将分散的多个消息部分合并成一个完整的HTTP请求或响应对象（即 FullHttpRequest或 FullHttpResponse），这样就能够确保你的业务处理器能够处理完整的HTTP消息。此外，HttpObjectAggregator也能够处理HTTP消息的分块传输编码的聚合。

在许多场景下，HttpObjectAggregator是必要的，尤其是当你需要处理的HTTP消息可能包含多个部分而不是一个单一流式消息时。正因为 HttpObjectAggregator可将这些部分合并，我们才可以关心消息的整个负载，忽视掉消息的分块状态。

使用场景

考虑到HTTP通信的复杂性，不同的HTTP消息可能包含多段数据，甚至是分块传输的数据。因此，在Netty的HTTP服务器管道中，通常会按照下面的顺序添加编解码器和聚合器：

ChannelPipeline p = ch.pipeline();
p.addLast("codec", new HttpServerCodec());
p.addLast("aggregator", new HttpObjectAggregator(512 * 1024)); // 设置聚合内容的最大长度

以上配置确保了传入的HTTP消息会被 HttpServerCodec解码，然后再经过 HttpObjectAggregator处理成完整的消息方便后续处理器处理。由此可见，HttpServerCodec与 HttpObjectAggregator在Netty实现HTTP服务器功能时共同发挥着至关重要的作用，配合使用可以显著简化HTTP协议的处理流程。