8.使用Exists监控ZNode的三大Change事件

一、 zookeeper是一个分布式的协调程序（所有程序都是通过订阅它来相互感知）

 　　

1. tcp（长链接） + watcher

server -》client

client -》server

 

2. Driver 中的方法 exists() 监控一个znode的 CURD 的操作。

client1 client2 同时订阅 baidu节点

通过对baidu节点的CURD操作，exists就会监控到，从而通知客户端

 

接下来是C#代码的实现

 

1. 实现接口 IWatcher

    public class ExistsWatcher : IWatcher
    {
        private ZooKeeper _zookeeper = null; 
        public ExistsWatcher(ZooKeeper zookeeper)
        {
            _zookeeper = zookeeper;
        }

        public void Process(WatchedEvent @event)
        {
            Console.WriteLine("path={0},state={1},type={2}", @event.Path, @event.State, @event.Type);
            //重新注册 exists
            _zookeeper.Exists(@event.Path, this);
        }
    }

2. 注册zookeeper  ZookeeperWatcher的实现看 上一节课代码

 　　　　　　ZooKeeper zookeeper = new ZooKeeper("192.168.84.136:2181", TimeSpan.FromSeconds(5),new ZookeeperWatcher());

            //通过wait函数，等待ZookeeperWatcher 回调函数执行成功
            ZookeeperWatcher.countdownEvent.Wait();
            var list = zookeeper.GetChildren("/", false);
            #region 第8节try
            {
                Stat stat = new Stat();
                stat = zookeeper.Exists("/google", new ExistsWatcher(zookeeper));
            }
            catch (KeeperException ex)
            {
                throw new Exception(ex.Message);
            }
            #endregion

注意：

client -》server watcher 监控是一次性的，

client 需要在wathcer接收到通知后，从新注册exists

 

 

执行了一次创建，一次删除，客户端都收到了通知

 

 

 

3. exists可以监控那些事件

NodeDeleted,NodeCreated,NodeDataChanged

 

4. exists 应用场景

master -》 backup 双机热备

【临时节点】

 

zookeeper本质就是一个协调程序。