摘要：就是上面提到的變化后執(zhí)行的程序。這段代碼是的構(gòu)造函數(shù)，除了里面的一些賦值函數(shù)，重點(diǎn)說下這個(gè)函數(shù)它有個(gè)參數(shù)，第一個(gè)參數(shù)是你要的名字，類似這樣的。

昨晚微信開放了JS接口。忙活了一晚上。
然后周六就沒啥斗志了，突然想起第二篇說好要介紹demo的沒介紹，就趕緊來寫了。

先來個(gè) 傳送門

這里簡單介紹了下官方demo。用來演示Zookeeper官方推薦的程序框架（Executor、DataMonitor）。

這個(gè)Demo實(shí)現(xiàn)了如下功能：

監(jiān)視一個(gè)結(jié)點(diǎn)，獲取該結(jié)點(diǎn)的數(shù)據(jù)，并啟動(dòng)一個(gè)自定義程序

如果這個(gè)結(jié)點(diǎn)發(fā)生變化了（數(shù)據(jù)更改，新增或者刪除），則停止這個(gè)自定義程序并重新執(zhí)行。

如果這個(gè)結(jié)點(diǎn)被刪除了，則停止運(yùn)行自定義程序

對著Demo看下代碼。首先，官方有這么個(gè)章節(jié)

  Program Design
  
  
Conventionally, ZooKeeper applications are broken into two units, one which maintains the connection, and the other which monitors data. In this application, the class called the Executor maintains the ZooKeeper connection, and the class called the DataMonitor monitors the data in the ZooKeeper tree. Also, Executor contains the main thread and contains the execution logic. It is responsible for what little user interaction there is, as well as interaction with the exectuable program you pass in as an argument and which the sample (per the requirements) shuts down and restarts, according to the state of the znode.

通俗翻譯下，官方認(rèn)為，一個(gè)zookeeper應(yīng)用簡單地分為兩個(gè)單元即可，一個(gè)用來管理連接，另一個(gè)用來監(jiān)視數(shù)據(jù)。在我們的Demo中，Executor被用來管理和Zookeeper的連接，DataMonitor用來監(jiān)視Zookeeper中的數(shù)據(jù)樹。另外，Executor同時(shí)也包含了主線程的執(zhí)行（也就是Main函數(shù)），然后也包含一點(diǎn)點(diǎn)的執(zhí)行邏輯。Demo對用戶交互的部分非常少，輸入的幾個(gè)參數(shù)（好吧，我自己去實(shí)現(xiàn)的時(shí)候，偷懶去寫死了）就可以開始跑了，Demo還會對znode的變化或者新的znode的連入進(jìn)行一些響應(yīng)。

看完這段，對原文最下面的完整樣例算了解一些，那這里既然就兩個(gè)類，Executor和DataMonitor嘛，對吧。就分別看下。

javapublic 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);
}

javapublic void process(WatchedEvent event);

javapublic DataMonitor(ZooKeeper zk, String znode, Watcher chainedWatcher,
                       DataMonitorListener listener) {
    this.zk = zk;
    this.znode = znode;
    this.chainedWatcher = chainedWatcher;
    this.listener = listener;
    // Get things started by checking if the node exists. We are going
    // to be completely event driven
    zk.exists(znode, true, this, null);
}

java public void processResult(int rc, String path, Object ctx, Stat stat) {
        boolean exists;
        switch (rc) {
            case Code.Ok:
                exists = true;
                break;
            case Code.NoNode:
                exists = false;
                break;
            case Code.SessionExpired:
            case Code.NoAuth:
                dead = true;
                listener.closing(rc);
                return;
            default:
                // Retry errors
                zk.exists(znode, true, this, null);
                return;
        }

        byte b[] = null;
        if (exists) {
            try {
                b = zk.getData(znode, false, null);
            } catch (KeeperException e) {
                // We don"t need to worry about recovering now. The watch
                // callbacks will kick off any exception handling
                e.printStackTrace();
            } catch (InterruptedException e) {
                return;
            }
        }
        if ((b == null && b != prevData)
                || (b != null && !Arrays.equals(prevData, b))) {
            listener.exists(b);
            prevData = b;
        }
    }

java/**
     * Return the stat of the node of the given path. Return null if no such a
     * node exists.
     * 

     * If the watch is non-null and the call is successful (no exception is thrown),
     * a watch will be left on the node with the given path. The watch will be
     * triggered by a successful operation that creates/delete the node or sets
     * the data on the node.
     *
     * @param path the node path
     * @param watcher explicit watcher
     * @return the stat of the node of the given path; return null if no such a
     *         node exists.
     * @throws KeeperException If the server signals an error
     * @throws InterruptedException If the server transaction is interrupted.
     * @throws IllegalArgumentException if an invalid path is specified
     */
    public Stat exists(final String path, Watcher watcher)
        throws KeeperException, InterruptedException;

javapublic void process(WatchedEvent event) {
    dm.process(event);
}

javapublic void process(WatchedEvent event) {
    String path = event.getPath();
    if (event.getType() == Event.EventType.None) {
        // We are are being told that the state of the
        // connection has changed
        switch (event.getState()) {
            case SyncConnected:
                logger.debug("SyncConnected");
                // In this particular example we don"t need to do anything
                // here - watches are automatically re-registered with
                // server and any watches triggered while the client was
                // disconnected will be delivered (in order of course)
                break;
            case Expired:
                logger.debug("expired");
                // It"s all over
                dead = true;
                listener.closing(Code.SESSIONEXPIRED.intValue());
                break;
        }
    } else {
        if (path != null && path.equals(znode)) {
            // Something has changed on the node, let"s find out
            zk.exists(znode, true, this, null);
        }
    }
    if (chainedWatcher != null) {
        chainedWatcher.process(event);
    }
}

java public void exists(byte[] data) {
    if (data == null) {
        if (child != null) {
            System.out.println("Killing process");
            child.destroy();
            try {
                child.waitFor();
            } catch (InterruptedException e) {
            }
        }
        child = null;
    } else {
        if (child != null) {
            System.out.println("Stopping child");
            child.destroy();
            try {
                child.waitFor();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        try {
            FileOutputStream fos = new FileOutputStream(filename);
            fos.write(data);
            fos.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
        try {
            System.out.println("Starting child");
            child = Runtime.getRuntime().exec(exec);
            new StreamWriter(child.getInputStream(), System.out);
            new StreamWriter(child.getErrorStream(), System.err);
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}