Netty
【直播预告】计算中间件Linkis开源技术的应用和实践！>>> 
protected void initChannel(SocketChannel ch) throws Exception {
ChannelPipeline p = ch.pipeline();
//解码用
p.addLast("frameDecoder", new ProtobufVarint32FrameDecoder());
//构造函数传递要解码成的类型 这里如果再有一个LocalDates的话应该怎么处理
p.addLast("protobufDecoder", new ProtobufDecoder(LocalTimeProtocol.LocalTimes.getDefaultInstance()));
//编码用
p.addLast("frameEncoder", new ProtobufVarint32LengthFieldPrepender());
p.addLast("protobufEncoder", new ProtobufEncoder());
//业务逻辑用 这里如果再有一个LocalDateClientHandler的话应该怎么处理
p.addLast("handler", new LocalTimeClientHandler());
}
希望给出的方案不是
if (arg1 instanceof Localtime）{}
else if (arg1 instanceof LocalDate){}
.
.
.
因为实体太多！目前的想法时根据接收过来的arg1定义一个ID，根据ID调用相应的ProtobufDecoder;下面的Handler也一样。但是由于刚接触Netty不熟，所以特来求助。
查找方案中有看到一遍相似的文章：http://www.cnblogs.com/Solstice/archive/2011/04/03/2004458.html想法可能不成熟，希望各位踢教！
麻烦各位最好给出Demo或者有类似实现的开源项目地址的，多谢！
参考官方的例子：PortUnificationServerHandler
简单的说就是在每个包的第一个字符写一个特殊的char,通过这个字符来动态加载不同的handler，这样就可以在一个端口实现多个协议的解析。不过本人不建议这么做。
public class PortUnificationServerHandler extends ByteToMessageDecoder { private final SslContext sslCtx; private final boolean detectSsl; private final boolean detectGzip; public PortUnificationServerHandler(SslContext sslCtx) { this(sslCtx, true, true); } private PortUnificationServerHandler(SslContext sslCtx, boolean detectSsl, boolean detectGzip) { this.sslCtx = sslCtx; this.detectSsl = detectSsl; this.detectGzip = detectGzip; } @Override protected void decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) throws Exception { // Will use the first five bytes to detect a protocol. if (in.readableBytes() < 5) { return; } if (isSsl(in)) { enableSsl(ctx); } else { final int magic1 = in.getUnsignedByte(in.readerIndex()); final int magic2 = in.getUnsignedByte(in.readerIndex() + 1); if (isGzip(magic1, magic2)) { enableGzip(ctx); } else if (isHttp(magic1, magic2)) { switchToHttp(ctx); } else if (isFactorial(magic1)) { switchToFactorial(ctx); } else { // Unknown protocol; discard everything and close the connection. in.clear(); ctx.close(); } } } private boolean isSsl(ByteBuf buf) { if (detectSsl) { return SslHandler.isEncrypted(buf); } return false; } private boolean isGzip(int magic1, int magic2) { if (detectGzip) { return magic1 == 31 && magic2 == 139; } return false; } private static boolean isHttp(int magic1, int magic2) { return magic1 == 'G' && magic2 == 'E' || // GET magic1 == 'P' && magic2 == 'O' || // POST magic1 == 'P' && magic2 == 'U' || // PUT magic1 == 'H' && magic2 == 'E' || // HEAD magic1 == 'O' && magic2 == 'P' || // OPTIONS magic1 == 'P' && magic2 == 'A' || // PATCH magic1 == 'D' && magic2 == 'E' || // DELETE magic1 == 'T' && magic2 == 'R' || // TRACE magic1 == 'C' && magic2 == 'O'; // CONNECT } private static boolean isFactorial(int magic1) { return magic1 == 'F'; } private void enableSsl(ChannelHandlerContext ctx) { ChannelPipeline p = ctx.pipeline(); p.addLast("ssl", sslCtx.newHandler(ctx.alloc())); p.addLast("unificationA", new PortUnificationServerHandler(sslCtx, false, detectGzip)); p.remove(this); } private void enableGzip(ChannelHandlerContext ctx) { ChannelPipeline p = ctx.pipeline(); p.addLast("gzipdeflater", ZlibCodecFactory.newZlibEncoder(ZlibWrapper.GZIP)); p.addLast("gzipinflater", ZlibCodecFactory.newZlibDecoder(ZlibWrapper.GZIP)); p.addLast("unificationB", new PortUnificationServerHandler(sslCtx, detectSsl, false)); p.remove(this); } private void switchToHttp(ChannelHandlerContext ctx) { ChannelPipeline p = ctx.pipeline(); p.addLast("decoder", new HttpRequestDecoder()); p.addLast("encoder", new HttpResponseEncoder()); p.addLast("deflater", new HttpContentCompressor()); p.addLast("handler", new HttpSnoopServerHandler()); p.remove(this); } private void switchToFactorial(ChannelHandlerContext ctx) { ChannelPipeline p = ctx.pipeline(); p.addLast("decoder", new BigIntegerDecoder()); p.addLast("encoder", new NumberEncoder()); p.addLast("handler", new FactorialServerHandler()); p.remove(this); } }喜欢 点个赞 http://www.oschina.net/p/gameframe
二楼的项目Maven构建了半天失败了！
大概是问题太简单了，大家都不屑回答！求指点！
可能我把问题想复杂了
原问题中initChannel方法的第6行和第11行 //构造函数传递要解码成的类型 这里如果再有一个LocalDates的话应该怎么处理 6 p.addLast("protobufDecoder", new ProtobufDecoder(LocalTimeProtocol.LocalTimes.getDefaultInstance())); //业务逻辑用 这里如果再有一个LocalDateClientHandler的话应该怎么处理 11 p.addLast("handler", new LocalTimeClientHandler());这里第六行的处理我是想如果要在解码消息时选择相应的编码，就要继承重写一个
public class ProtobufCodecFactory extends ProtobufDecoder{ public ProtobufCodecFactory(MessageLite prototype) { super(prototype); } @Override public void channelRead(ChannelHandlerContext arg0, Object arg1) throws Exception { super.channelRead(arg0, arg1); if(arg1 instanceof GeneratedMessage){ //这里我不太清楚ID应该怎么取出来，每一个协议的第一个都是 int32 id=1 //取出来后返回的取出上述MessageLite中的是相应protobuf的实例吗？ } } }第11行中的Handler我也是同样的想法？
让大家见笑了，麻烦指教下。纠结了一周多了。谢谢！
多协议怎么处理？有案例么？谢谢！！！
protobuf 的oneof用过没？ 消息类型里面加个type字段，标识不同类型的子类型消息