首页 > 其他 > 详细

zookeeper原理解析-序列化

时间:2017-01-05 11:59:11      阅读:259      评论:0      收藏:0      [点我收藏+]

1)底层通信数据封装与操作

 

         

BinaryInputArchive& BinaryOutputArchive底层通信数据封装与操作

    BinaryInputArchive是对于DataInput的封装,用于处理基于zookeeper协议的底层数据,其实是从DataInputStream输入中读取数据。

    BinaryOutputArchive是对于DataOutput的封装,根据zookeeper协议将数据写入到DataOutputStream中去。

  技术分享

      技术分享

 

 

1.  读取int, boolean基本数据类型直接代理给DataInput执行

 技术分享

 

   写入int, boolean基本数据类型直接代理给DataOutput执行

 技术分享

 

2.   读取String和Buffer是,BinaryInputArchive根据Zookeeper协议做了处理

    1) 读取四个字节int值表示读取数据内容的大小

    2) 根据数据大小构建一个byte数组

    3) 将DataInput的数据读取到字节数组中

技术分享

   

写入String和Buffer是,BinaryOutputArchive根据Zookeeper协议做了处理

1) 写入四个字节int值表示写入数据内容的大小, 如果写入数据为null,值为-1

2)将数据转为字节数组,写入DataOutput中

技术分享技术分享

 

3. 读取复杂的数据对象,Zookeeper底层传输的对象都需要实现Record接口,readRecord方法,会代理给Record进行反序列化

技术分享

 

        写入复杂的数据对象,Zookeeper底层传输的对象都需要实现Record接口writeRecord方法,会代理给Record进行序列化

       

技术分享

 

4.   对于Record对象中持有集合对象(当然能够序列化与反序列化,集合中的元素必须也实现Record):

BinaryInputArchive提供startVector

1)  读取四个字节的int数,表示集合的大小

2)  构建一个BinaryIndex对象返回

       技术分享

       

      BinaryOutputArchive提供startVector

       向DataOutput数据流中写入集合大小,如果为null值为-1

     技术分享

 5.  BinaryInputArchive对象的内部类BinaryIndex作用,主要是用来计数集合对象的反序列话的

  技术分享

 

 

Record是zookeepr底层通信数据序列化与反序列化统一接口,

2)Record接口

     

Record是zookeepr底层通信数据序列化与反序列化统一接口

 

1. 继承结构

技术分享

 

子类以Request结尾的是Client向Server发起请求

子类以Response结尾的是Server向Client发起响应

子类以Txn结尾是Server向Server发起事务请求的

子类以Packet结尾是…???

其他如Id, ACL往往被其他对象持有,不会单独在网络传输

 

2. 举例

 

1)CreateRequest: 用于在客户端创建一个节点时向服务器端发送的请求

技术分享

 

序列化CreateRequest,

archive对象是对DataOutput封装,顺序的将数据写入到DataOutputStream输出流中去

技术分享

 

 

反序列化CreateRequest,

archive对象是对DataInput封装,顺序的从DataInputStream输入流中中读取数据

 

 

      

zookeeper原理解析-序列化

原文:http://www.cnblogs.com/wxd0108/p/6251700.html

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!