欢迎您访问365答案网,请分享给你的朋友!
生活常识 学习资料

7.zookeeper的watch机制

时间:2023-05-12

watch机制,客户端使用NIO通讯模式监听服务端的调用
zkCli客户端示例

#监听一个节点,当节点发生变化会通知监听的客户端 get -w 节点名#不能监听子节点变化get -w /testNode

#监听子节点#不能监听子节点的子节点ls -w /testNode

#监听所有的子节点ls -R -w /testNode

curator客户端监听示例

@Testpublic void addNodeListener() throws Exception{ NodeCache nodeCache = new NodeCache(curatorframework, "/test-node1"); nodeCache.getListenable().addListener(new NodeCacheListener() { @Override public void nodeChanged() throws Exception { printZk(); } }); nodeCache.start(); System.in.read();}public void printZk() throws Exception{ byte[] bytes = curatorframework.getData().forPath("/test-node1"); System.out.println(new String(bytes));}

修改test-node1节点,java控制台输出节点变更的值

[zk: localhost:2181(CONNECTED) 10] set /test-node1 123[zk: localhost:2181(CONNECTED) 11] set /test-node1 333333

Copyright © 2016-2020 www.365daan.com All Rights Reserved. 365答案网 版权所有 备案号:

部分内容来自互联网,版权归原作者所有,如有冒犯请联系我们,我们将在三个工作时内妥善处理。