ZK的watch机制实现原理(2)

ZK的watch机制实现原理

客户端回调过程

• 使用SendThread.readResponse()方法来统一处理服务端的相应
• 将收到的字节流反序列化转换成WatcherEvent对象。调用eventThread.queueEvent(）方法将接收到的事件交给EventThread线程进行处理
• 从ZKWatchManager中查询注册过的客户端Watch信息。查询到后，会将其从ZKWatchManager的管理中删除。因此客户端的Watcher机制是一次性的，触发后就会被删除
• 将查询到的Watcher存储到waitingEvents队列中，调用EventThread类中的run方法循环取出在waitingEvents队列中等待的Watcher事件进行处理

本文分享的ZK的watch机制实现原理的具体介绍，小编希望给网友们带来一些知识。