《精通并发与Netty》学习笔记（04 - Google Protobuf介绍）

  syntax = "proto2";
  package protobuf;

  option java_package = "com.ssy.protobuf";
  option java_outer_classname = "PersonProbuf";

  message Person {
    required int32 id = 1;
    required string name = 2;
    optional int32 age = 3;
    optional string address = 4;
 }

            package
             com.ssy.netty.proto;


            import
             java.io.ByteArrayInputStream;

            import
             java.io.ByteArrayOutputStream;

            import
             java.io.IOException;

            import
             java.util.List;


            public
            class
             Test {

    
            public
            static
            void main(String[] args) throws IOException {

        // 按照定义的数据结构，创建一个Person
        PersonProbuf.Person.Builder personBuilder = PersonProbuf.Person.newBuilder();
        personBuilder.setId(1);
        personBuilder.setName("灿灿");
        personBuilder.setAge(35);
        personBuilder.setAddress("河北石家庄");
        PersonProbuf.Person xxg = personBuilder.build();

        // 将数据写到输出流，如网络输出流，这里就用ByteArrayOutputStream来代替
        ByteArrayOutputStream output = new ByteArrayOutputStream();
        xxg.writeTo(output);

        // -------------- 分割线：上面是发送方，将数据序列化后发送 ---------------byte[] byteArray = output.toByteArray();

        // -------------- 分割线：下面是接收方，将数据接收后反序列化 ---------------

        // 接收到流并读取，如网络输入流，这里用ByteArrayInputStream来代替
        ByteArrayInputStream input = new ByteArrayInputStream(byteArray);

        // 反序列化
        PersonProbuf.Person xxg2 = PersonProbuf.Person.parseFrom(input);
        System.out.println("ID:" + xxg2.getId());
        System.out.println("name:" + xxg2.getName());
        System.out.println("age:" + xxg2.getAge());
        System.out.println("address:" + xxg2.getAddress());
    }
}