Java使用Protocol Buffers入门四步骤

Protocol Buffers（简称protobuf）是谷歌的一项技术。用于将结构化的数据序列化、反序列化。经经常使用于网络传输。

这货实际上相似于XML生成和解析。但protobuf的效率高于XML，只是protobuf生成的是字节码，可读性比XML差。相似的还有json、Java的Serializable等。

protobuf支持各种语言。本文以Java为例。简介protobuf怎样使用。

其它语言用法相似。

首先须要下载：

http://download.csdn.net/download/xiao__gui/7586617

解压后有两个文件：protobuf-java-2.5.0.jar和protoc.exe。

protobuf-java-2.5.0.jar即protobuf所须要的jar包。假设用maven的话能够无视这个文件；

protoc.exe是protobuf代码生成工具。

第一步：定义数据结构


首先要定义protobuf的数据结构，这里要写一个.proto文件。这个文件有点相似于定义一个类。

比如定义一个Person。保存文件PersonMsg.proto（注意文件名称和里面的message名不要一样）。

message Person {

// ID（必需）
required int32 id = 1;

// 姓名（必需）
required string name = 2;

// email（可选）
optional string email = 3;

// 朋友（集合）
repeated string friends = 4;
}

上面的1、2、3、4是unique numbered tag，是一个唯一标识。

上面的样例中定义了一个很easy的数据结构，当然还能够定义更复杂的结构，这里不再讨论，详细能够看官方文档。

第二步：protoc.exe生成Java代码


使用文件protoc.exe，cmd命令行执行：

protoc.exe --java_out=E:\java PersonMsg.proto

输入文件是PersonMsg.proto。也就是定义数据结构的文件；输出目录是E:\java，将java文件生成在E:\java中。执行命令成功后会生成PersonMsg.java：



在Eclipse中创建一个项目，将java文件复制到项目中。项目中须要引入protobuf-java-2.5.0.jar包。

假设是maven项目则增加：

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

第三步：序列化
第四步：反序列化

一般来说。序列化和反序列化是分开的。比如网络传输，由一方将数据序列化后发送给还有一方来接收并解析。序列化发送和接收反序列化并不在一起。可是以下为了样例简单将二者写在同一程序中。

import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.util.List;

public class Main {

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

// 依照定义的数据结构，创建一个Person
PersonMsg.Person.Builder personBuilder = PersonMsg.Person.newBuilder();
personBuilder.setId(1);
personBuilder.setName("叉叉哥");
personBuilder.setEmail("xxg@163.com");
personBuilder.addFriends("Friend A");
personBuilder.addFriends("Friend B");
PersonMsg.Person xxg = personBuilder.build();

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

// -------------- 切割线：上面是发送方，将数据序列化后发送 ---------------

byte[] byteArray = output.toByteArray();

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

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

// 反序列化
PersonMsg.Person xxg2 = PersonMsg.Person.parseFrom(input);
System.out.println("ID:" + xxg2.getId());
System.out.println("name:" + xxg2.getName());
System.out.println("email:" + xxg2.getEmail());
System.out.println("friend:");
List<String> friends = xxg2.getFriendsList();
for(String friend : friends) {
System.out.println(friend);
}
}

}

作者：叉叉哥 转载请注明出处：/article/1557549.html