zookeeper watches

  Watches

所有的讀操作（getData(),getChildren(),exists()）都可以設置一個watch作為附加的操作

Watch的關鍵特性有

• 只觸發一次（one-timetrigger）

Watch當數據變化時，只會被觸發一次，之后就會被移除，當數據再次變化時，不會再觸發此watch

• 發送到客戶端（sentto the client）

通知客戶端是異步的，客戶端只會在它收到watch event時才會知道znode改變.通知客戶端的過程可能會發生異常，或者網絡延遲，但zookeeper會保證通知的一致性

• Watch為那些數據znode設置（the data for which the watch was set）

getData(),exists()設置數據監控，getChildren()設置孩子監控，

setData()會觸發數據監控，成功create（）會觸發創建的znode數據監控和父zonde的孩子監控，成功的delete()zonde的數據監控和孩子監控、還有父zonde的孩子監控

  Zookeeper 對watches一些保證

• Zookeeper客戶端保證所有的事情都是有序的（events,watches,異步回復）

• 客戶端先看到監聽的事件，先于所監聽的znode新的數據

• 監聽事件的順序對應zookeeper服務發生的更新時間順序

    關于監聽器必須注意的

• 監聽器只觸發一次

• 因為監聽是一次性的，并且在獲取事件通知和發送新的請求設置監聽器之間有延遲，所以不能完全相信每個事件的變化就是zonde當前的狀態，有可能發生了多次變化之后你才收到監聽事件的回復

• 同一個監聽對象只會被一個通知事件觸發，比如同一個監聽對象被注冊到一個exists和

GetDate，當刪除這個節點的時候，監聽對象只會被刪除事件觸發一次

• 當和服務器斷開后，客戶端不會獲得任何監聽器，直到重建連接，

以下是我根據官網例子簡化的實例，大家可以動手實踐以下，理解一下zookeeper的監聽器的操作

package personal.zk;

import lombok.extern.slf4j.Slf4j;
import org.apache.zookeeper.*;
import org.apache.zookeeper.data.Stat;

import java.io.IOException;

/**
 * comments()
 *
 * @author:czh ,mail:453775810@qq.com
 * @date 2015/11/4
 */
@Slf4j
public class Executor implementsWatcher,Runnable,AsyncCallback.StatCallback {
    Integer mutex=0;
    String znode;

    ZooKeeper zk;

    String filename;

    String exec[];


    public Executor(StringhostPort, String znode) throws KeeperException, IOException,InterruptedException {
        this.znode=znode;
        zk = new ZooKeeper(hostPort, 3000, this);
        zk.exists(znode,true, this, null);
    }

    /**
     * @param args
     */
    public static void main(String[] args) {
        String hostPort ="192.168.83.3:2181";
//       String hostPort="172.26.7.23:2181";
        String znode = "/dubbo";
        try {
            new Executor(hostPort,znode).run();
        } catch (Exceptione) {
            e.printStackTrace();
        }
    }

    /***************************************************************************
     * We do process any eventsourselves, we just need to forward them on.
     *
//     * @seeorg.apache.zookeeper.Watcher#process(org.apache.zookeeper.proto.WatcherEvent)
     */
    public void process(WatchedEventevent) {
        log.info("event.getPath():" + event.getPath() + "event.getState():" + event.getState() + "event.getType():" + event.getType());
    }

    public void run(){
        try {
            synchronized (mutex) {
                while (true) {
                    mutex.wait();
                }
            }
        } catch (InterruptedExceptione) {
            e.printStackTrace();
        }
    }

    /**
     * @param rc
     * @param path
     * @param ctx
     * @param stat
     */
    @Override
    public void proce***esult(int rc, String path, Object ctx, Stat stat) {
        log.info("proce***esult===========begin");
        boolean exists;
        log.info(String.valueOf(rc));
        switch (rc) {
            case KeeperException.Code.Ok:
                log.info("監聽器設置成功");
                break;
            case KeeperException.Code.NoNode:
                log.info("znode["+znode+"]不存在");
                break;
            case KeeperException.Code.SessionExpired:
            case KeeperException.Code.NoAuth:
                return;
            default:
                // Retry errors
                zk.exists(znode, true, this, null);
                return;
        }
        log.info("proce***esult===========end");
    }
}