0

我们将二进制编码数据作为 JSON 请求的有效负载发送到我们的 Netty 后端。在较小的有效载荷（1-2MB）上一切都很好，但在较大的有效载荷上它会失败并带有HTTP 413 Request entity too large.

我们发现了两个可能会受到影响的地方：

  1. HttpObjectAggregator的构造函数
  2. JsonObjectDecoder主体解析器的构造函数。

我们将第一个设置为高于（10MB）我们的问题阈值（5MB）的默认方式，而后者我们根本不使用，所以我们不确定如何深入研究这个。

（顺便说一句，我们打算在未来不将 JSON 用于大型二进制有效负载，因此不需要更改底层架构的“有用”提示 ;-)）

管道设置 我们有两个阶段的管道初始化，第一阶段取决于http协议版本和SSL是否结合，后一个阶段只关注应用程序级别的处理程序。PipelineInitializer只是一个内部接口。

/**
 * This class is concerned with setting up the handlers for the protocol level of the pipeline
 * Only use it for the cases where you know the passed in traffic will be HTTP 1.1
 */
public class Http1_1PipelineInitializer implements PipelineInitializer {

    private final static int MAX_CONTENT_LENGTH = 10 * 1024 * 1024; // 10MB

    @Override
    public void addHandlersToPipeline(ChannelPipeline pipeline) {
        pipeline.addLast(
                new HttpServerCodec(),
                new HttpObjectAggregator(MAX_CONTENT_LENGTH),
                new HttpChunkContentCompressor(),
                new ChunkedWriteHandler()
        );
    }

}

我们的 ApplicationPipelineInitializer 中的应用程序级管道设置。我不认为这些是相关的，但为了完整性而包括在内。这部分中的所有处理程序都是用户定义的处理程序：

@Override
public void addHandlersToPipeline(final ChannelPipeline pipeline) {
    pipeline.addLast(
            new HttpLoggerHandler(),
            userRoleProvisioningHandler,
            authHandlerFactory.get(),
            new AuthenticatedUserHandler(services),
            createRoleHandlerFactory(configuration, services, externalAuthorizer).get(),
            buildInfoHandler,
            eventStreamEncoder,
            eventStreamDecoder,
            eventStreamHandler,
            methodEncoder,
            methodDecoder,
            methodHandler,
            fileServer,
            notFoundHandler,
            createInterruptOnErrorHandler());

    // Prepend the error handler to every entry in the pipeline. The intention behind this is to have a catch-all
    // outbound error handler and thereby avoiding the need to attach a listener to every ctx.write(...).
    final OutboundErrorHandler outboundErrorHandler = new OutboundErrorHandler();
    for (Map.Entry<String, ChannelHandler> entry : pipeline) {
        pipeline.addBefore(entry.getKey(), entry.getKey() + "#OutboundErrorHandler", outboundErrorHandler);
    }
}

Netty 版本 4.1.15

4

1 回答 1

3

很抱歉浪费了大家的时间：这根本不是 Netty，因此很疯狂。检查输出后，我发现返回 HTTP 错误的是前面的 Nginx 反向代理，而不是 Netty。添加client_max_body_size 10M;成功了，它的限制与 Netty 的对齐。

于 2018-09-04T20:27:02.570 回答