Zookeeper的基本操作

写在前面的话：读书破万卷，编码如有神

--------------------------------------------------------------------

参考内容：

　　《私塾在线》，cc老师

--------------------------------------------------------------------

主要内容包括:

• zkCli的操作
• 四字命令
• zookeeper的java客户端操作

--------------------------------------------------------------------

1、zkCli的操作                                                                             

进入zookeeper的安装目录下的bin目录

通过zkCli.sh进行连接

通过help查看有什么命令可以使用

（1）stat path 查看当前path结点的消息

（2）get path 、set path是给当前path节点设置值和获取值

（3）ls path 是列出当前路径有哪些节点

（4）create [-s] [-e] path data acl

通过create可以在path路径上创建一个节点

参数

　　[-s]: 可选，代表一个序列号

　　[-e]: 可选，代表一个临时节点

　　path: 代表节点创建的路径

　　data: 代表该节点的值

　　acl: 代表access control list

（5）delete path [version]

通过delete可以删除path路径上的节点(如果有子节点，则不能删除)

（6）rmr path

通过rmr可以删除path路径上的节点(包括子节点)

---------------------------------------------------------------------------

2、四字命令                                                                                 

　　zookeeper支持某些特定的四字命令，他们大多是用来查询zookeeper服务的当前状态及相关信息的.

（1）conf : 输出相关服务配置的详细信息

（2）cons : 列出所有连接到服务器的客户端的完全的连接 、会话的详细信息。包括"接收/发送"的包数量、会话Id、操作延迟、最后的操作执行等信息

（3）dump : 列出未经处理的会话和临时节点

（4）envi : 输出关于服务环境的详细信息

（5）reqs : 列出未经处理的请求

（6）ruok : 测试服务是否处于正确状态。如果确实如此，那么服务返回"imok",否则不做任何相应

（7）stat : 输出关于性能和连接的客户端的列表

（8）wchs : 列出服务器watch的详细信息

（9）wchc : 通过session列出服务器watch的详细信息，它的输出是一个与watch相关的会话的列表

（10）wchp : 通过路径列出服务器watch的详细信息。它输出一个与session相关的路径 

---------------------------------------------------------------------------

3、zookeeper的java客户端操作

创建一个maven项目，在pom.xml文件中添加zookeeper相关的依赖包:

<dependency>
      <groupId>com.101tec</groupId>
      <artifactId>zkclient</artifactId>
      <version>0.10</version>
</dependency>
<dependency>
      <groupId>org.apache.zookeeper</groupId>
      <artifactId>zookeeper</artifactId>
      <version>3.4.9</version>
</dependency>

zookeeperTest.java

import org.apache.zookeeper.CreateMode;
import org.apache.zookeeper.KeeperException;
import org.apache.zookeeper.ZooDefs;
import org.apache.zookeeper.ZooKeeper;
import org.apache.zookeeper.data.Stat;

import java.io.IOException;


public class zookeeperTest {
    /**
     * 连接到zookeeper服务，并且返回一个实例
     * @param zk  zookeeper引用
     * @param hostPort  ip地址
     * @param sessionTime 超时时间
     * @return zookeeper的实例
     */
    private ZooKeeper startZK(ZooKeeper zk,String hostPort,int sessionTime){
        try {
            zk = new ZooKeeper(hostPort,sessionTime,null);
        } catch (IOException e) {
            e.printStackTrace();
        }
        return zk;
    }

    /**
     * 关闭zookeeper的连接
     * @param zk zookeeper实例
     */
    private void stopZK(ZooKeeper zk){
        try {
            zk.close();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }

    /**
     * 在zookeeper上创建一个节点
     * @param zk zookeeper实例
     * @param nodePath 要创建的节点path
     * @param nodeData 要创建的节点data
     * @param cm 创建节点的Mode
     */
    private void createNode(ZooKeeper zk, String nodePath, String nodeData, CreateMode cm){
        try {
            zk.create(nodePath,nodeData.getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE,cm);
        } catch (KeeperException e) {
            e.printStackTrace();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }

    /**
     * 获取zookeeper的path节点的值
     * @param zk zookeeper实例
     * @param nodePath 节点的值
     * @return zookeeper的path节点的值
     */
    private  String getNode(ZooKeeper zk,String nodePath){
        byte[] rets = null;
        try {
            rets = zk.getData(nodePath, false, new Stat());
        } catch (KeeperException e) {
            e.printStackTrace();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        return new String(rets);
    }

    public static void main(String[] args) {
        zookeeperTest zkt = new zookeeperTest();

        //zookeeper实例的引用
        ZooKeeper zooKeeper = null;

        //创建一个zookeeper实例
        zooKeeper = zkt.startZK(zooKeeper, "127.0.0.1:2181", 20000);

        //创建一个节点
        zkt.createNode(zooKeeper,"/zkTest","zkDatas",CreateMode.PERSISTENT);

        //获取指定路径上的节点的值
        String result = zkt.getNode(zooKeeper,"/zkTest");

        System.out.println("result = " + result);

        zkt.stopZK(zooKeeper);
    }
}

查看