1)底层通信数据封装与操作
BinaryInputArchive& BinaryOutputArchive底层通信数据封装与操作
BinaryInputArchive是对于DataInput的封装,用于处理基于zookeeper协议的底层数据,其实是从DataInputStream输入中读取数据。
BinaryOutputArchive是对于DataOutput的封装,根据zookeeper协议将数据写入到DataOutputStream中去。
![](http://img.blog.csdn.net/20150511195645479?watermark/2/text/aHR0cDovL2Jsb2cuY3Nkbi5uZXQvcXVob25nd2VpX3poYW5xaXU=/font/5a6L5L2T/fontsize/400/fill/I0JBQkFCMA==/dissolve/70/gravity/Center)
![](http://img.blog.csdn.net/20150511195658770?watermark/2/text/aHR0cDovL2Jsb2cuY3Nkbi5uZXQvcXVob25nd2VpX3poYW5xaXU=/font/5a6L5L2T/fontsize/400/fill/I0JBQkFCMA==/dissolve/70/gravity/Center)
1. 读取int, boolean基本数据类型直接代理给DataInput执行
![](http://img.blog.csdn.net/20150511195604230?watermark/2/text/aHR0cDovL2Jsb2cuY3Nkbi5uZXQvcXVob25nd2VpX3poYW5xaXU=/font/5a6L5L2T/fontsize/400/fill/I0JBQkFCMA==/dissolve/70/gravity/Center)
写入int, boolean基本数据类型直接代理给DataOutput执行
![](http://img.blog.csdn.net/20150511195831635?watermark/2/text/aHR0cDovL2Jsb2cuY3Nkbi5uZXQvcXVob25nd2VpX3poYW5xaXU=/font/5a6L5L2T/fontsize/400/fill/I0JBQkFCMA==/dissolve/70/gravity/Center)
2. 读取String和Buffer是,BinaryInputArchive根据Zookeeper协议做了处理
1) 读取四个字节int值表示读取数据内容的大小
2) 根据数据大小构建一个byte数组
3) 将DataInput的数据读取到字节数组中
![](http://img.blog.csdn.net/20150511195947466?watermark/2/text/aHR0cDovL2Jsb2cuY3Nkbi5uZXQvcXVob25nd2VpX3poYW5xaXU=/font/5a6L5L2T/fontsize/400/fill/I0JBQkFCMA==/dissolve/70/gravity/Center)
写入String和Buffer是,BinaryOutputArchive根据Zookeeper协议做了处理
1) 写入四个字节int值表示写入数据内容的大小, 如果写入数据为null,值为-1
2)将数据转为字节数组,写入DataOutput中
![](http://img.blog.csdn.net/20150511200059211?watermark/2/text/aHR0cDovL2Jsb2cuY3Nkbi5uZXQvcXVob25nd2VpX3poYW5xaXU=/font/5a6L5L2T/fontsize/400/fill/I0JBQkFCMA==/dissolve/70/gravity/Center) ![](http://img.blog.csdn.net/20150511200258897?watermark/2/text/aHR0cDovL2Jsb2cuY3Nkbi5uZXQvcXVob25nd2VpX3poYW5xaXU=/font/5a6L5L2T/fontsize/400/fill/I0JBQkFCMA==/dissolve/70/gravity/Center)
3. 读取复杂的数据对象,Zookeeper底层传输的对象都需要实现Record接口,readRecord方法,会代理给Record进行反序列化
![](http://img.blog.csdn.net/20150511200501638?watermark/2/text/aHR0cDovL2Jsb2cuY3Nkbi5uZXQvcXVob25nd2VpX3poYW5xaXU=/font/5a6L5L2T/fontsize/400/fill/I0JBQkFCMA==/dissolve/70/gravity/Center)
写入复杂的数据对象,Zookeeper底层传输的对象都需要实现Record接口writeRecord方法,会代理给Record进行序列化
![](http://img.blog.csdn.net/20150511201126114?watermark/2/text/aHR0cDovL2Jsb2cuY3Nkbi5uZXQvcXVob25nd2VpX3poYW5xaXU=/font/5a6L5L2T/fontsize/400/fill/I0JBQkFCMA==/dissolve/70/gravity/Center)
4. 对于Record对象中持有集合对象(当然能够序列化与反序列化,集合中的元素必须也实现Record):
BinaryInputArchive提供startVector
1) 读取四个字节的int数,表示集合的大小
2) 构建一个BinaryIndex对象返回
![](http://img.blog.csdn.net/20150511201302600?watermark/2/text/aHR0cDovL2Jsb2cuY3Nkbi5uZXQvcXVob25nd2VpX3poYW5xaXU=/font/5a6L5L2T/fontsize/400/fill/I0JBQkFCMA==/dissolve/70/gravity/Center)
BinaryOutputArchive提供startVector
向DataOutput数据流中写入集合大小,如果为null值为-1
![](http://img.blog.csdn.net/20150511201645543?watermark/2/text/aHR0cDovL2Jsb2cuY3Nkbi5uZXQvcXVob25nd2VpX3poYW5xaXU=/font/5a6L5L2T/fontsize/400/fill/I0JBQkFCMA==/dissolve/70/gravity/Center)
5. BinaryInputArchive对象的内部类BinaryIndex作用,主要是用来计数集合对象的反序列话的
![](http://img.blog.csdn.net/20150511201741313?watermark/2/text/aHR0cDovL2Jsb2cuY3Nkbi5uZXQvcXVob25nd2VpX3poYW5xaXU=/font/5a6L5L2T/fontsize/400/fill/I0JBQkFCMA==/dissolve/70/gravity/Center)
Record是zookeepr底层通信数据序列化与反序列化统一接口, |