ZooKeeper源码解析(10)Watcher实现

我们知道，ZooKeeper有一个非常重要的功能，就是做分布式锁．而这个分布式锁，就是通过ZooKeeper的Watcher来实现的．

在这篇文章中，我们将会介绍，在ZooKeeper中，Watcher到底是如何实现的．

ZooKeeper Watch介绍

在ZooKeeper中，有三个读操作:getData(), getChildren(), exists()，都接受一个叫做Watch参数．

在ZooKeeper中，有两种Watch，分别是data watches和child watches，getData()和exists()会设置data watches，而getChildren()会设置child watches．

Watch是由服务器端维护的一个集合，它会为每个客户端维护这么一个集合．

setData()会触发对应的znode上的data watches，create()会触发对应znode的data watches以及它的父节点的child watches，delete()会触发对应znode的data watches以及child watches，以及其父节点的child watches．

Watches只会被触发一次．

更多关于Watch的介绍，请到这里

ZooKeeper中Watch的实现

在ZooKeeper中，有一个Watcher接口：

这个Watcher接口中，定义了一个方法:process(WatchedEvent event)．

就是这个方法，定义了当事件被触发时，要进行的操作．

而实现Watcher接口的类，有三个，都是我们很熟悉的：

• ServerCnxn
• NIOServerCnxn
• NettyServerCnxn

我们这里主要看一下NIOServerCnxn中的实现：

我们可以看到，其process(WatchEvent event)方法，就是将WatchEvent发送给客户端．

ZooKeeper中Watch的原理

在之前的文章中，我们介绍请求处理的时候，提到了有一个生产链似的请求处理方式，其中最后的一个RequestProcessor就是FinalRequestProcessor，而正是在这个FinalRequestProcessor中，设置了Watch．

我们来看一下FinalRequestProcessor中的processRequest(Request request)部分的实现．

从这个方法中，我们可以这个一段代码块：

我们可以看到，其中调用了ZKDatabase的getData()方法来设置获取数据．并且最后有一个关于Watch的参数．

而我们上面正好介绍过，在使用getData()时，可以设置Watch．

我们跟进去，可以发现它最后就是调用了DataTree的getData()方法．

我们可以看到，这儿只不过是记录了一下这个Watch．

这里读者们可能就有一个疑问，就是，之前我们说过，ZooKeeper为每一个客户端维护一个Watch集合，但是这里我们只看到直接就放到了DataTree这一个共享的数据结构里了呀．

这是为什么呢？

因为Watch的实现NIOServerCnxn天生就是客户端独立的呀．

那Watch是怎么被消费掉，怎么被触发的呢？

我们回到FinalRequestProcessor的processRequest()方法，可以看到这么一段代码：

其中，最重要的就是图中我们圈出来的那一行．

我们看一下在zks.processTxn()的实现．

其中这个方法中，最重要的还是我们圈出来的那一行．

我们再跟进去，发现它调用了DataTree的processTxn()方法．我们直接来看这个方法的实现．

我们只分析OpCode.create时的情况.

我们看到，就是调用了createNode()方法．

在这个方法的尾部，我们可以看到，就触发了dataWatches和childWatches．

就这样完成了Watch的触发．