Netty（五）序列化protobuf在netty中的使用

protobuf是google序列化的工具，主要是把數據序列化成二進制的數據來傳輸用的。它主要優點如下：

1.性能好，效率高；

2.跨語言（java自帶的序列化，不能跨語言）

protobuf參考文檔：Protobuf詳解

 其實，在netty中使用Protobuf需要注意的是：

 protobufDecoder僅僅負責編碼，並不支持讀半包，所以在之前，一定要有讀半包的處理器。

 有三種方式可以選擇：

1. 使用netty提供ProtobufVarint32FrameDecoder
2. 繼承netty提供的通用半包處理器 LengthFieldBasedFrameDecoder
3. 繼承ByteToMessageDecoder類，自己處理半包

Server源碼部分：

        try {
            // ServerBootstrap 類，是啟動NIO服務器的輔助啟動類
            ServerBootstrap b = new ServerBootstrap();
            b.group(bossGroup,WorkerGroup)
                    .channel(NioServerSocketChannel.class)
                    .option(ChannelOption.SO_BACKLOG,1024)
                    .childHandler(new ChannelInitializer<SocketChannel>() {
                        @Override
                        public void initChannel(SocketChannel ch){
                            // protobufDecoder僅僅負責編碼，並不支持讀半包，所以在之前，一定要有讀半包的處理器。
                            // 有三種方式可以選擇：
                            // 使用netty提供ProtobufVarint32FrameDecoder
                            // 繼承netty提供的通用半包處理器 LengthFieldBasedFrameDecoder
                            // 繼承ByteToMessageDecoder類，自己處理半包

                            // 半包的處理
                            ch.pipeline().addLast(new ProtobufVarint32FrameDecoder());
                            // 需要解碼的目標類
                            ch.pipeline().addLast(new ProtobufDecoder(PersonProbuf.Person.getDefaultInstance()));

                            ch.pipeline().addLast(new ProtobufVarint32LengthFieldPrepender());

                            ch.pipeline().addLast(new ProtobufEncoder());

                            ch.pipeline().addLast(new ReqServerHandler());
                        }
                    });

            // 綁定端口,同步等待成功
            ChannelFuture f= b.bind(port).sync();

            // 等待服務端監聽端口關閉
            f.channel().closeFuture().sync();
        }finally {
            // 釋放線程池資源
            bossGroup.shutdownGracefully();
            WorkerGroup.shutdownGracefully();
        }

 

client源碼部分:

try {
            // Bootstrap 類，是啟動NIO服務器的輔助啟動類
            Bootstrap b = new Bootstrap();
            b.group(group).channel(NioSocketChannel.class)
                    .option(ChannelOption.TCP_NODELAY,true)
                    .handler(new ChannelInitializer<SocketChannel>() {
                        @Override
                        public void initChannel(SocketChannel ch)
                                throws Exception{
                            //
                            ch.pipeline().addLast(new ProtobufVarint32FrameDecoder());

                            ch.pipeline().addLast(new ProtobufDecoder(PersonProbuf.Person.getDefaultInstance()));
                            ch.pipeline().addLast(new ProtobufVarint32LengthFieldPrepender());
                            ch.pipeline().addLast(new ProtobufEncoder());
                            ch.pipeline().addLast(new ReqClientHandler());

                        }
                    });

            // 發起異步連接操作
            ChannelFuture f= b.connect(host,port).sync();

            // 等待客服端鏈路關閉
            f.channel().closeFuture().sync();
        }finally {
            group.shutdownGracefully();
        }

 

源碼下載

源碼在src/main/java/Serialization_ProtoBuf下，分為客戶端和服務端，他們的代碼基本和Netty入門章節的代碼類似，只是增加了Protobuf相關的解碼器使用。ProtoBuf文件下，是相關的protobuf的windows下的代碼生成器.

GitHub地址：https://github.com/orange1438/Netty_Course

 

 

作者：orange1438
出處：http://www.cnblogs.com/orange1438/
本文版權歸作者和博客園共有，歡迎轉載，但未經作者同意必須保留此段聲明，且在文章頁面明顯位置給出原文連接，否則保留追究法律責任的權利。