HTTP 内容中的 Netty 和 Protobuf答案

【问题标题】：Netty and Protobuf in HTTP contentHTTP 内容中的 Netty 和 Protobuf
【发布时间】：2014-02-26 19:11:27
【问题描述】：

我在 HTTP 内容中有带有 protobuf 消息的传入 HTTP 请求。到目前为止，我设法使用了 Snoop（HTTP 服务器）示例并修改了处理程序部分以将 HTTP 内容解析为 protobuf 消息并返回字节以进行输出。但我想这不是做到这一点的最佳方式。

是否可以在管道中使用 Netty 中内置的 Protobuf 编码器/解码器？所以首先 HTTPResponseDecoder（或更方便的东西）“砍掉”头部，只将内容部分传递给 FrameDecoder + ProtobufDecoder，然后将消息传递给 myAppHandler 应用业务逻辑的地方？

我有点困惑如何将消息（或其中的一部分）传递给下一个处理程序。还是我完全走错了路？

如果有的话，也许一个使用带有 HTTP 内容的 protobuf 的示例的链接也可以作为解释。

提前谢谢。

【问题讨论】：

标签： http netty protocol-buffers

【解决方案1】：

感谢您的默默支持：]

解决方案是使用 HttpObjectAggregator() 并使用来自聚合器处理程序的 FullHttpRequest 简单地编写一个处理程序来处理字节到消息的过程。此解码器的输出是 protobuf 消息：

public class ProtoRequestDecoder extends MessageToMessageDecoder<FullHttpRequest> {
    @Override
    protected void decode(ChannelHandlerContext ctx, FullHttpRequest msg, List<Object> out) throws Exception {


        byte[] payloadBytes = new byte[msg.content().readableBytes()];
        msg.content().readBytes(payloadBytes);

        MyMessage protoMessage = MyMessage.parseFrom(payloadBytes);

        out.add(protoMessage);

    }
}

【讨论】：

能否请您展示有关初始化管道的代码？