关于dart:netty系列之性能为王创建多路复用http2服务器

5次阅读

共计 2914 个字符，预计需要花费 8 分钟才能阅读完成。

在之前的文章中，咱们提到了在 netty 的客户端通过应用 Http2FrameCodec 和 Http2MultiplexHandler 能够反对多路复用，也就是说在一个连贯的 channel 根底上创立多个子 channel，通过子 channel 来解决不同的 stream，从而达到多路复用的目标。

既然客户端能够做到多路复用，同样的服务器端也能够，明天给大家介绍一下如何在 netty 的服务器端打造一个反对 http2 协定的多路复用服务器。

netty 中对于 http2 多路复用的根底类是 Http2FrameCodec、Http2MultiplexHandler 和 Http2MultiplexCodec。

Http2FrameCodec 是将底层的 HTTP/2 frames 音讯映射成为 netty 中的 Http2Frame 对象。

有了 Http2Frame 对象就能够通过 Http2MultiplexHandler 对新创建的 stream 开启不同的 channel。

Http2MultiplexCodec 是 Http2FrameCodec 和 Http2MultiplexHandler 的结合体，然而曾经不再被举荐应用了。

因为 Http2FrameCodec 继承自 Http2ConnectionHandler，而 Http2MultiplexHandler 继承自 Http2ChannelDuplexHandler，所以这两个类能够同时在客户端和服务器端应用。

客户端应用 Http2FrameCodecBuilder.forClient().build() 来取得 Http2FrameCodec，而服务器端通过 Http2FrameCodecBuilder.forServer().build() 来取得 Http2FrameCodec。

对于服务器端，同样须要解决 TLS 和一般 clear text 两种状况。对于 TLS 来说，咱们须要自建 ProtocolNegotiationHandler 继承自 ApplicationProtocolNegotiationHandler，而后实现 configurePipeline 办法，在其中别离解决 http2 和 http1.1 的连贯：

    protected void configurePipeline(ChannelHandlerContext ctx, String protocol) {if (ApplicationProtocolNames.HTTP_2.equals(protocol)) {
            // 增加多路复用反对
            ctx.pipeline().addLast(Http2FrameCodecBuilder.forServer().build());
            ctx.pipeline().addLast(new Http2MultiplexHandler(new CustMultiplexHttp2Handler()));
            return;
        }

        if (ApplicationProtocolNames.HTTP_1_1.equals(protocol)) {ctx.pipeline().addLast(new HttpServerCodec(),
                                   new HttpObjectAggregator(MAX_CONTENT_LENGTH),
                                   new CustHttp1Handler("ALPN Negotiation"));
            return;
        }

        throw new IllegalStateException("未知协定:" + protocol);
    }

首先增加 Http2FrameCodec，而后增加 Http2MultiplexHandler。因为 Http2MultiplexHandler 曾经封装了多路复用的细节，所以自定义的 handler 只须要实现失常的音讯解决逻辑即可。

因为 Http2FrameCodec 曾经对音讯进行了转换成为 HTTP2Frame 对象，所以只须要解决具体的 Frame 对象：

    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {if (msg instanceof Http2HeadersFrame) {onHeadersRead(ctx, (Http2HeadersFrame) msg);
        } else if (msg instanceof Http2DataFrame) {onDataRead(ctx, (Http2DataFrame) msg);
        } else {super.channelRead(ctx, msg);
        }
    }

对于 h2c 的降级来说，须要向 pipline 中传入 sourceCodec 和 upgradeHandler 两个处理器。

sourceCodec 能够间接应用 HttpServerCodec。

upgradeHandler 能够应用 HttpServerUpgradeHandler。

HttpServerUpgradeHandler 的构造函数须要传入一个 sourceCodec 和一个 upgradeCodecFactory。

sourceCodec 咱们曾经有了，再结构一个 upgradeCodecFactory 即可：

    private static final UpgradeCodecFactory upgradeCodecFactory = protocol -> {if (AsciiString.contentEquals(Http2CodecUtil.HTTP_UPGRADE_PROTOCOL_NAME, protocol)) {
            return new Http2ServerUpgradeCodec(Http2FrameCodecBuilder.forServer().build(),
                    new Http2MultiplexHandler(new CustMultiplexHttp2Handler()));
        } else {return null;}
    };

从代码中能够看出，upgradeCodecFactory 外部又调用了 Http2FrameCodec 和 Http2MultiplexHandler。这和应用 TLS 的处理器是统一的。

        final ChannelPipeline p = ch.pipeline();
        final HttpServerCodec sourceCodec = new HttpServerCodec();
        p.addLast(sourceCodec);
        p.addLast(new HttpServerUpgradeHandler(sourceCodec, upgradeCodecFactory));

通过上述形式，就能够创立出反对多路复用的 http2 netty 服务器了。

本文的例子能够参考：learn-netty4