[toc]

Google Protobuf在Netty中的使用

程序代码来自于《Netty权威指南》第8章，已经加了注释，不过需要注意的是，使用的proto源代码是在Google Protobuf入门与使用中生成的，关于protobuf代码自动生成工具的使用可以参考这篇文章。

例子中，通过解码器ProtobufVarint32FrameDecoder和编码器ProtobufVarint32LengthFieldPrepender的使用已经解决了半包问题，测试时可以把其注释掉，这样就可以演示Netty中使用Protobuf出现的TCP粘包问题。

同时，通过protobuf的使用，也可以深刻感受到，其在Netty中的使用确实非常简单，编解码、半包问题，只需要添加相关的处理器即可，而且它可以方便地实现跨语言的远程服务调用。（protobuf本身提供了对不同语言的支持）

但其实在使用时会发现有一个问题，就是编解码的对象是需要使用其生成的特定的proto对象来进行操作的，也就是说，需要编写.proto文件，再通过protoc来生成相应语言的代码文件，显然这样做还是会有些麻烦（虽然其实也还好，不算麻烦），有没有方便点的方法呢？后面通过protostuff的使用即可解决这个问题。

服务端

SubReqServer.java

package cn.xpleaf.subscribe;import cn.xpleaf.protobuf.SubscribeReqProto;import io.netty.bootstrap.ServerBootstrap;import io.netty.channel.ChannelFuture;import io.netty.channel.ChannelInitializer;import io.netty.channel.ChannelOption;import io.netty.channel.EventLoopGroup;import io.netty.channel.nio.NioEventLoopGroup;import io.netty.channel.socket.SocketChannel;import io.netty.channel.socket.nio.NioServerSocketChannel;import io.netty.handler.codec.protobuf.ProtobufDecoder;import io.netty.handler.codec.protobuf.ProtobufEncoder;import io.netty.handler.codec.protobuf.ProtobufVarint32FrameDecoder;import io.netty.handler.codec.protobuf.ProtobufVarint32LengthFieldPrepender;import io.netty.handler.logging.LogLevel;import io.netty.handler.logging.LoggingHandler;public class SubReqServer {    public void bind(int port) throws Exception {        // 配置服务端的NIO线程组        EventLoopGroup bossGroup = new NioEventLoopGroup();        EventLoopGroup workerGroup = new NioEventLoopGroup();        try {            ServerBootstrap b = new ServerBootstrap();            b.group(bossGroup, workerGroup)                .channel(NioServerSocketChannel.class)                .option(ChannelOption.SO_BACKLOG, 1024)                // 添加日志处理器                .handler(new LoggingHandler(LogLevel.INFO))                .childHandler(new ChannelInitializer<SocketChannel>() {                    @Override                    protected void initChannel(SocketChannel ch) throws Exception {                        // 添加ProtobufVarint32FrameDecoder，主要用于Protobuf的半包处理                        ch.pipeline().addLast(new ProtobufVarint32FrameDecoder());                        // 添加ProtobufDecoder解码器，它的参数是com.google.protobuf.MessageLite                        // 实际上就是要告诉ProtobufDecoder需要解码的目标类是什么，否则仅仅从字节数组中是                        // 无法判断出要解码的目标类型信息的（服务端需要解析的是客户端请求，所以是Req）                        ch.pipeline().addLast(new ProtobufDecoder(SubscribeReqProto.SubscribeReq.getDefaultInstance()));                        /**                         * 来自源码的代码注释，用于Protobuf的半包处理                         * * An encoder that prepends the the Google Protocol Buffers                         * <a ]