0

这是我的工具,对吗?

public ChannelPipeline getPipeline() throws Exception 
{
    ChannelPipeline p = pipeline();
    pipeline.addLast("decoder", new HttpRequestDecoder());
    p.addLast("frameDecoder", new ProtobufVarint32FrameDecoder());
    p.addLast("protobufDecoder", new ProtobufDecoder(LocalTimeProtocol.Locations.getDefaultInstance()));
    pipeline.addLast("encoder", new HttpResponseEncoder());
    p.addLast("frameEncoder", new ProtobufVarint32LengthFieldPrepender());
    p.addLast("protobufEncoder", new ProtobufEncoder());
    p.addLast("handler", new LocalTimeServerHandler());
    return p;
}
4

1 回答 1

0

不起作用。您必须编写一个处理程序来获取 HTTP 请求的内容并将请求的内容 (ChannelBuffer) 转换为 protobuf 消息。下游也需要做类似的工作。

于 2012-05-29T09:23:39.560 回答