Netty 5 HTTP 協議棧深度解析與實戰指南

閱讀導航

1. 前言：為何選 Netty 實現高併發 HTTP 服務
2. HTTP 協議基礎：GET/POST 請求結構、Content-Type 詳解
3. Netty 編解碼器體系：HttpServerCodec、HttpObjectAggregator
4. GET/POST 解析實戰：QueryStringDecoder、HttpPostRequestDecoder
5. 自定義 Decoder：HttpJsonDecoder、HttpProtobufDecoder
6. 踩坑實錄：內存洩漏、HTTP 長連接處理

一、項目背景

視頻質量統計系統，需支持 10W+ TPS。選 Netty 因：異步非阻塞模型、輕量無容器開銷、資源佔用優於 Tomcat、官方宣稱 HTTP 支持完善。

GitHub 實戰項目：netty-http，已實現 GET/POST 解析、三種 Content-Type 處理、文件上傳、自定義 Decoder。

二、HTTP 協議核心

1. GET 請求

GET /test?name=XXG&age=23 HTTP/1.1
Host: localhost:8081
...Headers...

參數在 URI 中，無 Message Body。

2. POST 請求

POST /test HTTP/1.1
Content-Type: application/x-www-form-urlencoded
Content-Length: 27

name=XXG&age=23

參數在 Body 中，需 Content-Length 指定長度。

3. 三大 POST Content-Type

• application/x-www-form-urlencoded：鍵值對編碼，表單默認
• multipart/form-data：文件上傳，Boundary 分割字段
• application/json：JSON 字符串，適合結構化數據、REST API

三、Netty HTTP 編解碼器

• HttpRequestDecoder：ByteBuf → HttpRequest/HttpContent
• HttpResponseEncoder：HttpResponse/HttpContent → ByteBuf
• HttpServerCodec：上述兩者組合
• 關鍵 HttpObjectAggregator：將 HttpMessage + HttpContent 聚合為 FullHttpRequest/Response，解決分片傳輸與 POST Body 解析問題

Pipeline 配置：

ch.pipeline().addLast("codec", new HttpServerCodec())
              .addLast("aggregator", new HttpObjectAggregator(65536));

四、請求解析實戰

1. GET 參數解析

QueryStringDecoder decoder = new QueryStringDecoder(uri, CharsetUtil.UTF_8);
Map> params = decoder.parameters();

2. POST 解析（需 Aggregator）

FullHttpRequest fullReq = (FullHttpRequest) msg;
// JSON
String json = fullReq.content().toString(CharsetUtil.UTF_8);
JSONObject obj = JSON.parseObject(json);

// form-urlencoded：QueryStringDecoder 或 HttpPostRequestDecoder
HttpPostRequestDecoder decoder = new HttpPostRequestDecoder(factory, request, CharsetUtil.UTF_8);
for (InterfaceHttpData data : decoder.getBodyHttpDatas()) {
    if (data.getHttpDataType() == HttpDataType.Attribute) {
        Attribute attr = (Attribute) data;
        System.out.println(attr.getName() + "=" + attr.getValue());
    }
}

// multipart 文件上傳
DiskFileUpload.baseDirectory = "/data/fileupload/";
for (InterfaceHttpData data : decoder.getBodyHttpDatas()) {
    if (data.getHttpDataType() == HttpDataType.FileUpload) {
        FileUpload file = (FileUpload) data;
        if (file.isCompleted()) file.renameTo(new File(baseDir + file.getFilename()));
    }
}

五、自定義 Decoder 實現

1. HttpJsonDecoder

public class HttpJsonDecoder extends MessageToMessageDecoder {
    protected void decode(ChannelHandlerContext ctx, HttpRequest msg, List