java - Netty:如何重用相同的 `FullHttpResponse` ？

Question

在我的项目中，我想写同样的 FullHttpResponse对许多客户来说是为了提高性能。

以前我也写过同样的ByteBuf对于自定义协议(protocol)，并使用了 retain防止写入后释放buf。

不幸的是 FullHttpResponse ( DefaultFullHttpResponse ) 我的技术似乎不起作用。我第一次写入响应时，客户端正确接收到响应，但下一次写入没有通过。

我做了一个简单的 System.out.println测试以确保没有任何阻塞并且我的代码已完全执行，我的测试表明是的，没有任何阻塞并且请求似乎确实通过了。

我正在使用 Netty 4.1.0.Final从 Maven Central 发布。

---

管道只有一个 HttpServerCodec(256, 512, 512, false, 64)和我的 SimpleChannelInboundHandler<HttpRequest> ，我发送 FullHttpResponse来自。

这是我的入站处理程序的简化版本:

class HTTPHandler extends SimpleChannelInboundHandler<HttpRequest> {

    private static final FullHttpResponse response =
            new DefaultFullHttpResponse(HttpVersion.HTTP_1_1, 
                                        HttpResponseStatus.OK,
                                        Unpooled.buffer(8).writeLong(0),
                                        false);

    @Override
    public void channelRead0(ChannelHandlerContext ctx, HttpRequest msg) {
        ctx.writeAndFlush(response.retain(), ctx.voidPromise());
    }

}

Answer 1

你需要使用 response.duplicate().retain() 或者如果使用 Netty 4.1.x 你也可以使用 response.retainedDuplicate()。

这是确保您获得单独的读者/作者索引所必需的。