java连接zookeeper_java 学习笔记(四) java连接ZooKeeper
public class Demo2 {
public static void main(String[] args) {
String connectString = "192.168.168.133:2181";
int sessionTimeout = 500000; // 会话时间。设置长一点,如果不够长,则会connect loss
try {
// 建立zookeeper链接
ZooKeeper zk = new ZooKeeper(connectString, sessionTimeout, new Watcher(){
public void process(WatchedEvent event) {
// 监控所有触发的事件
System.out.println("start do something");
EventType type = event.getType(); // 事件类型。枚举
KeeperState state = event.getState(); // 状态。 枚举
// type.getIntValue();
switch (type) {
case None: // int值对应 -1
System.out.println("none 事件触发");
break;
case NodeCreated: // int值对应 1
System.out.println("创建节点事件发生了");
break;
case NodeDeleted: // int值对应 2
System.out.println("删除节点事件发生了");
break;
case NodeDataChanged: // int值对应 3
System.out.println("节点数据改变事件发生了");
break;
case NodeChildrenChanged: // int值对应 4
System.out.println("子节点改变事件发生了");
break;
default:
System.out.println("I do not know what operate you do");
break;
}
// state.getIntValue(); NoSyncConnected 1和Unknown-1
switch (state) {
case Disconnected: // 0
System.out.println("失去连接");
break;
case SyncConnected: // 3
System.out.println("异步链接");
break;
case Expired: // -112
System.out.println("超时过期");
break;
default:
break;
}
System.out.println("end");
}
});
System.out.println("zk创建成功");
List list = zk.getChildren("/", true); // 获取所有节点
if(list != null) {
for(String s : list)
System.out.println(s);
}
// 在/app5节点下创建child节点
zk.create("/app7", "/app8的子节点数据".getBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT); // 会对数据持久化,服务下次启动任然存在
zk.create("/app8", "/app8的子节点数据".getBytes(), Ids.OPEN_ACL_UNSAFE,
CreateMode.PERSISTENT, new StringCallback(){
public void processResult(int rc, String path, Object ctx, String name) {
System.out.println("rc: " + rc);
System.out.println("path: " + path);
System.out.println("Object:" + ctx);
System.out.println("name: " + name);
}
}, "ctx object");
} catch (IOException e) {
e.printStackTrace();
} catch (KeeperException e) {
e.printStackTrace();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
zk每一次操纵都会被监控watcher记录下来
出现这种报错是由于创建节点的时候没有创建父节点 /app1
java连接zookeeper_java 学习笔记(四) java连接ZooKeeper相关推荐
- Java快速入门学习笔记9 | Java语言中的方法
有人相爱,有人夜里开车看海,有人却连LeetCode第一题都解不出来!虽然之前系统地学习过java课程,但是到现在一年多没有碰过Java的代码,遇到LeetCode不知是喜是悲,思来想去,然后清空自己 ...
- Java快速入门学习笔记7 | Java语言中的类与对象
有人相爱,有人夜里开车看海,有人却连LeetCode第一题都解不出来!虽然之前系统地学习过java课程,但是到现在一年多没有碰过Java的代码,遇到LeetCode不知是喜是悲,思来想去,然后清空自己 ...
- Java快速入门学习笔记5 | Java语言中的while循环语句
有人相爱,有人夜里开车看海,有人却连LeetCode第一题都解不出来!虽然之前系统地学习过java课程,但是到现在一年多没有碰过Java的代码,遇到LeetCode不知是喜是悲,思来想去,然后清空自己 ...
- Java快速入门学习笔记8 | Java语言中的数组
有人相爱,有人夜里开车看海,有人却连LeetCode第一题都解不出来!虽然之前系统地学习过java课程,但是到现在一年多没有碰过Java的代码,遇到LeetCode不知是喜是悲,思来想去,然后清空自己 ...
- Java快速入门学习笔记6 | Java语言中的for循环语句
有人相爱,有人夜里开车看海,有人却连LeetCode第一题都解不出来!虽然之前系统地学习过java课程,但是到现在一年多没有碰过Java的代码,遇到LeetCode不知是喜是悲,思来想去,然后清空自己 ...
- Java快速入门学习笔记4 | Java语言中的if条件语句
有人相爱,有人夜里开车看海,有人却连LeetCode第一题都解不出来!虽然之前系统地学习过java课程,但是到现在一年多没有碰过Java的代码,遇到LeetCode不知是喜是悲,思来想去,然后清空自己 ...
- Java快速入门学习笔记3 | Java语言中的表达式与操作符
有人相爱,有人夜里开车看海,有人却连LeetCode第一题都解不出来!虽然之前系统地学习过java课程,但是到现在一年多没有碰过Java的代码,遇到LeetCode不知是喜是悲,思来想去,然后清空自己 ...
- Java快速入门学习笔记2 | Java语言中的基本类型
有人相爱,有人夜里开车看海,有人却连LeetCode第一题都解不出来!虽然之前系统地学习过java课程,但是到现在一年多没有碰过Java的代码,遇到LeetCode不知是喜是悲,思来想去,然后清空自己 ...
- vcenter用到java吗_Vijava 学习笔记之 VCenter连接
package com.vmware.util; /** * Created by vixuan-008 on 2015/4/8. * ClientSesion 类:连接VCent服务器(URL.用户 ...
最新文章
- php将关联数组输出到前台,如何使用foreach从PHP中的关联数组输出特定数据
- XAML 布局StackPanel
- [转]让.NET应用秒变微服务
- 面试题:彻底搞懂 Cookie 和 Session
- 话唠黄金机器人_用了接吻教学机器人以后......哈哈哈哈不能我一个人瞎!
- 第五篇:数据预处理(二) - 异常值处理
- 哈尔滨工程大学微型计算机原理与接口技术,哈尔滨工程大学微机原理与接口技术第2-3讲.ppt...
- GridView边框样式简单美化
- 前端原生Html免费模板网站总结(带网址)
- 写在前面(ShenYu)
- AI cs5序列号 注册机
- 【沧海拾昧】WiFi串口通信ESP8266模块基本介绍(附野火WiFi透传实例)
- Bandizip绿色版上下文菜单解决办法
- vba九九乘法表代码_用五种方法利用EXCEL制作九九乘法表
- python语音程序设计教程_Python语言程序设计教程
- python特殊符号
- 用户画像标签系统体系解释
- BigDecimal 校验格式
- 将本地项目上传至码云仓库
- 必看!Java 学习路线
热门文章
- win8计算机管理员权限删除文件,win8系统使用管理员权限无法删除部分文件怎么办...
- 你发这些什么目的_微信CRM系统究竟是什么?
- opencv videocapture读取视频cap.isOpened 输出总是false
- matlab 矩阵位移法编程 结构力学,matlab 矩阵位移法编程 结构力学
- 洛谷 P1219 八皇后题解
- Linux下Rails3 + Lighttpd + fcgi部署研究
- Peter's smokes -poj 2509
- SELinux 引起的 Docker 启动失败
- leetcode链表题
- 如何获取codeforces的完整数据