Netty编解码（Protobuf实现）

浅浅的花香味﹌ 2022-05-13 14:56 239阅读 0赞

## Java序列化的缺点 ##

Java序列化从JDK1.1版本就已经提供了，它不需要添加额外类库，只需要实现java.io.Serializable并生成序列ID即可。但是在远程服务调用（RPC）时，很少直接使用Java序列化进行消息的编解码和传输，原因有一下几点：

**1.无法跨语言**

*最致命的原因：由于Java序列化技术是Java内部的私有协议，其他语言并不支持，所以相对于用户来说它完全是黑盒。而RPC往往都需要支持跨语言调用。*

**2.序列化后的码流太大**

**3.序列化性能过低**

![70][]

## 使用Protobuf做编解码： ##

首先下载protobuf

下载地址：[https://github.com/google/protobuf/releases][https_github.com_google_protobuf_releases]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3NTk4MDEx_size_27_color_FFFFFF_t_70][]

将exe文件放入C:\\Windows\\System32

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3NTk4MDEx_size_27_color_FFFFFF_t_70 1][]

创建SubscribeReq.proto文件

syntax="proto3";
    option java_package = "com.netty.protobuf";
    option java_outer_classname = "SubscribeReqProto";
    
    message SubscribeReq {
    int32 subReqId = 1;
    string userName = 2;
    string productName = 3;
    repeated string address = 4;
    }

创建SubscribeResp.proto文件

syntax="proto2";
    option java_package="com.netty.protobuf";
    option java_outer_classname="SubscribeRespProto";
     
    message SubscribeResp{
    		required int32 subReqId = 1;
    		required int32 respCode = 2;
    		required string desc = 3;		
    }

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3NTk4MDEx_size_27_color_FFFFFF_t_70 2][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3NTk4MDEx_size_27_color_FFFFFF_t_70 3][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3NTk4MDEx_size_27_color_FFFFFF_t_70 4][]

此时它会报错需要引入jar包

<dependency>
                <groupId>com.google.protobuf</groupId>
                <artifactId>protobuf-java</artifactId>
                <version>3.5.1</version>
            </dependency>

进行测试类：

import java.util.ArrayList;
    import java.util.List;
    
    public class TestSubscribeReq {
        public static void main(String[] args)throws Exception{
            SubscribeReqProto.SubscribeReq req=createSubscribeReq();
            System.out.println("Before encode:"+req.toString());
    
            SubscribeReqProto.SubscribeReq result=decode(encode(req));
            System.out.println("decode cotent is:"+result.toString());
    
            System.out.println(req.equals(result));
        }
        private static byte[] encode(SubscribeReqProto.SubscribeReq req){
            return req.toByteArray();
        }
        private static  SubscribeReqProto.SubscribeReq decode(byte[] body) throws Exception{
            return SubscribeReqProto.SubscribeReq.parseFrom(body);
        }
    
        private static SubscribeReqProto.SubscribeReq createSubscribeReq(){
            SubscribeReqProto.SubscribeReq.Builder builder= SubscribeReqProto.SubscribeReq.newBuilder();
            builder.setSubReqId(1);
            builder.setUserName("zzf");
            builder.setProductName("Netty Book");
            List<String> address=new ArrayList<String>();
            address.add("浙江");
            address.add("超人");
            address.add("乌龟");
            builder.addAllAddress(address);
            return builder.build();
    
        }
    }

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3NTk4MDEx_size_27_color_FFFFFF_t_70 5][]

首先我们看如何创建SubscribeReqProto.SubscribeReq的实例，通过SubscribeReqProto.SubscribeReq的静态方法newBuilder创建SubscribeReqProto.SubscribeReq的Builder实例,通过Builder构造器对SubscribeReq的属性进行相关设置，对于集合类型，通过addAllXXX()方法可以将集合对象添加到对象属性当中。

编码通过调用SubscribeReqProto.SubscribeReq实例的toByteArray方法，即可将SubscribeReq对象编码为byte数组。

解码通过调用SubscribeReqProto.SubscribeReq的静态方法parseFrom将二进制数组解码为原始数据对象。

## Netty的Protobuf服务端开发 ##

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 SubRespProServer {
        public static void main(String[] args)throws  Exception{
            int port=15444;
            new SubRespProServer().bind(port);
    
        }
    
        public void bind(int port)throws Exception{
            //配置服务端的NIO线程池
            EventLoopGroup bossGroup=new NioEventLoopGroup();
            EventLoopGroup workGroup=new NioEventLoopGroup();
            try{
                ServerBootstrap b=new ServerBootstrap();
                b.group(bossGroup, workGroup);
                b.channel(NioServerSocketChannel.class);
                b.option(ChannelOption.SO_BACKLOG, 100);
                b.handler(new LoggingHandler(LogLevel.INFO));
                b.childHandler(new ChannelInitializer<SocketChannel>() {
                    @Override
                    protected void initChannel(SocketChannel socketChannel) throws Exception {
                        socketChannel.pipeline().addLast(new ProtobufVarint32FrameDecoder());
                        socketChannel.pipeline().addLast(new ProtobufDecoder(SubscribeReqProto.SubscribeReq.getDefaultInstance()));
                        socketChannel.pipeline().addLast(new ProtobufVarint32LengthFieldPrepender());
                        socketChannel.pipeline().addLast(new ProtobufEncoder());
                        socketChannel.pipeline().addLast(new SubRespProHandler());
    
                    }
                });
                //绑定端口，等待同步成功
                ChannelFuture f=b.bind(port).sync();
                //等待服务端关闭监听端口
                f.channel().closeFuture().sync();
    
            }finally {
                //释放线程池资源
                bossGroup.shutdownGracefully();
                workGroup.shutdownGracefully();
    
            }
        }
    }

首先向ChannelPipeline添加ProtobufVarint32FrameDecoder，它主要用于半包处理，随后继续添加ProtobufDecoder解码器，它的参数是是需要解码的目标类：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3NTk4MDEx_size_27_color_FFFFFF_t_70 6][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3NTk4MDEx_size_27_color_FFFFFF_t_70 7][]

SubReqServerHandler实现：

import io.netty.channel.ChannelHandlerContext;
    import io.netty.channel.ChannelInboundHandlerAdapter;
    
    
    public class SubRespProHandler extends ChannelInboundHandlerAdapter {
    
        @Override
        public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
            ctx.close();
        }
    
        @Override
        public void channelActive(ChannelHandlerContext ctx) throws Exception {
            super.channelActive(ctx);
        }
    
        @Override
        public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
            SubscribeReqProto.SubscribeReq req=(SubscribeReqProto.SubscribeReq)msg;
            System.out.println("服务器接收客户端消息是:"+req.toString());
            ctx.writeAndFlush(resp(req.getSubReqId()));
        }
    
        private SubscribeRespProto.SubscribeResp resp(int subReqId)throws Exception{
            SubscribeRespProto.SubscribeResp.Builder resp= SubscribeRespProto.SubscribeResp.newBuilder();
            resp.setSubReqId(subReqId);
            resp.setRespCode(0);
            resp.setDesc("aaa,网上预定成功3天后，发送到指定的地址");
            return resp.build();
        }
    
        @Override
        public void channelReadComplete(ChannelHandlerContext ctx) throws Exception {
            super.channelReadComplete(ctx);
        }
    }

客户端

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.NioSocketChannel;
    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;
    
    /**
     * 客户端
     */
    public class SubReqProClient {
        public static void main(String[] args)throws Exception{
            int port=15444;
            new SubReqProClient().bind(port, "127.0.0.1");
        }
    
        public void bind(int port,String host)throws Exception{
            //配置客户端NIO线程池
            EventLoopGroup workGroup=new NioEventLoopGroup();
            try{
                io.netty.bootstrap.Bootstrap b=new io.netty.bootstrap.Bootstrap();
                b.group(workGroup);
                b.channel(NioSocketChannel.class);
                b.option(ChannelOption.TCP_NODELAY,true);
                b.handler(new ChannelInitializer<SocketChannel>() {
                    @Override
                    protected void initChannel(SocketChannel socketChannel) throws Exception {
                        socketChannel.pipeline().addLast(new ProtobufVarint32FrameDecoder());
                        socketChannel.pipeline().addLast(new ProtobufDecoder(SubscribeRespProto.SubscribeResp.getDefaultInstance()));
                        socketChannel.pipeline().addLast(new ProtobufVarint32LengthFieldPrepender());
                        socketChannel.pipeline().addLast(new ProtobufEncoder());
                        socketChannel.pipeline().addLast(new SubReqProHandler());
                    }
                });
                //发起异步连接操作
                ChannelFuture f=b.connect(host,port).sync();
                //等待客户端链路关闭
                f.channel().closeFuture().sync();
    
            }finally {
                //释放NIO 线程组
                workGroup.shutdownGracefully();
    
            }
        }
    }

