#yyds幹貨盤點#還有這種好事！netty自帶http2的編碼解碼器framecodec

簡介

netty為我們提供了很多http2的封裝，讓我們可以輕松的搭建出一個支援http2的伺服器。其中唯一需要我們自定義的就是http2 handler。

在之前的文章中，我們介紹了自定義http2handler繼承自Http2ConnectionHandler并且實作Http2FrameListener。這種實作方式是netty目前比較推薦的實作方式，今天給大家介紹的一種實作方式是netty中準備替換繼承Http2ConnectionHandler的實作方式，但是這種實作方式并不成熟，還在不斷的完善中。

今天給大家介紹一下這種實作方式。

Http2FrameCodec

這種實作方式的核心類是Http2FrameCodec。事實上Http2FrameCodec也是繼承自Http2ConnectionHandler。

它的主要作用是将HTTP/2中的frames和Http2Frame對象進行映射。Http2Frame是netty中對應所有http2 frame的封裝，這樣就可以在後續的handler中專注于處理Http2Frame對象即可，進而擺脫了http2協定的各種細節，可以減少使用者的工作量。

對于每個進入的HTTP/2 frame，Http2FrameCodec都會建立一個Http2Frame對象，并且将其傳遞給channelRead方法，用于對該對象進行處理。

通過調用write方法，可以對outbound的 Http2Frame 轉換成為http2 frame的格式。

Http2Frame、Http2FrameStream和Http2StreamFrame

netty中有三個非常類似的類，他們是Http2Frame、Http2FrameStream和Http2StreamFrame。

我們知道netty中一個tcp連接配接可以建立多個stream,Http2FrameStream就是和stream對應的類，這個類中包含了stream的id和stream目前的狀态。

一個stream中又包含了多個消息，每個消息都是由多個frame組成的，是以Http2Frame是和這些frame對應的netty類。

Http2StreamFrame本身也是一個frame，事實上它繼承自Http2Frame。

為什麼會有這個類呢？因為對應frame本身來說，一般情況下它是和一個特定的stream相關聯的，Http2StreamFrame表示這種關聯關系，可以通過它的set stream方法來指定其關聯的stream。如果想要該frame應用到整個連接配接而不是特定的某個stream，如果是關聯到整個連接配接，那麼stream()方法的傳回就是null。

Http2FrameCodec的構造

雖然Http2FrameCodec有構造函數，但是netty推薦使用Http2FrameCodecBuilder來構造它：

Http2FrameCodecBuilder.forServer().build()；
      

可以看到Http2FrameCodecBuilder有一個forServer還有一個forClient方法。他們一個是使用在伺服器端，一個是使用在用戶端。

主要是通過裡面的server屬性來進行區分。

Stream的生命周期

frame codec将會向有效的stream發送和寫入frames。之前講過了 Http2StreamFrame 是和一個Http2FrameStream對象相關聯的。

對于一個有效的stream來說，如果任意一方發送一個RST_STREAM frame，那麼該stream就會被關閉。

或者發送方或者接收方任意一方發送的frame中帶有END_STREAM标記，該stream也會被關閉。

流控制

Http2FrameCodec提供了對流的自動控制，但是我們仍然需要做一些操作，來對window進行更新。

具體而言，當我們在接收到Http2DataFrame消息的時候，對消息進行處理之後，需要增大window的大小，表示該data已經被處理了，可以有更多的空間去容納新的資料。

也就是說需要向ctx中寫入一個Http2WindowUpdateFrame，在這個Http2WindowUpdateFrame中需要傳入處理的data的大小和對應stream的id，下面是一個處理data frame的例子：

/**
     * 處理data frame消息
     */
    private static void onDataRead(ChannelHandlerContext ctx, Http2DataFrame data){
        Http2FrameStream stream = data.stream();
        if (data.isEndStream()) {
            sendResponse(ctx, stream, data.content());
        } else {
            // 不是end stream不發送，但是需要釋放引用
            data.release();
        }
        // 處理完data，需要更新window frame，增加處理過的Data大小
        ctx.write(new DefaultHttp2WindowUpdateFrame(data.initialFlowControlledBytes()).stream(stream));
    }
      

上的例子中，我們向DefaultHttp2WindowUpdateFrame傳入了對應的stream id，如果stream id為0，則表示處理的是整個connection，而不是單獨的某個stream。

除了window update frame之外，對于某個特定stream的初始window還可以發送一個 Http2SettingsFrame，通過設定Http2Settings.initialWindowSize() 達到初始化的目的。

接收消息

對于每個HTTP/2 stream來說，其中包含的frame可以分為 Http2HeadersFrame和Http2DataFrame，而Http2HeadersFrame必定是第一個接收到的frame,并且這個headerFrame還關聯了對應的stream對象：Http2FrameStream。

是以我們在處理的時候可以針對這兩種不同的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);
        }
    }
      

自定義handler

如果使用Http2FrameCodec，我們隻需要在pipline中添加Http2FrameCodec之後，再添加自定義的handler即可：

ctx.pipeline().addLast(Http2FrameCodecBuilder.forServer().build(), new CustHttp2Handler());
      

因為Http2FrameCodec已經對http2中的frame進行了轉換，是以我們在CustHttp2Handler中隻需要處理自定義邏輯即可。

netty推薦自定義的handler繼承自Http2ChannelDuplexHandler，因為它比普通的ChannelDuplexHandler多了一個建立newStream()和周遊所有有效stream的 forEachActiveStream(Http2FrameStreamVisitor)方法。

總結

本文講解了Http2FrameCodec的原理，和與其搭配的handler實作中要注意的事項。

本文的例子可以參考：​​learn-netty4​​

本文已收錄于 ​​http://www.flydean.com/31-netty-framecodec-http2/​​