Watches
所有的读操作(getData(),getChildren(),exists())都可以设置一个watch作为附加的操作
Watch的关键特性有
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 implements Watcher,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" );
}
}
运维网声明
1、欢迎大家加入本站运维交流群:群②:261659950 群⑤:202807635 群⑦870801961 群⑧679858003
2、本站所有主题由该帖子作者发表,该帖子作者与运维网 享有帖子相关版权
3、所有作品的著作权均归原作者享有,请您和我们一样尊重他人的著作权等合法权益。如果您对作品感到满意,请购买正版
4、禁止制作、复制、发布和传播具有反动、淫秽、色情、暴力、凶杀等内容的信息,一经发现立即删除。若您因此触犯法律,一切后果自负,我们对此不承担任何责任
5、所有资源均系网友上传或者通过网络收集,我们仅提供一个展示、介绍、观摩学习的平台,我们不对其内容的准确性、可靠性、正当性、安全性、合法性等负责,亦不承担任何法律责任
6、所有作品仅供您个人学习、研究或欣赏,不得用于商业或者其他用途,否则,一切后果均由您自己承担,我们对此不承担任何法律责任
7、如涉及侵犯版权等问题,请您及时通知我们,我们将立即采取措施予以解决
8、联系人Email:admin@iyunv.com 网址:www.yunweiku.com