SubReqClientHandler实现类：

import io.netty.channel.ChannelHandlerContext;
    import io.netty.channel.ChannelInboundHandlerAdapter;
    
    import java.util.ArrayList;
    import java.util.List;
    
    
    public class SubReqProHandler extends ChannelInboundHandlerAdapter {
        @Override
        public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
            ctx.close();
        }
    
        @Override
        public void channelActive(ChannelHandlerContext ctx) throws Exception {
            for(int i=0;i<10;i++){
                ctx.write(subReq(i));
            }
            ctx.flush();
        }
        private SubscribeReqProto.SubscribeReq subReq(int i){
            SubscribeReqProto.SubscribeReq.Builder req=SubscribeReqProto.SubscribeReq.newBuilder();
            req.setProductName("Netty Book");
            req.setUserName("啥啥啥");
            req.setSubReqId(i);
            List<String> address=new ArrayList<String>();
            address.add("aaaaaaaaaaaaaaaaaaa");
            address.add("bbbbbbbbbbbbbbbbbbb");
            address.add("ccccccccccccccccccc");
            req.addAllAddress(address);
            return req.build();
        }
    
        @Override
        public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
            System.out.println("接收服务器消息是:"+msg);
        }
    
        @Override
        public void channelReadComplete(ChannelHandlerContext ctx) throws Exception {
            ctx.flush();
        }
    }

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3NTk4MDEx_size_27_color_FFFFFF_t_70 8][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3NTk4MDEx_size_27_color_FFFFFF_t_70 9][]

### Protobuf的使用注意事项 ###

ProtobufDecoder仅仅负责解码，它不支持半包。影戏在protobufDecoder前面一定要有处理读半包的解码器：

1.使用Netty提供的ProtobufVarint32FrameDecoder，他可以处理半包消息。

2.继承Netty提供的通用半包解码器LengthFieldBasedFrameDecoder。

3.继承ByteToMessageDecoder类处理半包消息。

附件：

