MessagePack使用研究

MessagePack是一个基于二进制高效的对象序列化类库，可用于跨语言通信。它可以像JSON那样，在许多种语言之间交换结构对象；但是它比JSON更快速也更轻巧。支持Python、Ruby、Java、C/C++等众多语言。比GoogleProtocol Buffers还要快4倍。

代码实现1：

 

package com.newtest;

import java.io.IOException;

import org.msgpack.MessagePack;

import org.msgpack.annotation.Message;

@Message

public class Student {

public int sAge = 0;

public String sName;

public boolean sHasPhone;

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

Student stu = new Student();

stu.sAge = 13;

stu.sName = "programer";

stu.sHasPhone = true;

MessagePack pack = new MessagePack();

// 序列化

byte[] bytes = pack.write(stu);

// 反序列化

Student s = pack.read(bytes, Student.class);

System.out.println("Name: " + s.sName + "\n" + "Age: " + s.sAge + "\n"

+ "HasPhone: " + s.sHasPhone);

}

}

代码实现2：

 

package com.newtest;

 

 import java.io.IOException;

 import org.msgpack.MessagePack;

 import org.msgpack.annotation.Message;

 import org.msgpack.annotation.Optional;

 

 @Message

 public class ServerStudent {

     public int sAge = 0;

 

     public String sName;

 

     public boolean sHasPhone;

 

     /**

      * 在Server端相应的Entity里添加需要的属性， 但是为了兼容之前的数据，必须加上注解@Optional

      * Optional的作用是是否有该字段都不会影响MessagePack的正常解压

      */

     @Optional

     public double sHeight;

 

     /**

      * 该类里并没有sHeight字段，可以把它看做已经发出去的产品

      */

     @Message

     static class ClientStudent {

 

         public int sAge = 0;

 

         public String sName;

 

         public boolean sHasPhone;

     }

 

     /**

      * 与目前Server端数据字段相一致的Entity

      */

     @Message

     static class NewClientStudent {

         public int sAge = 0;

 

         public String sName;

 

         public boolean sHasPhone;

 

         public double sHeight;

     }

 

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

         ClientStudent stu = new ClientStudent();

         stu.sAge = 13;

         stu.sName = "programer";

         stu.sHasPhone = true;

 

         NewClientStudent ns = new NewClientStudent();

         ns.sAge = 10;

         ns.sName = "coder";

         ns.sHasPhone = false;

         ns.sHeight = 180;

 

         MessagePack pack = new MessagePack();

 

         // 序列化

         byte[] bytes = pack.write(stu);

         byte[] nBytes = pack.write(ns);

 

         // 反序列化

         ServerStudent s = pack.read(bytes, ServerStudent.class);

         ServerStudent ss = pack.read(nBytes, ServerStudent.class);

 

         System.out.println("之前发布出去的产品： \n" + "Name: " + s.sName + "\n"

                 + "Age: " + s.sAge + "\n" + "HasPhone: " + s.sHasPhone+"\n\n");

         System.out.println("目前的产品： \n" + "Name: " + ss.sName + "\n" + "Age: "

                 + ss.sAge + "\n" + "HasPhone: " + ss.sHasPhone + "\n"

                 + "Height: " + ss.sHeight);

     }

 

 }

需要进入的JARS:见附件

下载链接：

https://github.com/guoyunsky/msgpack-rpc-demo
https://github.com/nowelium/msgpack-socket-rpc