处理netty中的HTTP客户端异常

Question

我对netty比较陌生，不确定自己做的事情是否正确。我会尽量短一点。如果有任何不清楚的地方，请询问更多信息。

因此，我有一个提供HTTP请求的netty服务器，其中的内容应该是序列化为Json字符串的protobuf消息。

通道管道如下所示：

@Override protected void initChannel(final SocketChannel channel) throws Exception {
    final ChannelPipeline pipeline = channel.pipeline();
    pipeline.addLast(new HttpServerCodec());
    pipeline.addLast(new HttpObjectAggregator(1048576));
    pipeline.addLast(new HttpProtobufServerCodec(charset, requestConverter, responseConverter));
    pipeline.addLast(new ProtobufMessageHandler(mapping));
}

前两个通道处理程序是标准的netty工具,

HttpProtobufServerCodec类似于：

public class HttpProtobufServerCodec extends CombinedChannelDuplexHandler<HttpToProtobufDecoder, ProtobufToHttpEncoder>

和HttpToProtobufDecoder类似于：

public final class HttpToProtobufDecoder extends MessageToMessageDecoder<FullHttpRequest> {
    private Charset charset;
    private final Converter<byte[], ?> converter;

    protected HttpToProtobufDecoder(final Charset charset, final Converter<byte[], ?> converter) {
        this.charset = charset;
        this.converter = converter;
    }

    @Override protected void decode(final ChannelHandlerContext ctx, final FullHttpRequest msg, final List<Object> out)
            throws Exception {
        byte[] payloadBytes = new byte[msg.content().readableBytes()];
        msg.content().readBytes(payloadBytes);
        Message message = (Message) converter.convert(payloadBytes);
        out.add(message);
    }

    @Override public void exceptionCaught(final ChannelHandlerContext ctx, final Throwable cause) throws Exception {
        FullHttpResponse response = new DefaultFullHttpResponse(HttpVersion.HTTP_1_1, 
                    HttpResponseStatus.BAD_REQUEST, 
                    Unpooled.wrappedBuffer(charset.encode("Could not read request!").array()));

        //ctx.writeAndFlush(response);
        ctx.writeAndFlush(response).addListener(ChannelFutureListener.CLOSE);
    }
}

因此，我在HttpToProtobufDecoder中接收一个FullHttpRequest，并尝试将请求的内容解码为protobuf消息。如果无法解码内容，则抛出异常，这将使我们处于ExceptionCatch（...）方法..

在捕获异常时，创建HTTP 400响应并将其写入ChannelHandlerContext。这就是我的问题所在。

如果切换了以下行上的注释：

//ctx.writeAndFlush(response);
ctx.writeAndFlush(response).addListener(ChannelFutureListener.CLOSE);

客户端在读取响应正文时超时。但如果我在写完400之后关闭频道，一切似乎都很好。所发生的是；输入流的读取被阻止，因为没有可用的输入数据。即。我们被困在.read（...）下面，在客户端代码下面的某个地方：

while ((bytesRead = in.read(buffer)) != -1) {
        out.write(buffer, 0, bytesRead);
        byteCount += bytesRead;
    }

所以，问题是，您是否有关闭通道后，编写http 400响应由于某种原因？

我这样做对吗？我应该在ExceptionCatch中编写HTTP响应消息吗？

对不起，如果这个问题有点不清楚。任何帮助都将不胜感激！

/谢谢！

Answer 1

客户端无法知道您的消息何时已完全发送。添加一个内容长度或分块头，您将不再需要关闭连接。