// Generated by the protocol buffer compiler.  DO NOT EDIT!
    // source: SubscribeResp.proto
    
    package com.netty.protobuf;
    
    public final class SubscribeRespProto {
      private SubscribeRespProto() {}
      public static void registerAllExtensions(
          com.google.protobuf.ExtensionRegistryLite registry) {
      }
    
      public static void registerAllExtensions(
          com.google.protobuf.ExtensionRegistry registry) {
        registerAllExtensions(
            (com.google.protobuf.ExtensionRegistryLite) registry);
      }
      public interface SubscribeRespOrBuilder extends
          // @@protoc_insertion_point(interface_extends:SubscribeResp)
          com.google.protobuf.MessageOrBuilder {
    
        /**
         * <code>required int32 subReqId = 1;</code>
         */
        boolean hasSubReqId();
        /**
         * <code>required int32 subReqId = 1;</code>
         */
        int getSubReqId();
    
        /**
         * <code>required int32 respCode = 2;</code>
         */
        boolean hasRespCode();
        /**
         * <code>required int32 respCode = 2;</code>
         */
        int getRespCode();
    
        /**
         * <code>required string desc = 3;</code>
         */
        boolean hasDesc();
        /**
         * <code>required string desc = 3;</code>
         */
        String getDesc();
        /**
         * <code>required string desc = 3;</code>
         */
        com.google.protobuf.ByteString
            getDescBytes();
      }
      /**
       * Protobuf type {@code SubscribeResp}
       */
      public  static final class SubscribeResp extends
          com.google.protobuf.GeneratedMessageV3 implements
          // @@protoc_insertion_point(message_implements:SubscribeResp)
          SubscribeRespOrBuilder {
      private static final long serialVersionUID = 0L;
        // Use SubscribeResp.newBuilder() to construct.
        private SubscribeResp(com.google.protobuf.GeneratedMessageV3.Builder<?> builder) {
          super(builder);
        }
        private SubscribeResp() {
          subReqId_ = 0;
          respCode_ = 0;
          desc_ = "";
        }
    
        @Override
        public final com.google.protobuf.UnknownFieldSet
        getUnknownFields() {
          return this.unknownFields;
        }
        private SubscribeResp(
            com.google.protobuf.CodedInputStream input,
            com.google.protobuf.ExtensionRegistryLite extensionRegistry)
            throws com.google.protobuf.InvalidProtocolBufferException {
          this();
          if (extensionRegistry == null) {
            throw new NullPointerException();
          }
          int mutable_bitField0_ = 0;
          com.google.protobuf.UnknownFieldSet.Builder unknownFields =
              com.google.protobuf.UnknownFieldSet.newBuilder();
          try {
            boolean done = false;
            while (!done) {
              int tag = input.readTag();
              switch (tag) {
                case 0:
                  done = true;
                  break;
                case 8: {
                  bitField0_ |= 0x00000001;
                  subReqId_ = input.readInt32();
                  break;
                }
                case 16: {
                  bitField0_ |= 0x00000002;
                  respCode_ = input.readInt32();
                  break;
                }
                case 26: {
                  com.google.protobuf.ByteString bs = input.readBytes();
                  bitField0_ |= 0x00000004;
                  desc_ = bs;
                  break;
                }
                default: {
                  if (!parseUnknownField(
                      input, unknownFields, extensionRegistry, tag)) {
                    done = true;
                  }
                  break;
                }
              }
            }
          } catch (com.google.protobuf.InvalidProtocolBufferException e) {
            throw e.setUnfinishedMessage(this);
          } catch (java.io.IOException e) {
            throw new com.google.protobuf.InvalidProtocolBufferException(
                e).setUnfinishedMessage(this);
          } finally {
            this.unknownFields = unknownFields.build();
            makeExtensionsImmutable();
          }
        }
        public static final com.google.protobuf.Descriptors.Descriptor
            getDescriptor() {
          return SubscribeRespProto.internal_static_SubscribeResp_descriptor;
        }
    
        @Override
        protected FieldAccessorTable
            internalGetFieldAccessorTable() {
          return SubscribeRespProto.internal_static_SubscribeResp_fieldAccessorTable
              .ensureFieldAccessorsInitialized(
                  SubscribeResp.class, Builder.class);
        }
    
        private int bitField0_;
        public static final int SUBREQID_FIELD_NUMBER = 1;
        private int subReqId_;
        /**
         * <code>required int32 subReqId = 1;</code>
         */
        public boolean hasSubReqId() {
          return ((bitField0_ & 0x00000001) == 0x00000001);
        }
        /**
         * <code>required int32 subReqId = 1;</code>
         */
        public int getSubReqId() {
          return subReqId_;
        }
    
        public static final int RESPCODE_FIELD_NUMBER = 2;
        private int respCode_;
        /**
         * <code>required int32 respCode = 2;</code>
         */
        public boolean hasRespCode() {
          return ((bitField0_ & 0x00000002) == 0x00000002);
        }
        /**
         * <code>required int32 respCode = 2;</code>
         */
        public int getRespCode() {
          return respCode_;
        }
    
        public static final int DESC_FIELD_NUMBER = 3;
        private volatile Object desc_;
        /**
         * <code>required string desc = 3;</code>
         */
        public boolean hasDesc() {
          return ((bitField0_ & 0x00000004) == 0x00000004);
        }
        /**
         * <code>required string desc = 3;</code>
         */
        public String getDesc() {
          Object ref = desc_;
          if (ref instanceof String) {
            return (String) ref;
          } else {
            com.google.protobuf.ByteString bs = 
                (com.google.protobuf.ByteString) ref;
            String s = bs.toStringUtf8();
            if (bs.isValidUtf8()) {
              desc_ = s;
            }
            return s;
          }
        }
        /**
         * <code>required string desc = 3;</code>
         */
        public com.google.protobuf.ByteString
            getDescBytes() {
          Object ref = desc_;
          if (ref instanceof String) {
            com.google.protobuf.ByteString b = 
                com.google.protobuf.ByteString.copyFromUtf8(
                    (String) ref);
            desc_ = b;
            return b;
          } else {
            return (com.google.protobuf.ByteString) ref;
          }
        }
    
        private byte memoizedIsInitialized = -1;
        @Override
        public final boolean isInitialized() {
          byte isInitialized = memoizedIsInitialized;
          if (isInitialized == 1) return true;
          if (isInitialized == 0) return false;
    
          if (!hasSubReqId()) {
            memoizedIsInitialized = 0;
            return false;
          }
          if (!hasRespCode()) {
            memoizedIsInitialized = 0;
            return false;
          }
          if (!hasDesc()) {
            memoizedIsInitialized = 0;
            return false;
          }
          memoizedIsInitialized = 1;
          return true;
        }
    
        @Override
        public void writeTo(com.google.protobuf.CodedOutputStream output)
                            throws java.io.IOException {
          if (((bitField0_ & 0x00000001) == 0x00000001)) {
            output.writeInt32(1, subReqId_);
          }
          if (((bitField0_ & 0x00000002) == 0x00000002)) {
            output.writeInt32(2, respCode_);
          }
          if (((bitField0_ & 0x00000004) == 0x00000004)) {
            com.google.protobuf.GeneratedMessageV3.writeString(output, 3, desc_);
          }
          unknownFields.writeTo(output);
        }
    
        @Override
        public int getSerializedSize() {
          int size = memoizedSize;
          if (size != -1) return size;
    
          size = 0;
          if (((bitField0_ & 0x00000001) == 0x00000001)) {
            size += com.google.protobuf.CodedOutputStream
              .computeInt32Size(1, subReqId_);
          }
          if (((bitField0_ & 0x00000002) == 0x00000002)) {
            size += com.google.protobuf.CodedOutputStream
              .computeInt32Size(2, respCode_);
          }
          if (((bitField0_ & 0x00000004) == 0x00000004)) {
            size += com.google.protobuf.GeneratedMessageV3.computeStringSize(3, desc_);
          }
          size += unknownFields.getSerializedSize();
          memoizedSize = size;
          return size;
        }
    
        @Override
        public boolean equals(final Object obj) {
          if (obj == this) {
           return true;
          }
          if (!(obj instanceof SubscribeResp)) {
            return super.equals(obj);
          }
          SubscribeResp other = (SubscribeResp) obj;
    
          boolean result = true;
          result = result && (hasSubReqId() == other.hasSubReqId());
          if (hasSubReqId()) {
            result = result && (getSubReqId()
                == other.getSubReqId());
          }
          result = result && (hasRespCode() == other.hasRespCode());
          if (hasRespCode()) {
            result = result && (getRespCode()
                == other.getRespCode());
          }
          result = result && (hasDesc() == other.hasDesc());
          if (hasDesc()) {
            result = result && getDesc()
                .equals(other.getDesc());
          }
          result = result && unknownFields.equals(other.unknownFields);
          return result;
        }
    
        @Override
        public int hashCode() {
          if (memoizedHashCode != 0) {
            return memoizedHashCode;
          }
          int hash = 41;
          hash = (19 * hash) + getDescriptor().hashCode();
          if (hasSubReqId()) {
            hash = (37 * hash) + SUBREQID_FIELD_NUMBER;
            hash = (53 * hash) + getSubReqId();
          }
          if (hasRespCode()) {
            hash = (37 * hash) + RESPCODE_FIELD_NUMBER;
            hash = (53 * hash) + getRespCode();
          }
          if (hasDesc()) {
            hash = (37 * hash) + DESC_FIELD_NUMBER;
            hash = (53 * hash) + getDesc().hashCode();
          }
          hash = (29 * hash) + unknownFields.hashCode();
          memoizedHashCode = hash;
          return hash;
        }
    
        public static SubscribeResp parseFrom(
            java.nio.ByteBuffer data)
            throws com.google.protobuf.InvalidProtocolBufferException {
          return PARSER.parseFrom(data);
        }
        public static SubscribeResp parseFrom(
            java.nio.ByteBuffer data,
            com.google.protobuf.ExtensionRegistryLite extensionRegistry)
            throws com.google.protobuf.InvalidProtocolBufferException {
          return PARSER.parseFrom(data, extensionRegistry);
        }
        public static SubscribeResp parseFrom(
            com.google.protobuf.ByteString data)
            throws com.google.protobuf.InvalidProtocolBufferException {
          return PARSER.parseFrom(data);
        }
        public static SubscribeResp parseFrom(
            com.google.protobuf.ByteString data,
            com.google.protobuf.ExtensionRegistryLite extensionRegistry)
            throws com.google.protobuf.InvalidProtocolBufferException {
          return PARSER.parseFrom(data, extensionRegistry);
        }
        public static SubscribeResp parseFrom(byte[] data)
            throws com.google.protobuf.InvalidProtocolBufferException {
          return PARSER.parseFrom(data);
        }
        public static SubscribeResp parseFrom(
            byte[] data,
            com.google.protobuf.ExtensionRegistryLite extensionRegistry)
            throws com.google.protobuf.InvalidProtocolBufferException {
          return PARSER.parseFrom(data, extensionRegistry);
        }
        public static SubscribeResp parseFrom(java.io.InputStream input)
            throws java.io.IOException {
          return com.google.protobuf.GeneratedMessageV3
              .parseWithIOException(PARSER, input);
        }
        public static SubscribeResp parseFrom(
            java.io.InputStream input,
            com.google.protobuf.ExtensionRegistryLite extensionRegistry)
            throws java.io.IOException {
          return com.google.protobuf.GeneratedMessageV3
              .parseWithIOException(PARSER, input, extensionRegistry);
        }
        public static SubscribeResp parseDelimitedFrom(java.io.InputStream input)
            throws java.io.IOException {
          return com.google.protobuf.GeneratedMessageV3
              .parseDelimitedWithIOException(PARSER, input);
        }
        public static SubscribeResp parseDelimitedFrom(
            java.io.InputStream input,
            com.google.protobuf.ExtensionRegistryLite extensionRegistry)
            throws java.io.IOException {
          return com.google.protobuf.GeneratedMessageV3
              .parseDelimitedWithIOException(PARSER, input, extensionRegistry);
        }
        public static SubscribeResp parseFrom(
            com.google.protobuf.CodedInputStream input)
            throws java.io.IOException {
          return com.google.protobuf.GeneratedMessageV3
              .parseWithIOException(PARSER, input);
        }
        public static SubscribeResp parseFrom(
            com.google.protobuf.CodedInputStream input,
            com.google.protobuf.ExtensionRegistryLite extensionRegistry)
            throws java.io.IOException {
          return com.google.protobuf.GeneratedMessageV3
              .parseWithIOException(PARSER, input, extensionRegistry);
        }
    
        @Override
        public Builder newBuilderForType() { return newBuilder(); }
        public static Builder newBuilder() {
          return DEFAULT_INSTANCE.toBuilder();
        }
        public static Builder newBuilder(SubscribeResp prototype) {
          return DEFAULT_INSTANCE.toBuilder().mergeFrom(prototype);
        }
        @Override
        public Builder toBuilder() {
          return this == DEFAULT_INSTANCE
              ? new Builder() : new Builder().mergeFrom(this);
        }
    
        @Override
        protected Builder newBuilderForType(
            BuilderParent parent) {
          Builder builder = new Builder(parent);
          return builder;
        }
        /**
         * Protobuf type {@code SubscribeResp}
         */
        public static final class Builder extends
            com.google.protobuf.GeneratedMessageV3.Builder<Builder> implements
            // @@protoc_insertion_point(builder_implements:SubscribeResp)
            SubscribeRespOrBuilder {
          public static final com.google.protobuf.Descriptors.Descriptor
              getDescriptor() {
            return SubscribeRespProto.internal_static_SubscribeResp_descriptor;
          }
    
          @Override
          protected FieldAccessorTable
              internalGetFieldAccessorTable() {
            return SubscribeRespProto.internal_static_SubscribeResp_fieldAccessorTable
                .ensureFieldAccessorsInitialized(
                    SubscribeResp.class, Builder.class);
          }
    
          // Construct using com.netty.protobuf.SubscribeRespProto.SubscribeResp.newBuilder()
          private Builder() {
            maybeForceBuilderInitialization();
          }
    
          private Builder(
              BuilderParent parent) {
            super(parent);
            maybeForceBuilderInitialization();
          }
          private void maybeForceBuilderInitialization() {
            if (com.google.protobuf.GeneratedMessageV3
                    .alwaysUseFieldBuilders) {
            }
          }
          @Override
          public Builder clear() {
            super.clear();
            subReqId_ = 0;
            bitField0_ = (bitField0_ & ~0x00000001);
            respCode_ = 0;
            bitField0_ = (bitField0_ & ~0x00000002);
            desc_ = "";
            bitField0_ = (bitField0_ & ~0x00000004);
            return this;
          }
    
          @Override
          public com.google.protobuf.Descriptors.Descriptor
              getDescriptorForType() {
            return SubscribeRespProto.internal_static_SubscribeResp_descriptor;
          }
    
          @Override
          public SubscribeResp getDefaultInstanceForType() {
            return SubscribeResp.getDefaultInstance();
          }
    
          @Override
          public SubscribeResp build() {
            SubscribeResp result = buildPartial();
            if (!result.isInitialized()) {
              throw newUninitializedMessageException(result);
            }
            return result;
          }
    
          @Override
          public SubscribeResp buildPartial() {
            SubscribeResp result = new SubscribeResp(this);
            int from_bitField0_ = bitField0_;
            int to_bitField0_ = 0;
            if (((from_bitField0_ & 0x00000001) == 0x00000001)) {
              to_bitField0_ |= 0x00000001;
            }
            result.subReqId_ = subReqId_;
            if (((from_bitField0_ & 0x00000002) == 0x00000002)) {
              to_bitField0_ |= 0x00000002;
            }
            result.respCode_ = respCode_;
            if (((from_bitField0_ & 0x00000004) == 0x00000004)) {
              to_bitField0_ |= 0x00000004;
            }
            result.desc_ = desc_;
            result.bitField0_ = to_bitField0_;
            onBuilt();
            return result;
          }
    
          @Override
          public Builder clone() {
            return (Builder) super.clone();
          }
          @Override
          public Builder setField(
              com.google.protobuf.Descriptors.FieldDescriptor field,
              Object value) {
            return (Builder) super.setField(field, value);
          }
          @Override
          public Builder clearField(
              com.google.protobuf.Descriptors.FieldDescriptor field) {
            return (Builder) super.clearField(field);
          }
          @Override
          public Builder clearOneof(
              com.google.protobuf.Descriptors.OneofDescriptor oneof) {
            return (Builder) super.clearOneof(oneof);
          }
          @Override
          public Builder setRepeatedField(
              com.google.protobuf.Descriptors.FieldDescriptor field,
              int index, Object value) {
            return (Builder) super.setRepeatedField(field, index, value);
          }
          @Override
          public Builder addRepeatedField(
              com.google.protobuf.Descriptors.FieldDescriptor field,
              Object value) {
            return (Builder) super.addRepeatedField(field, value);
          }
          @Override
          public Builder mergeFrom(com.google.protobuf.Message other) {
            if (other instanceof SubscribeResp) {
              return mergeFrom((SubscribeResp)other);
            } else {
              super.mergeFrom(other);
              return this;
            }
          }
    
          public Builder mergeFrom(SubscribeResp other) {
            if (other == SubscribeResp.getDefaultInstance()) return this;
            if (other.hasSubReqId()) {
              setSubReqId(other.getSubReqId());
            }
            if (other.hasRespCode()) {
              setRespCode(other.getRespCode());
            }
            if (other.hasDesc()) {
              bitField0_ |= 0x00000004;
              desc_ = other.desc_;
              onChanged();
            }
            this.mergeUnknownFields(other.unknownFields);
            onChanged();
            return this;
          }
    
          @Override
          public final boolean isInitialized() {
            if (!hasSubReqId()) {
              return false;
            }
            if (!hasRespCode()) {
              return false;
            }
            if (!hasDesc()) {
              return false;
            }
            return true;
          }
    
          @Override
          public Builder mergeFrom(
              com.google.protobuf.CodedInputStream input,
              com.google.protobuf.ExtensionRegistryLite extensionRegistry)
              throws java.io.IOException {
            SubscribeResp parsedMessage = null;
            try {
              parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry);
            } catch (com.google.protobuf.InvalidProtocolBufferException e) {
              parsedMessage = (SubscribeResp) e.getUnfinishedMessage();
              throw e.unwrapIOException();
            } finally {
              if (parsedMessage != null) {
                mergeFrom(parsedMessage);
              }
            }
            return this;
          }
          private int bitField0_;
    
          private int subReqId_ ;
          /**
           * <code>required int32 subReqId = 1;</code>
           */
          public boolean hasSubReqId() {
            return ((bitField0_ & 0x00000001) == 0x00000001);
          }
          /**
           * <code>required int32 subReqId = 1;</code>
           */
          public int getSubReqId() {
            return subReqId_;
          }
          /**
           * <code>required int32 subReqId = 1;</code>
           */
          public Builder setSubReqId(int value) {
            bitField0_ |= 0x00000001;
            subReqId_ = value;
            onChanged();
            return this;
          }
          /**
           * <code>required int32 subReqId = 1;</code>
           */
          public Builder clearSubReqId() {
            bitField0_ = (bitField0_ & ~0x00000001);
            subReqId_ = 0;
            onChanged();
            return this;
          }
    
          private int respCode_ ;
          /**
           * <code>required int32 respCode = 2;</code>
           */
          public boolean hasRespCode() {
            return ((bitField0_ & 0x00000002) == 0x00000002);
          }
          /**
           * <code>required int32 respCode = 2;</code>
           */
          public int getRespCode() {
            return respCode_;
          }
          /**
           * <code>required int32 respCode = 2;</code>
           */
          public Builder setRespCode(int value) {
            bitField0_ |= 0x00000002;
            respCode_ = value;
            onChanged();
            return this;
          }
          /**
           * <code>required int32 respCode = 2;</code>
           */
          public Builder clearRespCode() {
            bitField0_ = (bitField0_ & ~0x00000002);
            respCode_ = 0;
            onChanged();
            return this;
          }
    
          private Object desc_ = "";
          /**
           * <code>required string desc = 3;</code>
           */
          public boolean hasDesc() {
            return ((bitField0_ & 0x00000004) == 0x00000004);
          }
          /**
           * <code>required string desc = 3;</code>
           */
          public String getDesc() {
            Object ref = desc_;
            if (!(ref instanceof String)) {
              com.google.protobuf.ByteString bs =
                  (com.google.protobuf.ByteString) ref;
              String s = bs.toStringUtf8();
              if (bs.isValidUtf8()) {
                desc_ = s;
              }
              return s;
            } else {
              return (String) ref;
            }
          }
          /**
           * <code>required string desc = 3;</code>
           */
          public com.google.protobuf.ByteString
              getDescBytes() {
            Object ref = desc_;
            if (ref instanceof String) {
              com.google.protobuf.ByteString b = 
                  com.google.protobuf.ByteString.copyFromUtf8(
                      (String) ref);
              desc_ = b;
              return b;
            } else {
              return (com.google.protobuf.ByteString) ref;
            }
          }
          /**
           * <code>required string desc = 3;</code>
           */
          public Builder setDesc(
              String value) {
            if (value == null) {
        throw new NullPointerException();
      }
      bitField0_ |= 0x00000004;
            desc_ = value;
            onChanged();
            return this;
          }
          /**
           * <code>required string desc = 3;</code>
           */
          public Builder clearDesc() {
            bitField0_ = (bitField0_ & ~0x00000004);
            desc_ = getDefaultInstance().getDesc();
            onChanged();
            return this;
          }
          /**
           * <code>required string desc = 3;</code>
           */
          public Builder setDescBytes(
              com.google.protobuf.ByteString value) {
            if (value == null) {
        throw new NullPointerException();
      }
      bitField0_ |= 0x00000004;
            desc_ = value;
            onChanged();
            return this;
          }
          @Override
          public final Builder setUnknownFields(
              final com.google.protobuf.UnknownFieldSet unknownFields) {
            return super.setUnknownFields(unknownFields);
          }
    
          @Override
          public final Builder mergeUnknownFields(
              final com.google.protobuf.UnknownFieldSet unknownFields) {
            return super.mergeUnknownFields(unknownFields);
          }
    
    
          // @@protoc_insertion_point(builder_scope:SubscribeResp)
        }
    
        // @@protoc_insertion_point(class_scope:SubscribeResp)
        private static final SubscribeResp DEFAULT_INSTANCE;
        static {
          DEFAULT_INSTANCE = new SubscribeResp();
        }
    
        public static SubscribeResp getDefaultInstance() {
          return DEFAULT_INSTANCE;
        }
    
        @Deprecated public static final com.google.protobuf.Parser<SubscribeResp>
            PARSER = new com.google.protobuf.AbstractParser<SubscribeResp>() {
          @Override
          public SubscribeResp parsePartialFrom(
              com.google.protobuf.CodedInputStream input,
              com.google.protobuf.ExtensionRegistryLite extensionRegistry)
              throws com.google.protobuf.InvalidProtocolBufferException {
            return new SubscribeResp(input, extensionRegistry);
          }
        };
    
        public static com.google.protobuf.Parser<SubscribeResp> parser() {
          return PARSER;
        }
    
        @Override
        public com.google.protobuf.Parser<SubscribeResp> getParserForType() {
          return PARSER;
        }
    
        @Override
        public SubscribeResp getDefaultInstanceForType() {
          return DEFAULT_INSTANCE;
        }
    
      }
    
      private static final com.google.protobuf.Descriptors.Descriptor
        internal_static_SubscribeResp_descriptor;
      private static final 
        com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
          internal_static_SubscribeResp_fieldAccessorTable;
    
      public static com.google.protobuf.Descriptors.FileDescriptor
          getDescriptor() {
        return descriptor;
      }
      private static  com.google.protobuf.Descriptors.FileDescriptor
          descriptor;
      static {
        String[] descriptorData = {
          "\n\023SubscribeResp.proto\"A\n\rSubscribeResp\022\020" +
          "\n\010subReqId\030\001 \002(\005\022\020\n\010respCode\030\002 \002(\005\022\014\n\004de" +
          "sc\030\003 \002(\tB(\n\022com.netty.protobufB\022Subscrib" +
          "eRespProto"
        };
        com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner assigner =
            new com.google.protobuf.Descriptors.FileDescriptor.    InternalDescriptorAssigner() {
              public com.google.protobuf.ExtensionRegistry assignDescriptors(
                  com.google.protobuf.Descriptors.FileDescriptor root) {
                descriptor = root;
                return null;
              }
            };
        com.google.protobuf.Descriptors.FileDescriptor
          .internalBuildGeneratedFileFrom(descriptorData,
            new com.google.protobuf.Descriptors.FileDescriptor[] {
            }, assigner);
        internal_static_SubscribeResp_descriptor =
          getDescriptor().getMessageTypes().get(0);
        internal_static_SubscribeResp_fieldAccessorTable = new
          com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
            internal_static_SubscribeResp_descriptor,
            new String[] { "SubReqId", "RespCode", "Desc", });
      }
    
      // @@protoc_insertion_point(outer_class_scope)
    }

