码迷,mamicode.com
首页 > 其他好文 > 详细

zookeeer client 通信协议

时间:2016-07-15 19:21:02      阅读:115      评论:0      收藏:0      [点我收藏+]

标签:

这里主要记录zookeeper client通信协议的.在官方的文档里没找到协议相关部分.这里是记录的协议是通过分析客户端代码得来的.

一.通信流程

      客户端发起连接,发送握手包进行timeout协商,协商成功后会返回一个session id和timeoout值.随后就可以进行正常通信,通信过程中要在timeout范围内发送ping包. 

        zookeeper client和server之间的通信协议基本规则就是发送请求获取响应.并根据响应做不同的动作.

       发送数据格式为:

                   消息长度+xid+request. xid每次请求必须是唯一的.消息长度和xid同为4字节,命令长度为4字节且必须为request的开始4字节.

                   命令是从1到11的数字表示,close的命令为-11.不同类型请求request有些差异.详细在第二部分. 

                   特殊请求具有固定的xid:watch_xid固定为-1,ping_xid为-2,auth_xid固定为-4.普通请求一般从0开始每次请求累加一次xid.

       响应数据为:

                   消息长度+header+response.消息长度为4字节,表明header+response的总长度.

                   header为xid,zxid,err对应长度为4,8,4.response根据请求类型不同具有差别.详细在第二部分

                   根据header里xid的区别分为watch,ping,auth,data这四种类型

                   根据这四种类型来区分返回消息是事件,还是认证,心跳和请求数据.client并以此作出不同响应.

二.各命令request

1.首先是握手connect,

  request:

      protocol version+zxid+timeout+session id+passwd len+passwd+read only.对应的字节长度为4,8,4,8,4,16,1

         取值除timeout外其他几个皆可为0,password可以为任意16个字符.read_only为0或1(是布尔值).

                握手包没有xid和命令

  response:

                   protocol version,timeout,session_id,passwd len,passwd,read only.

                握手响应包没有header.

2.ping

  request:

                     type (ping包只有一个字段就是命令值是11,它完整的发送包是4字节长度,4字节xid,4字节命令.)

  response:

      res_len+header+res (ping响应包一般只拆到header即可通过xid确认)

3.create

        request:

      type+path_len+path+data_len+data+acl_len+acl+flags

      type=1,4字节

      path_len是4字节,为path的长度,path为需要创建的路径,支持utf8

      data_len为4字节,为data的长度,data为节点的值,支持utf8

      acl_len,4字节.表明acl的长度.

      acl,详见acl描述部分.

      flags为4字节.

   response:

      data_len+data (无特殊情况即不再将res_len和header写出来,下面各请求也将如此.如没有将表明)

      data_len为4字节,data可以使用utf8

4.delete

   request:

      type+path_len+path+protocol version

      type=2

      path_len,path同create request

      protocol version 4字节,为-1则不进行版本检查.否则版本不同则删除失败

   response:

      只返回res_len+header.不返回res_data.

5.exists

   request:

      type+path_len+path+watcher

      type=3

      path_len,path同create request

      watcher为布尔值.判断是否有事件注册.为1或0. 1字节

   response:

      stat

      stat由8,8,8,8,4,4,4,8,4,4,8字节顺序组成.

 6.getdata

   request:

       type+path_len+path+watcher

       type=4.其他字段同exists request

   response:

       data_len+data+stat

       data_len为data长度,4字节.

       stat同exists response

7.setdata

   request:

       type+path_len+path+data_len+data+protocol version

       type=4,

       path,data字段同create request

       protocol version 字段同delete request.-1为不考虑版本.

   response:

       stat

       同exists response 

 

 

 

ACL:

   acl分两部分.一部分是标志.一部分是数据和id

   标志:

      all,read,write,create,delete,admin

      all=31,read=1,write=2,create=4,delete=8,admin=16 均为4字节

      若想表示其中某几项则使用对应项的值的和即可

   数据和id:

      数据和id都是字符串可以使用utf8,均为长度加字符.长度为4字节

   ACL完整标识:

      acl_标志+data_len+data+id_len+id

zookeeer client 通信协议

标签:

原文地址:http://www.cnblogs.com/cloud-zhao/p/5673790.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!