package serialize;

import java.io.Serializable;
import java.util.List;
import com.baidu.bjf.remoting.protobuf.FieldType;
import com.baidu.bjf.remoting.protobuf.annotation.Protobuf;

public class User implements Serializable {
  private static final long serialVersionUID = -7890663945232864573L;

  @Protobuf(fieldType = FieldType.INT32, required = false, order = 1)
  private Integer userId;

  @Protobuf(fieldType = FieldType.STRING, required = false, order = 2)
  private String userName;

  @Protobuf(fieldType = FieldType.STRING, required = false, order = 3)
  private String passWord;

  @Protobuf(fieldType = FieldType.STRING, required = false, order = 4)
  private String userInfo;

  @Protobuf(fieldType = FieldType.OBJECT, required = false, order = 5)
  private List<User> friends;

  public Integer getUserId() {
    return userId;
  }

  public void setUserId(Integer userId) {
    this.userId = userId;
  }

  public String getUserName() {
    return userName;
  }

  public void setUserName(String userName) {
    this.userName = userName;
  }

  public String getPassWord() {
    return passWord;
  }

  public void setPassWord(String passWord) {
    this.passWord = passWord;
  }

  public String getUserInfo() {
    return userInfo;
  }

  public void setUserInfo(String userInfo) {
    this.userInfo = userInfo;
  }

  public List<User> getFriends() {
    return friends;
  }

  public void setFriends(List<User> friends) {
    this.friends = friends;
  }

  @Override
  public String toString() {
    return "User [userId=" + userId + ", userName=" + userName + ", passWord=" + passWord + ", userInfo=" + userInfo
        + ", friends=" + friends + "]";
  }

}

package serialize;

import java.io.IOException;
import java.util.ArrayList;
import java.util.List;

import com.baidu.bjf.remoting.protobuf.Codec;
import com.baidu.bjf.remoting.protobuf.ProtobufProxy;
/**
 * 
 * @author liqqc
 *
 */
public class ProtoBuffSerialize {

  public static void main(String[] args) throws IOException {
    new ProtoBuffSerialize().start();
  }

  public void start() throws IOException {
    Codec<User> studentClassCodec = ProtobufProxy.create(User.class, false);

    User u2 = new User();
    List<User> friends = new ArrayList<>();
    u2.setUserName("张三");
    u2.setPassWord("123456");
    u2.setUserInfo("张三是一个很牛逼的人");
    u2.setFriends(friends);

    User f1 = new User();
    f1.setUserName("李四");
    f1.setPassWord("123456");
    f1.setUserInfo("李四是一个很牛逼的人");

    User f2 = new User();
    f2.setUserName("王五");
    f2.setPassWord("123456");
    f2.setUserInfo("王五是一个很牛逼的人");
    friends.add(f1);
    friends.add(f2);

    Long stime_jpb_encode = System.currentTimeMillis();
    byte[] bytes = null;
    for(int i = 0; i<10; i++) {
      bytes = studentClassCodec.encode(u2);
    }
    System.out.println("jprotobuf序列化耗时：" + (System.currentTimeMillis() - stime_jpb_encode) + "ms; 总大小：" + bytes.length);

    Long stime_jpb_decode = System.currentTimeMillis();
    User user = studentClassCodec.decode(bytes);
    Long etime_jpb_decode = System.currentTimeMillis();
    System.out.println("jprotobuf反序列化耗时："+ (etime_jpb_decode-stime_jpb_decode) + "ms; User: " + user);
  }

}