// Generated by the protocol buffer compiler.  DO NOT EDIT!
    // source: SubscribeReq.proto
    
    package com.netty.protobuf;
    
    public final class SubscribeReqProto {
      private SubscribeReqProto() {}
      public static void registerAllExtensions(
          com.google.protobuf.ExtensionRegistryLite registry) {
      }
    
      public static void registerAllExtensions(
          com.google.protobuf.ExtensionRegistry registry) {
        registerAllExtensions(
            (com.google.protobuf.ExtensionRegistryLite) registry);
      }
      public interface SubscribeReqOrBuilder extends
          // @@protoc_insertion_point(interface_extends:SubscribeReq)
          com.google.protobuf.MessageOrBuilder {
    
        /**
         * <code>int32 subReqId = 1;</code>
         */
        int getSubReqId();
    
        /**
         * <code>string userName = 2;</code>
         */
        String getUserName();
        /**
         * <code>string userName = 2;</code>
         */
        com.google.protobuf.ByteString
            getUserNameBytes();
    
        /**
         * <code>string productName = 3;</code>
         */
        String getProductName();
        /**
         * <code>string productName = 3;</code>
         */
        com.google.protobuf.ByteString
            getProductNameBytes();
    
        /**
         * <code>repeated string address = 4;</code>
         */
        java.util.List<String>
            getAddressList();
        /**
         * <code>repeated string address = 4;</code>
         */
        int getAddressCount();
        /**
         * <code>repeated string address = 4;</code>
         */
        String getAddress(int index);
        /**
         * <code>repeated string address = 4;</code>
         */
        com.google.protobuf.ByteString
            getAddressBytes(int index);
      }
      /**
       * Protobuf type {@code SubscribeReq}
       */
      public  static final class SubscribeReq extends
          com.google.protobuf.GeneratedMessageV3 implements
          // @@protoc_insertion_point(message_implements:SubscribeReq)
          SubscribeReqOrBuilder {
      private static final long serialVersionUID = 0L;
        // Use SubscribeReq.newBuilder() to construct.
        private SubscribeReq(com.google.protobuf.GeneratedMessageV3.Builder<?> builder) {
          super(builder);
        }
        private SubscribeReq() {
          subReqId_ = 0;
          userName_ = "";
          productName_ = "";
          address_ = com.google.protobuf.LazyStringArrayList.EMPTY;
        }
    
        @Override
        public final com.google.protobuf.UnknownFieldSet
        getUnknownFields() {
          return this.unknownFields;
        }
        private SubscribeReq(
            com.google.protobuf.CodedInputStream input,
            com.google.protobuf.ExtensionRegistryLite extensionRegistry)
            throws com.google.protobuf.InvalidProtocolBufferException {
          this();
          if (extensionRegistry == null) {
            throw new NullPointerException();
          }
          int mutable_bitField0_ = 0;
          com.google.protobuf.UnknownFieldSet.Builder unknownFields =
              com.google.protobuf.UnknownFieldSet.newBuilder();
          try {
            boolean done = false;
            while (!done) {
              int tag = input.readTag();
              switch (tag) {
                case 0:
                  done = true;
                  break;
                case 8: {
    
                  subReqId_ = input.readInt32();
                  break;
                }
                case 18: {
                  String s = input.readStringRequireUtf8();
    
                  userName_ = s;
                  break;
                }
                case 26: {
                  String s = input.readStringRequireUtf8();
    
                  productName_ = s;
                  break;
                }
                case 34: {
                  String s = input.readStringRequireUtf8();
                  if (!((mutable_bitField0_ & 0x00000008) == 0x00000008)) {
                    address_ = new com.google.protobuf.LazyStringArrayList();
                    mutable_bitField0_ |= 0x00000008;
                  }
                  address_.add(s);
                  break;
                }
                default: {
                  if (!parseUnknownFieldProto3(
                      input, unknownFields, extensionRegistry, tag)) {
                    done = true;
                  }
                  break;
                }
              }
            }
          } catch (com.google.protobuf.InvalidProtocolBufferException e) {
            throw e.setUnfinishedMessage(this);
          } catch (java.io.IOException e) {
            throw new com.google.protobuf.InvalidProtocolBufferException(
                e).setUnfinishedMessage(this);
          } finally {
            if (((mutable_bitField0_ & 0x00000008) == 0x00000008)) {
              address_ = address_.getUnmodifiableView();
            }
            this.unknownFields = unknownFields.build();
            makeExtensionsImmutable();
          }
        }
        public static final com.google.protobuf.Descriptors.Descriptor
            getDescriptor() {
          return SubscribeReqProto.internal_static_SubscribeReq_descriptor;
        }
    
        @Override
        protected FieldAccessorTable
            internalGetFieldAccessorTable() {
          return SubscribeReqProto.internal_static_SubscribeReq_fieldAccessorTable
              .ensureFieldAccessorsInitialized(
                  SubscribeReq.class, Builder.class);
        }
    
        private int bitField0_;
        public static final int SUBREQID_FIELD_NUMBER = 1;
        private int subReqId_;
        /**
         * <code>int32 subReqId = 1;</code>
         */
        public int getSubReqId() {
          return subReqId_;
        }
    
        public static final int USERNAME_FIELD_NUMBER = 2;
        private volatile Object userName_;
        /**
         * <code>string userName = 2;</code>
         */
        public String getUserName() {
          Object ref = userName_;
          if (ref instanceof String) {
            return (String) ref;
          } else {
            com.google.protobuf.ByteString bs = 
                (com.google.protobuf.ByteString) ref;
            String s = bs.toStringUtf8();
            userName_ = s;
            return s;
          }
        }
        /**
         * <code>string userName = 2;</code>
         */
        public com.google.protobuf.ByteString
            getUserNameBytes() {
          Object ref = userName_;
          if (ref instanceof String) {
            com.google.protobuf.ByteString b = 
                com.google.protobuf.ByteString.copyFromUtf8(
                    (String) ref);
            userName_ = b;
            return b;
          } else {
            return (com.google.protobuf.ByteString) ref;
          }
        }
    
        public static final int PRODUCTNAME_FIELD_NUMBER = 3;
        private volatile Object productName_;
        /**
         * <code>string productName = 3;</code>
         */
        public String getProductName() {
          Object ref = productName_;
          if (ref instanceof String) {
            return (String) ref;
          } else {
            com.google.protobuf.ByteString bs = 
                (com.google.protobuf.ByteString) ref;
            String s = bs.toStringUtf8();
            productName_ = s;
            return s;
          }
        }
        /**
         * <code>string productName = 3;</code>
         */
        public com.google.protobuf.ByteString
            getProductNameBytes() {
          Object ref = productName_;
          if (ref instanceof String) {
            com.google.protobuf.ByteString b = 
                com.google.protobuf.ByteString.copyFromUtf8(
                    (String) ref);
            productName_ = b;
            return b;
          } else {
            return (com.google.protobuf.ByteString) ref;
          }
        }
    
        public static final int ADDRESS_FIELD_NUMBER = 4;
        private com.google.protobuf.LazyStringList address_;
        /**
         * <code>repeated string address = 4;</code>
         */
        public com.google.protobuf.ProtocolStringList
            getAddressList() {
          return address_;
        }
        /**
         * <code>repeated string address = 4;</code>
         */
        public int getAddressCount() {
          return address_.size();
        }
        /**
         * <code>repeated string address = 4;</code>
         */
        public String getAddress(int index) {
          return address_.get(index);
        }
        /**
         * <code>repeated string address = 4;</code>
         */
        public com.google.protobuf.ByteString
            getAddressBytes(int index) {
          return address_.getByteString(index);
        }
    
        private byte memoizedIsInitialized = -1;
        @Override
        public final boolean isInitialized() {
          byte isInitialized = memoizedIsInitialized;
          if (isInitialized == 1) return true;
          if (isInitialized == 0) return false;
    
          memoizedIsInitialized = 1;
          return true;
        }
    
        @Override
        public void writeTo(com.google.protobuf.CodedOutputStream output)
                            throws java.io.IOException {
          if (subReqId_ != 0) {
            output.writeInt32(1, subReqId_);
          }
          if (!getUserNameBytes().isEmpty()) {
            com.google.protobuf.GeneratedMessageV3.writeString(output, 2, userName_);
          }
          if (!getProductNameBytes().isEmpty()) {
            com.google.protobuf.GeneratedMessageV3.writeString(output, 3, productName_);
          }
          for (int i = 0; i < address_.size(); i++) {
            com.google.protobuf.GeneratedMessageV3.writeString(output, 4, address_.getRaw(i));
          }
          unknownFields.writeTo(output);
        }
    
        @Override
        public int getSerializedSize() {
          int size = memoizedSize;
          if (size != -1) return size;
    
          size = 0;
          if (subReqId_ != 0) {
            size += com.google.protobuf.CodedOutputStream
              .computeInt32Size(1, subReqId_);
          }
          if (!getUserNameBytes().isEmpty()) {
            size += com.google.protobuf.GeneratedMessageV3.computeStringSize(2, userName_);
          }
          if (!getProductNameBytes().isEmpty()) {
            size += com.google.protobuf.GeneratedMessageV3.computeStringSize(3, productName_);
          }
          {
            int dataSize = 0;
            for (int i = 0; i < address_.size(); i++) {
              dataSize += computeStringSizeNoTag(address_.getRaw(i));
            }
            size += dataSize;
            size += 1 * getAddressList().size();
          }
          size += unknownFields.getSerializedSize();
          memoizedSize = size;
          return size;
        }
    
        @Override
        public boolean equals(final Object obj) {
          if (obj == this) {
           return true;
          }
          if (!(obj instanceof SubscribeReq)) {
            return super.equals(obj);
          }
          SubscribeReq other = (SubscribeReq) obj;
    
          boolean result = true;
          result = result && (getSubReqId()
              == other.getSubReqId());
          result = result && getUserName()
              .equals(other.getUserName());
          result = result && getProductName()
              .equals(other.getProductName());
          result = result && getAddressList()
              .equals(other.getAddressList());
          result = result && unknownFields.equals(other.unknownFields);
          return result;
        }
    
        @Override
        public int hashCode() {
          if (memoizedHashCode != 0) {
            return memoizedHashCode;
          }
          int hash = 41;
          hash = (19 * hash) + getDescriptor().hashCode();
          hash = (37 * hash) + SUBREQID_FIELD_NUMBER;
          hash = (53 * hash) + getSubReqId();
          hash = (37 * hash) + USERNAME_FIELD_NUMBER;
          hash = (53 * hash) + getUserName().hashCode();
          hash = (37 * hash) + PRODUCTNAME_FIELD_NUMBER;
          hash = (53 * hash) + getProductName().hashCode();
          if (getAddressCount() > 0) {
            hash = (37 * hash) + ADDRESS_FIELD_NUMBER;
            hash = (53 * hash) + getAddressList().hashCode();
          }
          hash = (29 * hash) + unknownFields.hashCode();
          memoizedHashCode = hash;
          return hash;
        }
    
        public static SubscribeReq parseFrom(
            java.nio.ByteBuffer data)
            throws com.google.protobuf.InvalidProtocolBufferException {
          return PARSER.parseFrom(data);
        }
        public static SubscribeReq parseFrom(
            java.nio.ByteBuffer data,
            com.google.protobuf.ExtensionRegistryLite extensionRegistry)
            throws com.google.protobuf.InvalidProtocolBufferException {
          return PARSER.parseFrom(data, extensionRegistry);
        }
        public static SubscribeReq parseFrom(
            com.google.protobuf.ByteString data)
            throws com.google.protobuf.InvalidProtocolBufferException {
          return PARSER.parseFrom(data);
        }
        public static SubscribeReq parseFrom(
            com.google.protobuf.ByteString data,
            com.google.protobuf.ExtensionRegistryLite extensionRegistry)
            throws com.google.protobuf.InvalidProtocolBufferException {
          return PARSER.parseFrom(data, extensionRegistry);
        }
        public static SubscribeReq parseFrom(byte[] data)
            throws com.google.protobuf.InvalidProtocolBufferException {
          return PARSER.parseFrom(data);
        }
        public static SubscribeReq parseFrom(
            byte[] data,
            com.google.protobuf.ExtensionRegistryLite extensionRegistry)
            throws com.google.protobuf.InvalidProtocolBufferException {
          return PARSER.parseFrom(data, extensionRegistry);
        }
        public static SubscribeReq parseFrom(java.io.InputStream input)
            throws java.io.IOException {
          return com.google.protobuf.GeneratedMessageV3
              .parseWithIOException(PARSER, input);
        }
        public static SubscribeReq parseFrom(
            java.io.InputStream input,
            com.google.protobuf.ExtensionRegistryLite extensionRegistry)
            throws java.io.IOException {
          return com.google.protobuf.GeneratedMessageV3
              .parseWithIOException(PARSER, input, extensionRegistry);
        }
        public static SubscribeReq parseDelimitedFrom(java.io.InputStream input)
            throws java.io.IOException {
          return com.google.protobuf.GeneratedMessageV3
              .parseDelimitedWithIOException(PARSER, input);
        }
        public static SubscribeReq parseDelimitedFrom(
            java.io.InputStream input,
            com.google.protobuf.ExtensionRegistryLite extensionRegistry)
            throws java.io.IOException {
          return com.google.protobuf.GeneratedMessageV3
              .parseDelimitedWithIOException(PARSER, input, extensionRegistry);
        }
        public static SubscribeReq parseFrom(
            com.google.protobuf.CodedInputStream input)
            throws java.io.IOException {
          return com.google.protobuf.GeneratedMessageV3
              .parseWithIOException(PARSER, input);
        }
        public static SubscribeReq parseFrom(
            com.google.protobuf.CodedInputStream input,
            com.google.protobuf.ExtensionRegistryLite extensionRegistry)
            throws java.io.IOException {
          return com.google.protobuf.GeneratedMessageV3
              .parseWithIOException(PARSER, input, extensionRegistry);
        }
    
    
        public Builder newBuilderForType() { return newBuilder(); }
        public static Builder newBuilder() {
          return DEFAULT_INSTANCE.toBuilder();
        }
        public static Builder newBuilder(SubscribeReq prototype) {
          return DEFAULT_INSTANCE.toBuilder().mergeFrom(prototype);
        }
        public Builder toBuilder() {
          return this == DEFAULT_INSTANCE
              ? new Builder() : new Builder().mergeFrom(this);
        }
    
        @Override
        protected Builder newBuilderForType(
            BuilderParent parent) {
          Builder builder = new Builder(parent);
          return builder;
        }
        /**
         * Protobuf type {@code SubscribeReq}
         */
        public static final class Builder extends
            com.google.protobuf.GeneratedMessageV3.Builder<Builder> implements
            // @@protoc_insertion_point(builder_implements:SubscribeReq)
            SubscribeReqOrBuilder {
          public static final com.google.protobuf.Descriptors.Descriptor
              getDescriptor() {
            return SubscribeReqProto.internal_static_SubscribeReq_descriptor;
          }
    
          @Override
          protected FieldAccessorTable
              internalGetFieldAccessorTable() {
            return SubscribeReqProto.internal_static_SubscribeReq_fieldAccessorTable
                .ensureFieldAccessorsInitialized(
                    SubscribeReq.class, Builder.class);
          }
    
          // Construct using com.netty.protobuf.SubscribeReqProto.SubscribeReq.newBuilder()
          private Builder() {
            maybeForceBuilderInitialization();
          }
    
          private Builder(
              BuilderParent parent) {
            super(parent);
            maybeForceBuilderInitialization();
          }
          private void maybeForceBuilderInitialization() {
            if (com.google.protobuf.GeneratedMessageV3
                    .alwaysUseFieldBuilders) {
            }
          }
          @Override
          public Builder clear() {
            super.clear();
            subReqId_ = 0;
    
            userName_ = "";
    
            productName_ = "";
    
            address_ = com.google.protobuf.LazyStringArrayList.EMPTY;
            bitField0_ = (bitField0_ & ~0x00000008);
            return this;
          }
    
          @Override
          public com.google.protobuf.Descriptors.Descriptor
              getDescriptorForType() {
            return SubscribeReqProto.internal_static_SubscribeReq_descriptor;
          }
    
          public SubscribeReq getDefaultInstanceForType() {
            return SubscribeReq.getDefaultInstance();
          }
    
          public SubscribeReq build() {
            SubscribeReq result = buildPartial();
            if (!result.isInitialized()) {
              throw newUninitializedMessageException(result);
            }
            return result;
          }
    
          public SubscribeReq buildPartial() {
            SubscribeReq result = new SubscribeReq(this);
            int from_bitField0_ = bitField0_;
            int to_bitField0_ = 0;
            result.subReqId_ = subReqId_;
            result.userName_ = userName_;
            result.productName_ = productName_;
            if (((bitField0_ & 0x00000008) == 0x00000008)) {
              address_ = address_.getUnmodifiableView();
              bitField0_ = (bitField0_ & ~0x00000008);
            }
            result.address_ = address_;
            result.bitField0_ = to_bitField0_;
            onBuilt();
            return result;
          }
    
          @Override
          public Builder clone() {
            return (Builder) super.clone();
          }
          @Override
          public Builder setField(
              com.google.protobuf.Descriptors.FieldDescriptor field,
              Object value) {
            return (Builder) super.setField(field, value);
          }
          @Override
          public Builder clearField(
              com.google.protobuf.Descriptors.FieldDescriptor field) {
            return (Builder) super.clearField(field);
          }
          @Override
          public Builder clearOneof(
              com.google.protobuf.Descriptors.OneofDescriptor oneof) {
            return (Builder) super.clearOneof(oneof);
          }
          @Override
          public Builder setRepeatedField(
              com.google.protobuf.Descriptors.FieldDescriptor field,
              int index, Object value) {
            return (Builder) super.setRepeatedField(field, index, value);
          }
          @Override
          public Builder addRepeatedField(
              com.google.protobuf.Descriptors.FieldDescriptor field,
              Object value) {
            return (Builder) super.addRepeatedField(field, value);
          }
          @Override
          public Builder mergeFrom(com.google.protobuf.Message other) {
            if (other instanceof SubscribeReq) {
              return mergeFrom((SubscribeReq)other);
            } else {
              super.mergeFrom(other);
              return this;
            }
          }
    
          public Builder mergeFrom(SubscribeReq other) {
            if (other == SubscribeReq.getDefaultInstance()) return this;
            if (other.getSubReqId() != 0) {
              setSubReqId(other.getSubReqId());
            }
            if (!other.getUserName().isEmpty()) {
              userName_ = other.userName_;
              onChanged();
            }
            if (!other.getProductName().isEmpty()) {
              productName_ = other.productName_;
              onChanged();
            }
            if (!other.address_.isEmpty()) {
              if (address_.isEmpty()) {
                address_ = other.address_;
                bitField0_ = (bitField0_ & ~0x00000008);
              } else {
                ensureAddressIsMutable();
                address_.addAll(other.address_);
              }
              onChanged();
            }
            this.mergeUnknownFields(other.unknownFields);
            onChanged();
            return this;
          }
    
          @Override
          public final boolean isInitialized() {
            return true;
          }
    
          @Override
          public Builder mergeFrom(
              com.google.protobuf.CodedInputStream input,
              com.google.protobuf.ExtensionRegistryLite extensionRegistry)
              throws java.io.IOException {
            SubscribeReq parsedMessage = null;
            try {
              parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry);
            } catch (com.google.protobuf.InvalidProtocolBufferException e) {
              parsedMessage = (SubscribeReq) e.getUnfinishedMessage();
              throw e.unwrapIOException();
            } finally {
              if (parsedMessage != null) {
                mergeFrom(parsedMessage);
              }
            }
            return this;
          }
          private int bitField0_;
    
          private int subReqId_ ;
          /**
           * <code>int32 subReqId = 1;</code>
           */
          public int getSubReqId() {
            return subReqId_;
          }
          /**
           * <code>int32 subReqId = 1;</code>
           */
          public Builder setSubReqId(int value) {
            
            subReqId_ = value;
            onChanged();
            return this;
          }
          /**
           * <code>int32 subReqId = 1;</code>
           */
          public Builder clearSubReqId() {
            
            subReqId_ = 0;
            onChanged();
            return this;
          }
    
          private Object userName_ = "";
          /**
           * <code>string userName = 2;</code>
           */
          public String getUserName() {
            Object ref = userName_;
            if (!(ref instanceof String)) {
              com.google.protobuf.ByteString bs =
                  (com.google.protobuf.ByteString) ref;
              String s = bs.toStringUtf8();
              userName_ = s;
              return s;
            } else {
              return (String) ref;
            }
          }
          /**
           * <code>string userName = 2;</code>
           */
          public com.google.protobuf.ByteString
              getUserNameBytes() {
            Object ref = userName_;
            if (ref instanceof String) {
              com.google.protobuf.ByteString b = 
                  com.google.protobuf.ByteString.copyFromUtf8(
                      (String) ref);
              userName_ = b;
              return b;
            } else {
              return (com.google.protobuf.ByteString) ref;
            }
          }
          /**
           * <code>string userName = 2;</code>
           */
          public Builder setUserName(
              String value) {
            if (value == null) {
        throw new NullPointerException();
      }
      
            userName_ = value;
            onChanged();
            return this;
          }
          /**
           * <code>string userName = 2;</code>
           */
          public Builder clearUserName() {
            
            userName_ = getDefaultInstance().getUserName();
            onChanged();
            return this;
          }
          /**
           * <code>string userName = 2;</code>
           */
          public Builder setUserNameBytes(
              com.google.protobuf.ByteString value) {
            if (value == null) {
        throw new NullPointerException();
      }
      checkByteStringIsUtf8(value);
            
            userName_ = value;
            onChanged();
            return this;
          }
    
          private Object productName_ = "";
          /**
           * <code>string productName = 3;</code>
           */
          public String getProductName() {
            Object ref = productName_;
            if (!(ref instanceof String)) {
              com.google.protobuf.ByteString bs =
                  (com.google.protobuf.ByteString) ref;
              String s = bs.toStringUtf8();
              productName_ = s;
              return s;
            } else {
              return (String) ref;
            }
          }
          /**
           * <code>string productName = 3;</code>
           */
          public com.google.protobuf.ByteString
              getProductNameBytes() {
            Object ref = productName_;
            if (ref instanceof String) {
              com.google.protobuf.ByteString b = 
                  com.google.protobuf.ByteString.copyFromUtf8(
                      (String) ref);
              productName_ = b;
              return b;
            } else {
              return (com.google.protobuf.ByteString) ref;
            }
          }
          /**
           * <code>string productName = 3;</code>
           */
          public Builder setProductName(
              String value) {
            if (value == null) {
        throw new NullPointerException();
      }
      
            productName_ = value;
            onChanged();
            return this;
          }
          /**
           * <code>string productName = 3;</code>
           */
          public Builder clearProductName() {
            
            productName_ = getDefaultInstance().getProductName();
            onChanged();
            return this;
          }
          /**
           * <code>string productName = 3;</code>
           */
          public Builder setProductNameBytes(
              com.google.protobuf.ByteString value) {
            if (value == null) {
        throw new NullPointerException();
      }
      checkByteStringIsUtf8(value);
            
            productName_ = value;
            onChanged();
            return this;
          }
    
          private com.google.protobuf.LazyStringList address_ = com.google.protobuf.LazyStringArrayList.EMPTY;
          private void ensureAddressIsMutable() {
            if (!((bitField0_ & 0x00000008) == 0x00000008)) {
              address_ = new com.google.protobuf.LazyStringArrayList(address_);
              bitField0_ |= 0x00000008;
             }
          }
          /**
           * <code>repeated string address = 4;</code>
           */
          public com.google.protobuf.ProtocolStringList
              getAddressList() {
            return address_.getUnmodifiableView();
          }
          /**
           * <code>repeated string address = 4;</code>
           */
          public int getAddressCount() {
            return address_.size();
          }
          /**
           * <code>repeated string address = 4;</code>
           */
          public String getAddress(int index) {
            return address_.get(index);
          }
          /**
           * <code>repeated string address = 4;</code>
           */
          public com.google.protobuf.ByteString
              getAddressBytes(int index) {
            return address_.getByteString(index);
          }
          /**
           * <code>repeated string address = 4;</code>
           */
          public Builder setAddress(
              int index, String value) {
            if (value == null) {
        throw new NullPointerException();
      }
      ensureAddressIsMutable();
            address_.set(index, value);
            onChanged();
            return this;
          }
          /**
           * <code>repeated string address = 4;</code>
           */
          public Builder addAddress(
              String value) {
            if (value == null) {
        throw new NullPointerException();
      }
      ensureAddressIsMutable();
            address_.add(value);
            onChanged();
            return this;
          }
          /**
           * <code>repeated string address = 4;</code>
           */
          public Builder addAllAddress(
              Iterable<String> values) {
            ensureAddressIsMutable();
            com.google.protobuf.AbstractMessageLite.Builder.addAll(
                values, address_);
            onChanged();
            return this;
          }
          /**
           * <code>repeated string address = 4;</code>
           */
          public Builder clearAddress() {
            address_ = com.google.protobuf.LazyStringArrayList.EMPTY;
            bitField0_ = (bitField0_ & ~0x00000008);
            onChanged();
            return this;
          }
          /**
           * <code>repeated string address = 4;</code>
           */
          public Builder addAddressBytes(
              com.google.protobuf.ByteString value) {
            if (value == null) {
        throw new NullPointerException();
      }
      checkByteStringIsUtf8(value);
            ensureAddressIsMutable();
            address_.add(value);
            onChanged();
            return this;
          }
          @Override
          public final Builder setUnknownFields(
              final com.google.protobuf.UnknownFieldSet unknownFields) {
            return super.setUnknownFieldsProto3(unknownFields);
          }
    
          @Override
          public final Builder mergeUnknownFields(
              final com.google.protobuf.UnknownFieldSet unknownFields) {
            return super.mergeUnknownFields(unknownFields);
          }
    
    
          // @@protoc_insertion_point(builder_scope:SubscribeReq)
        }
    
        // @@protoc_insertion_point(class_scope:SubscribeReq)
        private static final SubscribeReq DEFAULT_INSTANCE;
        static {
          DEFAULT_INSTANCE = new SubscribeReq();
        }
    
        public static SubscribeReq getDefaultInstance() {
          return DEFAULT_INSTANCE;
        }
    
        private static final com.google.protobuf.Parser<SubscribeReq>
            PARSER = new com.google.protobuf.AbstractParser<SubscribeReq>() {
          public SubscribeReq parsePartialFrom(
              com.google.protobuf.CodedInputStream input,
              com.google.protobuf.ExtensionRegistryLite extensionRegistry)
              throws com.google.protobuf.InvalidProtocolBufferException {
            return new SubscribeReq(input, extensionRegistry);
          }
        };
    
        public static com.google.protobuf.Parser<SubscribeReq> parser() {
          return PARSER;
        }
    
        @Override
        public com.google.protobuf.Parser<SubscribeReq> getParserForType() {
          return PARSER;
        }
    
    
        public SubscribeReq getDefaultInstanceForType() {
          return DEFAULT_INSTANCE;
        }
    
      }
    
      private static final com.google.protobuf.Descriptors.Descriptor
        internal_static_SubscribeReq_descriptor;
      private static final 
        com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
          internal_static_SubscribeReq_fieldAccessorTable;
    
      public static com.google.protobuf.Descriptors.FileDescriptor
          getDescriptor() {
        return descriptor;
      }
      private static  com.google.protobuf.Descriptors.FileDescriptor
          descriptor;
      static {
        String[] descriptorData = {
          "\n\022SubscribeReq.proto\"X\n\014SubscribeReq\022\020\n\010" +
          "subReqId\030\001 \001(\005\022\020\n\010userName\030\002 \001(\t\022\023\n\013prod" +
          "uctName\030\003 \001(\t\022\017\n\007address\030\004 \003(\tB\'\n\022com.ne" +
          "tty.protobufB\021SubscribeReqProtob\006proto3"
        };
        com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner assigner =
            new com.google.protobuf.Descriptors.FileDescriptor.    InternalDescriptorAssigner() {
              public com.google.protobuf.ExtensionRegistry assignDescriptors(
                  com.google.protobuf.Descriptors.FileDescriptor root) {
                descriptor = root;
                return null;
              }
            };
        com.google.protobuf.Descriptors.FileDescriptor
          .internalBuildGeneratedFileFrom(descriptorData,
            new com.google.protobuf.Descriptors.FileDescriptor[] {
            }, assigner);
        internal_static_SubscribeReq_descriptor =
          getDescriptor().getMessageTypes().get(0);
        internal_static_SubscribeReq_fieldAccessorTable = new
          com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
            internal_static_SubscribeReq_descriptor,
            new String[] { "SubReqId", "UserName", "ProductName", "Address", });
      }
    
      // @@protoc_insertion_point(outer_class_scope)
    }

