google的protocol buffers 对象的序列化 for java

前言：

protobuf确实比JSON快很多倍，看下面的图就知道了。

环境：

win7 x64

eclipse 4.3

protoc-2.5.0

安装包下载：

https://code.google.com/p/protobuf/downloads/list

2.6+的版本已转到GitHub上，下载地址是：

https://github.com/google/protobuf/releases

1.生成jar包

下载ProtoBuf包和生成protobuf-2.5.0.jar文件。下载protoc-2.5.0-win32.zip和protobuf-2.5.0.zip，两个文件都解压缩，将protoc-2.5.0-win32中的protoc.exe文件拷贝到protobuf-2.5.0\src目录下，然后进入protobuf-2.5.0\java，执行 mvn install，编译完成后可以在protobuf-2.5.0\java\target目录中找到protobuf-2.5.0.jar文件。

2.建立eclipse项目

  a.  protoc.exe 放在工程的根目录下面

  b. protobuf-java-2.5.0.jar 放在lib下面

  c.  新建一个文件夹proto存放proto文件

 d. 在proto文件夹下新建一个文件msg.proto，写入以下内容：

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

message Person {
required string name = 1;
required int32 id = 2;
optional string email = 3;

enum PhoneType {
MOBILE = 0;
HOME = 1;
WORK = 2;
}

message PhoneNumber {
required string number = 1;
optional PhoneType type = 2 [default = HOME];
}

repeated PhoneNumber phone = 4;

message CountryInfo {
required string name = 1;
required string code = 2;
optional int32 number = 3;
}
}

message AddressBook {
repeated Person person = 1;
}

3.产生protobuf JAVA类

进入  cd E:/Git/myhadoop2.x/myhadoop2.x文件夹

执行：

protoc --java_out=./src/main/java   ./proto/msg.proto

在包package com.jamesfen.protobuf;下面会找到类PersonProbuf

4.序列化反序列化测试：

package com.jamesfen.protobuf;
import java.util.List;
import com.google.protobuf.InvalidProtocolBufferException;
import com.jamesfen.protobuf.PersonProbuf;
import com.jamesfen.protobuf.PersonProbuf.Person;
import com.jamesfen.protobuf.PersonProbuf.Person.PhoneNumber;
public class TestProtobuf {

/**
* @param args
*/
public static void main(String[] args) {
// TODO Auto-generated method stub
PersonProbuf.Person.Builder builder = PersonProbuf.Person.newBuilder();
builder.setEmail("kkk@email.com");
builder.setId(1);
builder.setName("TestName");
builder.addPhone(PersonProbuf.Person.PhoneNumber.newBuilder().setNumber("131111111").setType(PersonProbuf.Person.PhoneType.MOBILE));
builder.addPhone(PersonProbuf.Person.PhoneNumber.newBuilder().setNumber("011111").setType(PersonProbuf.Person.PhoneType.HOME));
Person person = builder.build();
byte[] buf = person.toByteArray();
try {
Person person2 = PersonProbuf.Person.parseFrom(buf);
System.out.println(person2.getName() + ", " + person2.getEmail());
List<PhoneNumber> lstPhones = person2.getPhoneList();
for (PhoneNumber phoneNumber : lstPhones) {
System.out.println(phoneNumber.getNumber());
}
} catch (InvalidProtocolBufferException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
System.out.println(buf);
}

}

5. 输出：

TestName, kkk@email.com

131111111

011111

[B@472a2a50

6.demo源码下载

https://github.com/Bellonor/myhadoop2.x