一、监听器原理
- 首先创建 zookeeper 客户端，内部会创建两个线程，一个负责网络连接通信（connect），一个负责监听（listener）
- 通过 connect 线程将注册的监听事件发送给 zookeeper ，zookeeper 将这个监听事件添加到自身的注册监听器列表中
- zookeeper 监听到有数据或路径变化，就会将这个消息发送给客户端的 listener 线程
- listener 线程收到之后会进行处理
不应该对 zookeeper 的 watch 监听事件进行强依赖，理由如下：
- 当客户端在 zookeeper 上某个节点绑定监听事件后，如果该事件被触发，zookeeper 会通过回调函数的方式通知客户端，但是客户端只会收到一次通知。如果后续这个节点再次发生变化，那么之前设置 Watcher 的客户端不会再次收到消息（Watcher 是一次性的操作），可以通过循环监听去达到永久监听的效果。
- 客户端断开之后重新连接到服务器也是需要一段时间。这就导致了 zookeeper 客户端不能接收全部的 zookeeper 事件
1. 监听机制的特点
zookeeper 的 getData() 和 getChildren() 和 exists() 方法都可以注册 watcher 监听，监听有下面几个特性
- 一次性触发。当数据改变的时候，那么一个Watch事件会产生并且被发送到客户端中。但是客户端只会收到一次这样的通知，如果以后这个数据再次发生改变的时候，之前设置Watch的客户端将不会再次收到改变的通知，因为Watch机制规定了它是一个一次性的触发器。可以通过循环监听去达到永久监听的效果。而循环注册 watch 事件，在第一个 watch 触发，并且第二个 watch 还未注册成功的间隙，进行节点数据的修改，显然无法收到 watch 事件。
- watch 事件异步发送给客户端。这就表明不同的客户端收到的 watch 的时间可能不同，但是 zookeeper 有保证：当一个客户端在看到 watch 事件之前是不会看到节点数据的变化的。网络延迟或其他因素可能导致不同 client 在不同时刻获取到 watch 事件，但是不同的客户端所看到的一切具有一致的顺序
- 我们可以认为 zookeeper 内部会维护两个 watch 列表：
data watch和child watch。getData()和exists()会设置data watch，而getChildren()会设置child watch。或者我们可以认为 watch 是根据返回值设置，getData()和exists()返回节点本身的信息，而getChildren()会返回子节点的列表。因此成功的setData()会触发 znode 上设置的data watch；成功的create()操作会触发被创建的 znode 上的data watch以及其父节点上的child watch。而一次成功的delete()操作将会同时触发一个 znode 节点的data watch和child watch（因为这样就没有子节点了），同时还会触发其父节点的child watch。 - Watch由 client 连接上的 ZooKeeper 服务器在本地维护。这样可以减小设置、维护和分发watch的开销。当一个客户端连接到一个新的服务器上时，watch将会被以任意会话事件触发。当与一个服务器失去连接的时候，是无法接收到watch的。而当client重新连接时，如果需要的话，所有先前注册过的watch，都会被重新注册。通常这是完全透明的。只有在一个特殊情况下，watch可能会丢失：对于一个未创建的znode的 watch，如果在客户端断开连接期间被创建了，并且随后在客户端连接上之前又删除了，这种情况下，这个watch事件可能会被丢失
- 客户端断开之后重新连接到服务器也是需要一段时间。这就导致了 zookeeper 客户端不能接收全部的 zookeeper 事件
- 从 zookeeper 相关的文档来看，zookeeper 消息并不保证一定送达，在网络短暂故障的重连期间，可能存在消息丢失的情况，所以在 zookeeper 服务器压力不大并且数据不大的情况下，可以周期性全量拉取 zookeeper 数据
watch 机制会丢失数据，因此在 zookeeper 服务器压力不大并且数据不大的情况下，可以周期性全量拉取 zookeeper 数据进行对账。
二、写数据流程
