PROSAGA码农传奇-zookeeper-Zookeeper通信协议

抱歉，但是我不知道任何方便的文档来详细描述Apache ZooKeeper有线协议。在内部，我们的代码库使用名为Jute的框架，该框架基于最初从Apache Hadoop改编的代码。该框架允许定义结构化记录，根据这些定义生成代码，然后提供由ZooKeeper代码其余部分调用的序列化/反序列化例程。

黄麻记录定义在此处可见：

https://github.com/apache/zookeeper/blob/release-3.4.9/src/zookeeper.jute

在这里可以看到用于处理这些记录定义的Jute框架代码：

https://github.com/apache/zookeeper/tree/release-3.4.9/src/java/main/org/apache/jute

我认为，要深入了解有线协议，唯一的选择就是深入研究这段代码。

在挖掘了几层原始套接字处理代码（根据配置使用NIO或Netty）之后，反序列化有效负载的实际工作发生在ZooKeeperServer#processPacket(ServerCnxn, ByteBuffer)：

https://github.com/apache/zookeeper/blob/release-3.4.9/src/java/main/org/apache/zookeeper/server/ZooKeeperServer.java#L941

它在此处反序列化a RequestHeader，它是所有协议消息开头的元数据的通用标头。的定义RequestHeader如下所示：

https://github.com/apache/zookeeper/blob/release-3.4.9/src/zookeeper.jute#L88-L91

我们可以看到它由2个4字节整数字段组成：一个连接ID，后跟消息的类型。类型值在ZooDefs这里定义：

https://github.com/apache/zookeeper/blob/release-3.4.9/src/java/main/org/apache/zookeeper/ZooDefs.java#L28

知道了所有这些之后，让我们回到您的数据包捕获并尝试理解它：

Data: 00000008fffffffe0000000b
```
00000008 - payload length
fffffffe - connection ID
0000000b - op code ("ping")
```
在每个消息的开头（甚至在之前RequestHeader），都有有效载荷的长度。在这里，我们看到了8个字节的长度。

接下来的4个字节是连接ID fffffffe。

最后的4个字节是操作码0000000b（或十进制的11个）。阅读ZooDefs，我们可以看到这是“ ping”操作。“ ping”操作用于客户端和服务器之间的定期心跳。有效负载中不需要用于“ ping”操作的其他数据，因此这是此数据包的结尾，并且在此数据包之后也没有其他数据。对于不同的操作，有效负载中将存在其他数据，这些数据代表该操作的参数。

我希望这有帮助。