zookeeper分布式集群中Curator的PathChildrenCache监测节点数据更新添加删除
System.out.println(TAG + “数据:” + event.getData().getPath() + “,” + new String(event.getData().getData()));由于篇幅问题,我呢也将自己当前所在技术领域的各项知识点、工具、框架等汇总成一份技术路线图,还有一些架构进阶视频、全套学习PDF文件、面试文档、源码笔记。System.out.println
尾声
在我的博客上很多朋友都在给我留言,需要一些系统的面试高频题目。之前说过我的复习范围无非是个人技术博客还有整理的笔记,考虑到笔记是手写版不利于保存,所以打算重新整理并放到网上,时间原因这里先列出面试问题,题解详见:
展示学习笔记
网上学习资料一大堆,但如果学到的知识不成体系,遇到问题时只是浅尝辄止,不再深入研究,那么很难做到真正的技术提升。
一个人可以走的很快,但一群人才能走的更远!不论你是正从事IT行业的老鸟或是对IT行业感兴趣的新人,都欢迎加入我们的的圈子(技术交流、学习资源、职场吐槽、大厂内推、面试辅导),让我们一起学习成长!
import java.util.concurrent.TimeUnit;
public class Main {
private final String TAG = "调试# ";
public static void main(String[] args) {
//初始化log4j,zookeeper否则报错。
//org.apache.log4j.BasicConfigurator.configure();
try {
Main m = new Main();
} catch (Exception e) {
e.printStackTrace();
}
}
private String getAddress() {
String ip = “127.0.0.1”;
return ip + “:2181,” + ip + “:2182,” + ip + “:2183”;
}
public Main() throws Exception {
RetryPolicy retryPolicy = new ExponentialBackoffRetry(1000, 5);
CuratorFramework client = CuratorFrameworkFactory.builder()
.connectString(getAddress())
.sessionTimeoutMs(10 * 1000)
.connectionTimeoutMs(20 * 1000)
.retryPolicy(retryPolicy)
.build();
client.start();
String path = “/test_data/my_path”;
//检测是否存在该路径。
Stat stat = client.checkExists().forPath(path);
//如果不存在这个路径,stat为null,创建新的节点路径。
if (stat == null) {
String s = client.create()
.creatingParentsIfNeeded()
.withMode(CreateMode.PERSISTENT)
.forPath(path);
System.out.println(TAG + “已创建:” + s);
} else {
System.out.println(TAG + “已存在:” + path);
}
PathChildrenCache pathChildrenCache = new PathChildrenCache(client, path, true);
pathChildrenCache.start();
PathChildrenCacheListener pathChildrenCacheListener = new PathChildrenCacheListener() {
@Override
public void childEvent(CuratorFramework curatorFramework, PathChildrenCacheEvent event) throws Exception {
System.out.println(TAG + “事件:” + event.getType());
System.out.println(TAG + “数据:” + event.getData().getPath() + “,” + new String(event.getData().getData()));
List childData = event.getInitialData();
if (childData != null) {
for (ChildData data : childData) {
System.out.println(TAG + “子路径:” + data.getPath());
System.out.println(TAG + “子数据:” + data.getData().toString());
}
}
}
};
pathChildrenCache.getListenable().addListener(pathChildrenCacheListener);
//创建一个子节点。
String tempPath = path + “/test_01”;
if (client.checkExists().forPath(tempPath) == null) {
System.out.println(TAG + “不存在:” + tempPath);
client.create().creatingParentsIfNeeded().forPath(tempPath, “hello,world!”.getBytes(“UTF-8”));
TimeUnit.SECONDS.sleep(5);
} else {
System.out.println(TAG + “存在:” + tempPath);
}
update(client, tempPath);
TimeUnit.SECONDS.sleep(5);
delete(client, tempPath);
TimeUnit.SECONDS.sleep(5);
Android高级架构师
由于篇幅问题,我呢也将自己当前所在技术领域的各项知识点、工具、框架等汇总成一份技术路线图,还有一些架构进阶视频、全套学习PDF文件、面试文档、源码笔记。
- 330页PDF Android学习核心笔记(内含上面8大板块)
-
Android学习的系统对应视频
-
Android进阶的系统对应学习资料
- Android BAT部分大厂面试题(有解析)
好了,以上便是今天的分享,希望为各位朋友后续的学习提供方便。觉得内容不错,也欢迎多多分享给身边的朋友哈。
网上学习资料一大堆,但如果学到的知识不成体系,遇到问题时只是浅尝辄止,不再深入研究,那么很难做到真正的技术提升。
一个人可以走的很快,但一群人才能走的更远!不论你是正从事IT行业的老鸟或是对IT行业感兴趣的新人,都欢迎加入我们的的圈子(技术交流、学习资源、职场吐槽、大厂内推、面试辅导),让我们一起学习成长!
学到的知识不成体系,遇到问题时只是浅尝辄止,不再深入研究,那么很难做到真正的技术提升。**
一个人可以走的很快,但一群人才能走的更远!不论你是正从事IT行业的老鸟或是对IT行业感兴趣的新人,都欢迎加入我们的的圈子(技术交流、学习资源、职场吐槽、大厂内推、面试辅导),让我们一起学习成长!
更多推荐
所有评论(0)