序列化：
概述：
对于一个网络通信，首先需要解决的就是对数据的序列化和反序列化处理，在ZooKeeper中，使用了Jute这一序列化组件来进行数据的序列化和反序列化操作。同时，为了实现一个高效的网络通信程序，良好的通信协议设计也是至关重要的。Zookeeper团队曾想过将Jute替换成Apache的Avro或是Google的protobuf但是考虑到新老版本序列化组件的兼容性和当前Jute的序列化能力并不是ZooKeeper的性能瓶颈。
使用Jute进行序列化：
package com.tianlh.zookeeper.jute; import java.io.ByteArrayOutputStream; import java.io.IOException; import java.nio.ByteBuffer; import lombok.Getter; import lombok.Setter; import org.apache.jute.BinaryInputArchive; import org.apache.jute.BinaryOutputArchive; import org.apache.jute.InputArchive; import org.apache.jute.OutputArchive; import org.apache.jute.Record; import org.apache.zookeeper.server.ByteBufferInputStream; / * @author 黑子 * @Date 2018/1/15 10:50 */ @Getter @Setter public class MocHeader implements Record {
private long sessionId; private String type; public MocHeader(){} public MocHeader(long sessionId, String type){ this.sessionId = sessionId; this.type = type; } @Override public void serialize(OutputArchive outputArchive, String tag) throws IOException { outputArchive.startRecord(this, tag); outputArchive.writeLong(sessionId,"sessionId"); outputArchive.writeString(type, "type"); outputArchive.endRecord(this, tag); } @Override public void deserialize(InputArchive inputArchive, String tag) throws IOException { inputArchive.startRecord(tag); sessionId = inputArchive.readLong("sessionId"); type = inputArchive.readString("type"); inputArchive.endRecord(tag); } public static void main(String[] args) throws IOException { final String tag = "header"; // 序列化 ByteArrayOutputStream baos = new ByteArrayOutputStream() ; BinaryOutputArchive boa = BinaryOutputArchive.getArchive(baos); new MocHeader(L, "MyHeader").serialize(boa, tag); // 包装成ByteBuffer 用于网络传输 ByteBuffer bb = ByteBuffer.wrap(baos.toByteArray()); // 反序列化 ByteBufferInputStream bbis = new ByteBufferInputStream(bb); BinaryInputArchive bbia = BinaryInputArchive.getArchive(bbis); MocHeader header = new MocHeader(); header.deserialize(bbia, tag); baos.close(); bbis.close(); } } 通信协议：
概述：
基于TCP/IP协议，ZooKeeper实现了自己的通信协议来完成客户端与服务端、服务端与服务端之间的网络通信。ZooKeeper通信协议整体上的设计非常简单，对于请求，主要
包含请求头和请求体，而对于晌应，则主要包含响应头和响应体，
请求：
协议的请求头组成如下：
xid用于记录客户端请求发起的先后序号，用来确保单个客户端请求的响应顺序。type代表请求的操作类型，常见的包括创建节点、删除节点和获取节点数据等。
协议的请求体部分是指请求的主体内容部分，包含了请求的所有操作内容。不同的请求类型，其请求体部分的结构是不同的。
响应：
协议的响应头中的xid和上文中提到的请求头中的xid是一致的，响应中只是将请求中的xid原值返回。zxid代表ZooKeeper服务器上当前最新的事务ID。err则是一个错误码，当请求处理过程中出现异常情况时，会在这个错误码中标识出来，常见的包括处理成功（Code.OK:0）、节点不存在（Code.NONODE:101）和没有权限（Code.NOAUTH:102）等，
协议的响应体部分是指响应的主体内容部分，包含了响应的所有返回数据。不同的响应类型，其响应体部分的结构是不同的
发布者：全栈程序员-站长，转载请注明出处：https://javaforall.net/223580.html原文链接：https://javaforall.net
