Thrift序列化和反序列化处理代码(java版)
2012-07-02 15:20
447 查看
好多网上介绍的thrift都是基于rpc的服务端客户端的例子,看了下c++版本的序列化处理,摸索了一下,找到序列化、反序列化的处理方法,记录一下。
// 内存级缓冲,默认32长度,自动增加
TMemoryBuffer mb0 = new TMemoryBuffer(32);
TProtocol prot0 = new org.apache.thrift.protocol.TCompactProtocol(mb0);
TMemoryBuffer mb1 = new TMemoryBuffer(32);
TProtocol prot1 = new org.apache.thrift.protocol.TBinaryProtocol(mb1);
TMemoryBuffer mb2 = new TMemoryBuffer(32);
TProtocol prot2 = new org.apache.thrift.protocol.TJSONProtocol(mb2);
// 传输消息对象
RequestMessage msg = new RequestMessage();
msg.setMessage("abcdefghjklfadfadfadfadloiue");
msg.setKey("key");
// 序列化处理
msg.write(prot0);
msg.write(prot1);
msg.write(prot2);
System.out.println("序列化长度Compact:" + mb0.length());
System.out.println("序列化长度Binary:" + mb1.length());
System.out.println("序列化长度JSON:" + mb2.length());
// 反序列化处理
byte[] data = mb1.getArray(); // 接收的字节
RequestMessage msg1 = new RequestMessage();
TMemoryBuffer tmb = new TMemoryBuffer(32);
tmb.write(data);
TProtocol tp = new org.apache.thrift.protocol.TBinaryProtocol(tmb);
msg1.read(tp);
System.out.println(msg1.getMessage());
执行:
序列化长度Compact:36
序列化长度Binary:46
序列化长度JSON:62
abcdefghjklfadfadfadfadloiue
// 内存级缓冲,默认32长度,自动增加
TMemoryBuffer mb0 = new TMemoryBuffer(32);
TProtocol prot0 = new org.apache.thrift.protocol.TCompactProtocol(mb0);
TMemoryBuffer mb1 = new TMemoryBuffer(32);
TProtocol prot1 = new org.apache.thrift.protocol.TBinaryProtocol(mb1);
TMemoryBuffer mb2 = new TMemoryBuffer(32);
TProtocol prot2 = new org.apache.thrift.protocol.TJSONProtocol(mb2);
// 传输消息对象
RequestMessage msg = new RequestMessage();
msg.setMessage("abcdefghjklfadfadfadfadloiue");
msg.setKey("key");
// 序列化处理
msg.write(prot0);
msg.write(prot1);
msg.write(prot2);
System.out.println("序列化长度Compact:" + mb0.length());
System.out.println("序列化长度Binary:" + mb1.length());
System.out.println("序列化长度JSON:" + mb2.length());
// 反序列化处理
byte[] data = mb1.getArray(); // 接收的字节
RequestMessage msg1 = new RequestMessage();
TMemoryBuffer tmb = new TMemoryBuffer(32);
tmb.write(data);
TProtocol tp = new org.apache.thrift.protocol.TBinaryProtocol(tmb);
msg1.read(tp);
System.out.println(msg1.getMessage());
执行:
序列化长度Compact:36
序列化长度Binary:46
序列化长度JSON:62
abcdefghjklfadfadfadfadloiue
相关文章推荐
- Java的基本的序列化和反序列化的案例代码
- Java 序列化 反序列化 历史版本处理
- java 序列化和反序列化代码示例
- IO_对象处理流_序列化反序列化_关闭流jdk1.7try-with-resourceJAVA159-160
- java序列化和反序列化
- java 序列化 反序列化 简单实现
- java中如何处理异常代码示例
- Java序列化和反序列化
- java对象与字符串之间的序列化和反序列化
- java对象表示方式:序列化和反序列化
- java 的序列化和反序列化
- 【语音处理】wav转pcm mp3转pcm Java示例代码
- Rhythmk 一步一步学 JAVA(3): java JSON 数据序列化 以及反序列化
- java序列化,反序列化及反序列如何判断是否已读到文件末尾
- java序列化/反序列化之xstream、protobuf、protostuff 的比较与使用例子
- Java对象的序列化和反序列化
- Java基础学习总结——Java对象的序列化和反序列化
- jackson中自定义处理序列化和反序列化
- Java对象的序列化和反序列化
- java 序列化 与 反序列化