这是由protobuf生成的java文件。

[70]: /images/20220504/b28995a84eed4acf912765e9585d61ae.png
[https_github.com_google_protobuf_releases]: https://github.com/google/protobuf/releases
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3NTk4MDEx_size_27_color_FFFFFF_t_70]: /images/20220504/7e0d8eb4d7cc428eb81a83fb0aec3108.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3NTk4MDEx_size_27_color_FFFFFF_t_70 1]: /images/20220504/f4db625805fc4f7087a95c1ae096b805.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3NTk4MDEx_size_27_color_FFFFFF_t_70 2]: /images/20220504/cddf44719874406591a8fde46dc0f3e0.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3NTk4MDEx_size_27_color_FFFFFF_t_70 3]: /images/20220504/3138a17d26f44e22a267110b68828439.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3NTk4MDEx_size_27_color_FFFFFF_t_70 4]: /images/20220504/c80eb4b0ed27426688cb60c55a86dcbb.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3NTk4MDEx_size_27_color_FFFFFF_t_70 5]: /images/20220504/fb07ba61adc249f3a1be71d0b0397ece.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3NTk4MDEx_size_27_color_FFFFFF_t_70 6]: /images/20220504/112ac095976945b5b2674d58b9c7adac.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3NTk4MDEx_size_27_color_FFFFFF_t_70 7]: /images/20220504/300b81de1ddf40669a8afd852b1f64e7.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3NTk4MDEx_size_27_color_FFFFFF_t_70 8]: /images/20220504/a6b30a18a3f44108bd7a9c1a117faa24.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3NTk4MDEx_size_27_color_FFFFFF_t_70 9]: /images/20220504/9cb44eab1c76435895dbb1d2f1a8b1ff.png