zoukankan      html  css  js  c++  java
  • 【分布式】Zookeeper客户端基本的使用

      与mysql、redis等软件一样,zookeeper的软件包中也提供了客户端程序用于对服务器上的数据进行操作。本节我们就来学习zookeeper客户端的使用方法。不过在详细讲解zk客户端的使用方法之前,我们会先来讨论zookeeper的数据存储结构,只有理解了zookeeper的数据存储结构,才会真正明白zk操作的真正含义。

    zookeeper数据存储结构

      zookeeper采用树状结构对数据进行存储,整个数据存储结构非常类似于linux的文件系统。如下图所示,节点node_1的路径是/node_1,节点node_1_1的路径是/node_1/node_1_1。zookeeper就是通过对这些节点进行创建、删除、修改、读取等操作来完成系统功能的。

    连接zookeeper服务器

      在zookeeper的bin目录下,名为zkCli.sh的文件就是zookeeper为我们提供的客户端脚本程序。我们可以通过它操作zookeeper服务器上的数据。使用zkCli.sh连接zk服务器的命令格式:./zkCli.sh -timeout 0 -server ip:port。这里的timeout参数是会话超时时间,单位是毫秒,如果在此时间内zk服务器没有收到客户端的心跳包,那么这个会话就失效了。与zk服务器建立连接如下图所示,注意到最后的提示符中有CONNECTED代表已经成功与服务器建立了连接。

      执行h命令可以查看zookeeper支持的操作命令列表。

      这些命令大致可分为增删改查4种类型,下面我们对其进行一一介绍。

    ls查看某个节点的全部子节点

      ls命令用于列出某个节点下的所有子节点信息。

      此处列出了/节点下的全部子节点信息,由于我们还没有创建任何节点,所以只有一个zookeeper节点(由zk自己默认创建)存在。

    create创建一个节点

      create命令用于创建一个新的节点,它的命令格式create [-s] [-e] path data acl。path是节点的路径,data是节点中存储的数据值,acl是节点的权限(权限相关内容将在java api部分讲解)。参数s表示创建一个顺序节点。

      上面的示例连续执行了3次create -s /node_1 123命令,由于加了参数-s,所以zk会自动在创建的节点名字后面增加一个后缀,并且后缀名字是递增的。
      参数e表示创建的是一个临时节点,临时节点只在本会话内有效,登出之后临时节点就会被删除。

    stat查看一个节点的状态信息

      下面例子创建了一个新的/node_1节点,用stat命令查看节点的信息如下:

      在zookeeper中,每次对数据节点的写操作都是一个事务,每个事务都有一个唯一的事务id作为这个事务的标识。
      cZxid就是创建这个节点的事务id。
      ctime是创建这个节点的时间。
      mZxid是最后更新该节点的事务id。
      mtime是节点被最后更新的时间。
      pZxid是节点的子节点列表被最后一次更新的事务id。子节点列表被更新只有两种情况,分别是“增加子节点”和“删除子节点”。修改子节点的数据内容不包括在内。
      cversion是当前节点的子节点的变更版本号。
      dataVersion当前节点存储数据内容的变更版本号。
      aclVersion当前数据节点acl的变更版本号。上面3个版本号均可以用于实现乐观锁。
      ephemeralOwner为创建该临时节点的事务id。如果是持久节点,那么该值固定为0。
      dataLength表示当前节点存储数据内容的长度。
      numChildren表示当前节点包含的子节点个数。

    get命令获取当前节点存储数据的内容

      get命令可以获取一个节点存储的数据内容,同时可以获取该节点的stat信息。

    ls2是ls的超级指令

      ls2除了可以列出当前节点的所有子节点,还能列出当前节点的stat信息。

    set命令修改一个节点中存储的数据

    delete命令删除节点

      delete命令可以用于删除一个节点,但它只能删除没有任何子节点的节点。在下面的例子中,节点/node_1中有一个子节点/node_1/node_1_1。所以不能用delete命令删除节点/node_1。

      以上就是zookeeper客户端提供的比较重要的命令。注意在zookeeper的所有写操作中,都有一个version字段,可以利用这个字段实现乐观锁。

    摘自:https://segmentfault.com/a/1190000012070655

  • 相关阅读:
    java_类承继其他类的内部类例子
    java_接口和抽象类的区别
    java_数组作缓存池的不可变类实例
    C++_归并排序(纯C版)
    C++_归并排序
    C++_快速排序(纯C版本)
    C++_快速排序
    C++_直接插入排序(纯C版)
    C++_直接插入排序
    自定义比较器的用法
  • 原文地址:https://www.cnblogs.com/liuwenlin/p/10176196.html
Copyright © 2011-2022 走看看