MessagePack Java 0.6.X 使用一个消息打包（message-packable）类

使用注解 @Message 来让你可以序列化你自己类中对象的 public 字段。

本代码可以在 https://github.com/cwiki-us-demo/messagepack-6-demo-java/blob/master/src/test/java/com/insight/demo/msgpack/MessagePack6Object.java 中下载到本地后进行编译测试。

package com.insight.demo.msgpack; import org.junit.Test; import org.msgpack.MessagePack; import org.msgpack.annotation.Message; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import java.util.UUID; import static org.junit.Assert.assertEquals; /**  * MessagePack6Objects  *  * @author yhu  */ public class MessagePack6Object {     final Logger logger = LoggerFactory.getLogger(MessagePack6Object.class);     /**      * MessageData Message Object      */     @Message // Annotation     public static class MessageData {         // public fields are serialized.         public String uuid;         public String name;         public double version;     }     /**      * Test MessagePack6Objects      */     @Test     public void testMessagePack6Objects() {         logger.debug("MessagePack6Objects for Objects");         String uuid = UUID.randomUUID().toString();         // INIT OBJ         MessageData src = new MessageData();         src.uuid = uuid;         src.name = "MessagePack6";         src.version = 0.6;         try {             MessagePack msgPack = new MessagePack();             // Serialization             logger.debug("------ Serialization ------");             byte[] bytes = msgPack.write(src);             logger.debug("Bytes Array Length: [{}]", bytes.length);             // Deserialization             logger.debug("------ Deserialization ------");             MessageData dst = msgPack.read(bytes, MessageData.class);             logger.debug("Check Object for UUID: [{}]", dst.uuid);             assertEquals(uuid, dst.uuid);         } catch (Exception ex) {             logger.error("MessagePack Serialization And Deserialization error", ex);         }     } }

如果你希望按照顺序序列化多个对象的话，你可以使用  Packer 和  Unpacker 多个对象。

这是因为 MessagePack.write(Object) 和 read(byte[]) 实际上每次都调用创建了 Packer 和 Unpacker 对象。

为了使用 Packer 和  Unpacker 对象，请调用 createPacker(OutputStream) 和  createUnpacker(InputStream)。

本代码可以 https://github.com/cwiki-us-demo/messagepack-6-demo-java/blob/master/src/test/java/com/insight/demo/msgpack/MessagePack6Objects.java 中查看。

package com.insight.demo.msgpack; import org.junit.Test; import org.msgpack.MessagePack; import org.msgpack.annotation.Message; import org.msgpack.packer.Packer; import org.msgpack.unpacker.Unpacker; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import java.io.ByteArrayInputStream; import java.io.ByteArrayOutputStream; import java.util.UUID; import static org.junit.Assert.assertEquals; /**  * MessagePack6Objects  *  * @author yhu  */ public class MessagePack6Objects {     final Logger logger = LoggerFactory.getLogger(MessagePack6Objects.class);     /**      * MessageData Message Objects      */     @Message // Annotation     public static class MessageData {         // public fields are serialized.         public String uuid;         public String name;         public double version;     }     /**      * Test MessagePack6Objects      */     @Test     public void testMessagePack6Objects() {         logger.debug("MessagePack6Objects for Objects");         String uuid = UUID.randomUUID().toString();         // INIT OBJ         MessageData src1 = new MessageData();         src1.uuid = uuid;         src1.name = "MessagePack6-src1";         src1.version = 0.6;         MessageData src2 = new MessageData();         src2.uuid = uuid;         src2.name = "MessagePack6-src2";         src2.version = 10.6;         MessageData src3 = new MessageData();         src3.uuid = uuid;         src3.name = "MessagePack6-src3";         src3.version = 1.6;         try {             MessagePack msgPack = new MessagePack();             // Serialization             logger.debug("------ Serialization ------");             ByteArrayOutputStream out = new ByteArrayOutputStream();             Packer packer = msgPack.createPacker(out);             packer.write(src1);             packer.write(src2);             packer.write(src3);             byte[] bytes = out.toByteArray();             logger.debug("Bytes Array Length: [{}]", bytes.length);             // Deserialization             logger.debug("------ Deserialization ------");             ByteArrayInputStream in = new ByteArrayInputStream(bytes);             Unpacker unpacker = msgPack.createUnpacker(in);             MessageData dst1 = unpacker.read(MessageData.class);             MessageData dst2 = unpacker.read(MessageData.class);             MessageData dst3 = unpacker.read(MessageData.class);             logger.debug("Check Object for UUID: [{}]", dst1.uuid);             assertEquals(uuid, dst1.uuid);         } catch (Exception ex) {             logger.error("MessagePack Serialization And Deserialization error", ex);         }     } }

https://www.cwiki.us/display/Serialization/QuickStart+For+MessagePack+Java+0.6.X