如何通过Netty公开API将FullHttpResponse转为完整ByteBuf用于缓存

Netty提供了成熟的公开API可以实现该需求，生成的ByteBuf包含响应行、响应头、响应体全量内容，完全符合HTTP协议规范，可直接用于缓存场景。

方案1：复用内置HttpResponseEncoder编码（推荐） #

该方案和Netty默认HTTP出站编码逻辑完全一致，无需手动处理协议格式，不会出现兼容性问题：

• 依赖的io.netty.handler.codec.http.HttpResponseEncoder是Netty公开的标准组件，无需引入额外依赖
• 编码生成的ByteBuf和实际网络发送的响应内容完全相同

import io.netty.buffer.ByteBuf;
import io.netty.buffer.PooledByteBufAllocator;
import io.netty.handler.codec.http.*;
import java.nio.charset.StandardCharsets;

// 1. 构造业务需要的FullHttpResponse
FullHttpResponse response = new DefaultFullHttpResponse(
        HttpVersion.HTTP_1_1,
        HttpResponseStatus.OK,
        PooledByteBufAllocator.DEFAULT.buffer().writeBytes("缓存的响应内容".getBytes(StandardCharsets.UTF_8))
);
// 按需设置响应头，必须设置Content-Length和响应类型
response.headers().set(HttpHeaderNames.CONTENT_TYPE, "text/plain; charset=utf-8");
response.headers().set(HttpHeaderNames.CONTENT_LENGTH, response.content().readableBytes());

// 2. 编码得到完整响应ByteBuf
HttpResponseEncoder encoder = new HttpResponseEncoder();
ByteBuf fullResponseBuf = PooledByteBufAllocator.DEFAULT.buffer();
try {
    encoder.encode(null, response, fullResponseBuf);
} catch (Exception e) {
    fullResponseBuf.release();
    throw new RuntimeException("HTTP响应编码失败", e);
}

// fullResponseBuf就是完整的HTTP响应ByteBuf，使用完成后记得调用release()释放内存

方案2：手动拼接协议内容（适合自定义场景） #

如果需要定制协议序列化逻辑，可以手动拼接三部分内容，注意严格遵循HTTP协议规范：

• 响应行格式：[HTTP版本] [状态码] [原因短语]\r\n
• 响应头格式：每个头为[头名]: [头值]\r\n，所有头写完后额外加\r\n分隔头和体
• 最后追加响应体内容

ByteBuf fullResponseBuf = PooledByteBufAllocator.DEFAULT.buffer();
// 写入响应行
fullResponseBuf.writeCharSequence(
        response.protocolVersion() + " " + response.status() + "\r\n",
        StandardCharsets.UTF_8
);
// 写入所有响应头
for (Map.Entry<CharSequence, CharSequence> header : response.headers()) {
    fullResponseBuf.writeCharSequence(
            header.getKey() + ": " + header.getValue() + "\r\n",
            StandardCharsets.UTF_8
    );
}
// 写入头体分隔符
fullResponseBuf.writeCharSequence("\r\n", StandardCharsets.UTF_8);
// 写入响应体
fullResponseBuf.writeBytes(response.content().duplicate());

注意：手动拼接必须使用\r\n作为换行符，且保证Content-Length头的值和实际响应体长度一致，否则会导致客户端解析失败

缓存使用提示 #

• 若缓存的ByteBuf会被多次读取，建议调用retain()增加引用计数，或者转为堆字节数组存储，避免Netty堆外内存泄漏
• 缓存的ByteBuf可以直接写入Netty Channel出站，无需二次编码，能大幅降低高并发场景下的CPU开销

内容的提问来源于stack exchange，提问作者tusharmath