ZooKeeper的使用---Java程序
2024-10-19 23:26:13
一、导入库
- 以下库存放在目录lib中:
audience-annotations-0.5.0.jar
jline-0.9.94.jar
log4j-1.2.17.jar
netty-3.10.6.Final.jar
slf4j-api-1.7.25.jar
slf4j-log4j12-1.7.25.jar
- 以下库存放在zookeeper安装的根目录中:
zookeeper-3.4.12.jar
二、ZooKeeper对象的操作
- zookeeper对象的创建
String connectString = "hadoop1:2181,hadoop2:2181,hadoop3:2181”;
int sessionTimeout = 2000; ZooKeeper zookeeper = new ZooKeeper(connectString, sessionTimeout, new Watcher() {
@Override
public void process(WatchedEvent event) {
...
}
});
其中:
connectString是连接zookeeper的信息
sessionTimeout是会话超时时间,也就是当一个zookeeper超过该时间没有心跳,则认为该节点故障。
Watcher是一个监控器,一旦触发监控就会回调process方法,触发的事件会存在event对象中。
- ZooKeeper对象的常用方法
方法名 | 返回值 | 作用 | 各参数 | 备注 |
String create(final String path, byte data[], List<ACL> acl,CreateMode createMode) | 返回值是path的字符串 | 创建节点 |
|
|
Stat setData(final String path, byte data[], int version) | 节点状态对象,里面包含节点的各种信息,包括节点更改的版本,节点创建的日期等等。 | 设置节点的数据 |
|
|
List<String> getChildren(String path, boolean watch) | 节点下子节点集合,只有节点名称,不是全路径 | 获取子节点列表 |
|
|
byte[] getData(String path, boolean watch, Stat stat) | 该节点的值 | 获取该节点的值 |
|
|
void delete(final String path, int version) | 删除节点 |
|
最新文章
- AC日记——加密的病历单 openjudge 1.7 12
- Octopus系列之一些问题的汇总
- 21个高质量的Swift开源iOS App
- Cache&;Session Viewer
- HttpContext 讲解
- Lucene学习总结之八:Lucene的查询语法,JavaCC及QueryParser
- text-overflow 文字溢出时的设置
- Cocos2d-x中父节点scale对子节点的影响
- 新秀发挥云17号:RHEL改变以太网地址克隆虚拟机后,
- Salesforce开发者学习笔记之二:Salesforce开发平台应用场景
- OsharpNS轻量级.net core快速开发框架简明入门教程-基于Osharp实现自己的业务功能
- java文件运行的过程
- ubuntu 16.04 安装 Mask_RCNN 遇到的问题集锦
- 05 python 初学(列表)
- Luogu4916 魔力环 莫比乌斯反演、组合、生成函数
- Javascript 中调参数的脚本onclick=";select(this)"; this 怎么解释
- MySQL 事务机制
- 网页录像录音功能的实现之MediaRecorder的使用
- APP消息推送机制的实现(PUSH)
- .net webform 把word转为html