package zk.test;
import org.apache.zookeeper.CreateMode;
import org.apache.zookeeper.WatchedEvent;
import org.apache.zookeeper.Watcher;
import org.apache.zookeeper.ZooDefs.Ids;
import org.apache.zookeeper.ZooKeeper;
public class ZkTest {
private static final int SESSION_TIMEOUT = 30000;
public static void main(String[] args) throws Exception{
ZooKeeper zk = new ZooKeeper("localhost:2181",
SESSION_TIMEOUT, new Watcher() {
// 监控所有被触发的事件
@Override
public void process(WatchedEvent event) {
System.out.println("已经触发了" + event.getType() + "事件!");
}
});
zk.create("/testRootA", "testRoot_data".getBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
//创建子节点1
zk.create("/testRootA/testChild_1", "testChild_data".getBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
System.out.println(new String(zk.getData("/testRootA", false, null)));
System.out.println((zk.getChildren("/testRootA/testChild_1", true)));
//修改
zk.setData("/testRootA/testChild_1", "modifyTestChildOne".getBytes(), -1);
System.out.println("目录结点状态:" + zk.exists("/testRootA", true));
//创建子节点2
zk.create("/testRootA/testChild_2", "testChild_2_data".getBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
System.out.println((zk.getChildren("/testRootA/testChild_2", true)));
//删除结点
zk.delete("/testRootA/testChild_1", -1);
zk.delete("/testRootA/testChild_2", -1);
zk.delete("/testRootA", -1);
zk.close();
}
}
分享到:
相关推荐
zookeeper-demo:一个简单的zookeeper API调用示例和一个上下线检测演示
第7章介绍C语言版的API接口,也可以作为非Java语言实现的ZooKeeperAPI的基础,对非Java语言的开发人员非常有帮助。第8章介绍一款更高层级的封装的ZooKeeper接口。第三部分(第9~10章)主要介绍ZooKeeper内部原理及...
第7章介绍C语言版的API接口,也可以作为非Java语言实现的ZooKeeperAPI的基础,对非Java语言的开发人员非常有帮助。第8章介绍一款更高层级的封装的ZooKeeper接口。第三部分(第9~10章)主要介绍ZooKeeper内部原理及...
第7章介绍C语言版的API接口,也可以作为非Java语言实现的ZooKeeperAPI的基础,对非Java语言的开发人员非常有帮助。第8章介绍一款更高层级的封装的ZooKeeper接口。第三部分(第9~10章)主要介绍ZooKeeper内部原理及...
第7章介绍C语言版的API接口,也可以作为非Java语言实现的ZooKeeperAPI的基础,对非Java语言的开发人员非常有帮助。第8章介绍一款更高层级的封装的ZooKeeper接口。第三部分(第9~10章)主要介绍ZooKeeper内部原理及...
第7章介绍C语言版的API接口,也可以作为非Java语言实现的ZooKeeperAPI的基础,对非Java语言的开发人员非常有帮助。第8章介绍一款更高层级的封装的ZooKeeper接口。第三部分(第9~10章)主要介绍ZooKeeper内部原理及...
第7章介绍C语言版的API接口,也可以作为非Java语言实现的ZooKeeperAPI的基础,对非Java语言的开发人员非常有帮助。第8章介绍一款更高层级的封装的ZooKeeper接口。第三部分(第9~10章)主要介绍ZooKeeper内部原理及...
第7章介绍C语言版的API接口,也可以作为非Java语言实现的ZooKeeperAPI的基础,对非Java语言的开发人员非常有帮助。第8章介绍一款更高层级的封装的ZooKeeper接口。第三部分(第9~10章)主要介绍ZooKeeper内部原理及...
第7章介绍C语言版的API接口,也可以作为非Java语言实现的ZooKeeperAPI的基础,对非Java语言的开发人员非常有帮助。第8章介绍一款更高层级的封装的ZooKeeper接口。第三部分(第9~10章)主要介绍ZooKeeper内部原理及...
大数据实验Hbase安装部署和使用javaapi调用,详细且成功率高,纯自己手写的,hadoop和hbase版本是采用林子雨老师教材中的,自己在此教程上改良,引入先安装zookeeper方法避免诸多问题产生。
ZooKeeper的目标就是封装好复杂易出错的关键服务,将简单易用的接口和性能高效、功能稳定的系统提供给用户。 Rabbit ZooKeeper Extensions 该项目使用了 Apache ZooKeeper .NET async Client 组件,除提供了基本...
springboot+dubbo+zookeeper实现分布式系统源码,dubbo-project总工程,dubbo-usercommon服务API工程,dubbo-userprovider提供服务工程,dubbo-usercuser消费服务工程
1.api目录:存放消费者与提供者调用的service接口 2.consumer目录:消费者目录 调用提供者远程提供的接口实现 3.provider目录:提供者目录 提供给消费者接口实现 内赠: 基于Zookeeper的分布式锁demo, 基于Zookeeper...
通过调用ZK提供的创建节点的API,能够很容易创建一个全局唯一的path,这个path就可以作为一个名称。 阿里巴巴集团开源的分布式服务框架Dubbo中使用ZooKeeper来作为其命名服务,维护全局的服务地址列表, 点击这里...
对于具有更方便的 API 和锁等功能的更高级别的接口,请查看 。 前叉安全! 从 1.1.0 开始,这个库是 fork 安全的(这并不容易实现)。 这意味着您可以在 unicorn、resque 以及您生病的小猴子本周使用的任何其他 ...
此项目,我们用来调用对外暴露的接口。 2.运行步骤: 1.下载项目到本地 ssh方式: git clone :lightClouds917/springboot-dubbo-zookeeper.git https方式: git clone 2.启动 外层的springboot-dubbo-zookeeper 只是...
REST 调用输出 JSON (可选)使用zookeeper注册varnish节点 可以使用 yaml 配置文件和合理的默认值进行配置 入门 安装 注意:建议使用 ruby 版本管理器,例如而不是使用系统 ruby 安装。 使用 ruby ...