apache zookeeper使用方法实例详解

本文涉及了Apache Zookeeper使用方法实例详解的相关知识，接下来我们就看看具体内容。

简介

Apache Zookeeper 是由 Apache Hadoop 的 Zookeeper 子项目发展而来，现在已经成为了 Apache 的顶级项目。Zookeeper 为分布式系统提供了高效可靠且易于使用的协同服务，它可以为分布式应用提供相当多的服务，诸如统一命名服务，配置管理，状态同步和组服务等。 Zookeeper 接口简单，开发人员不必过多地纠结在分布式系统编程难于处理的同步和一致性问题上，你可以使用 Zookeeper 提供的现成(off-the-shelf)服务来实现分布式系统的配置管理，组管理，Leader 选举等功能。

英文原文地址：http://zookeeper.apache.org/doc/current/javaExample.html

一个简单的 Zookeeper Watch 客户端

为了介绍 Zookeeper Java API 的基本用法，本文将带你如何一步一步实现一个功能简单的  Zookeeper 客户端。该 Zookeeper 客户端会监视一个你指定 Zookeeper 节点 Znode， 当被监视的节点发生变化时，客户端会启动或者停止某一程序。

基本要求

该客户端具备四个基本要求：

（1）客户端所带参数：

（2）Zookeeper 服务地址。

（3）被监视的 Znode 节点名称。

（4）可执行程序及其所带的参数

客户端会获取被监视 Znode 节点的数据并启动你所指定的可执行程序。如果被监视的 Znode 节点发生改变，客户端重新获取其内容并再次启动你所指定的可执行程序。如果被监视的 Znode 节点消失，客户端会杀死可执行程序。

程序设计

一般而言，Zookeeper 应用程序分为两部分，其中一部分维护与服务器端的连接，另外一部分监视 Znode 节点的数据。在本程序中，Executor 类负责维护 Zookeeper 连接，DataMonitor 类监视 Zookeeper 目录树中的数据， 同时，Executor 包含了主线程和程序主要的执行逻辑，它负责少量的用户交互，以及与可执行程序的交互，该可执行程序接受你向它传入的参数，并且会根据被监视的 Znode 节点的状态变化停止或重启。

Executor类

Executor 对象是本例程最基本的“容器”，它包括Zookeeper 对象和DataMonitor对象。

public static void main(String[] args) {    if (args.length < 4) {      System.err          .println("USAGE: Executor hostPort znode filename program [args ...]");      System.exit(2);    }    String hostPort = args[0];    String znode = args[1];    String filename = args[2];    String exec[] = new String[args.length - 3];    System.arraycopy(args, 3, exec, 0, exec.length);    try {      new Executor(hostPort, znode, filename, exec).run();    } catch (Exception e) {      e.printStackTrace();    }  }  public Executor(String hostPort, String znode, String filename,      String exec[]) throws KeeperException, IOException {    this.filename = filename;    this.exec = exec;    zk = new ZooKeeper(hostPort, 3000, this);    dm = new DataMonitor(zk, znode, null, this);  }  public void run() {    try {      synchronized (this) {        while (!dm.dead) {          wait();        }      }    } catch (InterruptedException e) {    }  }