序列化与反序列化
zookeeper的客户端与服务端、服务端与服务端之间会进行一系列的网络通信,在进行数据的传输过程中就涉及到序列化与反序列化,zookeeper使用Jute作为它的序列化组件,在使用的时候,需要序列化与反序列化的对象实现Record接口并实现该接口的serialize()
和deserialize()
方法,先看下接口Record:
它只有两个方法,分别是serialize()
和deserialize()
,下面以ReplyHeader
为例看下它的使用。
-
- 实现接口Record:
-
- 创建BinaryOutputArchive
-
- 序列化。上一步中调用BinaryOutputArchive的
writeRecord()
方法,看下源码:
- 序列化。上一步中调用BinaryOutputArchive的
进入writeRecord()
方法调用Record实现类的serialize()
方法进行序列化。
-
- 反序列化。创建BinaryInputArchive,调用Record实现类的
deserialize()
方法进行反序列。
- 反序列化。创建BinaryInputArchive,调用Record实现类的
以上就是Jute进行序列化与反序列化的基本过程。
通信协议
基于TCP/IP协议,zookeeper实现了自己的通信协议,设计上,客户端与服务端、服务端与服务端之间的网络通信数据结构,对于请求,包含数据总长度、请求头与请求体,对于响应,包含数据总长度、响应头与响应体,如下图。
请求协议:
响应协议:
请求头的数据结构
响应头的数据结构
文章来源:https://www.toymoban.com/news/detail-643778.html
对于请求体与响应体,不同的请求体和响应体的数据结构是不同的,可以参考/zookeeper-jute/target/generated-sources/java/org/apache/zookeeper/proto
该目录下的类。
文章来源地址https://www.toymoban.com/news/detail-643778.html
到了这里,关于《Zookeeper》从零开始学Zookeeper源码(二)之数据序列化与通信协议的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!