1.从http://zookeeper.apache.org下载最新版本的ZooKeeper(当前最新版为zookeeper-3.4.5)
2.$ tar zxf zookeeper-3.4.5.tar.gz解压
3.在conf目录下创建配置文件zoo.cfg
- tickTime=2000
- dataDir=/home/lan/zookeeper
- clientPort=2181
tickTime=2000 dataDir=/home/lan/zookeeper clientPort=2181
tickTime是发送心跳包的时间间隔
dataDir用于存储Zookeeper的内存数据库快照和更新事务日志(日志目录可另外配置)
clientPort端口用于监听客户端连接
4.启动ZooKeeper
5.连接ZooKeeper
5.在shell中通过help命令查看客户端可以执行哪些命令
6.通过ls命令查看根目录
7.创建一个znode
8.读取znode
9.修改znode
10.删除znode
- package zookeeper.demo;
- import java.io.IOException;
- import java.util.List;
- import java.util.concurrent.CountDownLatch;
- import org.apache.zookeeper.CreateMode;
- import org.apache.zookeeper.KeeperException;
- import org.apache.zookeeper.WatchedEvent;
- import org.apache.zookeeper.Watcher;
- import org.apache.zookeeper.Watcher.Event.KeeperState;
- import org.apache.zookeeper.ZooDefs.Ids;
- import org.apache.zookeeper.ZooKeeper;
- import org.apache.zookeeper.data.Stat;
- public class ZooKeeperTestCase implements Watcher {
- private static ZooKeeper zk;
- private String path;
- private Stat stat;
- private static CountDownLatch countDown = new CountDownLatch(1);
- public ZooKeeperTestCase(){
- if(zk == null){
- try {
- System.out.println("Starting ZK:");
- zk = new ZooKeeper("192.168.202.129", 3000, this);
- countDown.await();
- System.out.println("Finished starting ZK: " + zk);
- } catch (IOException e) {
- zk = null;
- e.printStackTrace();
- } catch (InterruptedException e) {
- e.printStackTrace();
- }
- }
- }
- @Override
- public void process(WatchedEvent event) {
- if(event.getState() == KeeperState.SyncConnected){
- countDown.countDown();
- }
- System.out.println("-----"+event.getState());
- }
- public void create() throws KeeperException, InterruptedException{
- path = zk.create("/zk_java", "java_binding".getBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT_SEQUENTIAL);
- System.out.println("created znode:" + path);
- }
- public void list() throws KeeperException, InterruptedException{
- List<String> strings = zk.getChildren("/", true);
- System.out.println("list:"+strings);
- }
- public void exist() throws KeeperException, InterruptedException{
- stat = zk.exists(path, true);
- System.out.println("exits:"+stat.getDataLength());
- }
- public void get() throws KeeperException, InterruptedException{
- Stat stat = new Stat();
- byte[] data = zk.getData(path, true, stat);
- System.out.print(new String(data));
- System.out.println(stat);
- }
- public void set() throws KeeperException, InterruptedException{
- stat = zk.setData(path, "zk_ooxx".getBytes(), stat.getVersion());
- }
- public void delete() throws InterruptedException, KeeperException{
- zk.delete(path, stat.getVersion());
- }
- public void close() throws InterruptedException{
- zk.close();
- }
- public static void main(String[] args) throws Exception {
- ZooKeeperTestCase zkTest = new ZooKeeperTestCase();
- zkTest.list();
- zkTest.create();
- zkTest.list();
- zkTest.exist();
- zkTest.get();
- zkTest.set();
- zkTest.get();
- zkTest.delete();
- zkTest.list();
- zkTest.close();
- }
- }
相关推荐
《Paxos到Zookeeper——分布式一致性原理与实践》,学习zookeeper必备。该资源仅供大家了解书的内容,如果真有兴趣深入学习,建议购买正版书籍。
2.Zookeeper——Zookeeper单机和分布式安装 3.Zookeeper——Zookeeper客户端命令 4.Zookeeper——Zookeeper内部原理 5.Zookeeper——Zookeeper实战 三、Hive 1.Hive——Hive概述 2.Hive——Hive...
Zookeeper从入门到精通.xmind
《Zookeeper从入门到精通课程资源》 包含了入门开发详解,集群高可用结构讲解,Web界面监控 ,案例实战
Zookeeper 从入门到精通及实战案例 开发详解 案例实战 Web界面监控 。。。。 。。。。 。。。。
主要是一些zookeeper的代码 可结合博主的zookeeper从入门到精通进行阅读 详情可配合我的博客进行学习 https://blog.csdn.net/weixin_47872288/article/details/120444546
zookeeper的基础与架构、集群搭建 zookeeper是什么?? zookeeper是一个分布式协调服务,就是为用户的分布式应用提供协调服务 zookeeper是为其他的分布式程序服务的 zookeeper本身也是一个分布式程序(只要有半数...
Zookeeper 从入门到精通及实战案例
很好的大数据学习资料,适合初学者使用,详细介绍了zookeeper
zookeeper 入门到精通文档...................................................................................................................................................................................
案例是Dubbo和Zookeeper整合入门案例,有负载均衡(自己修改一下端口),解决了无法发布被事务代理的Service问题,写了消费方和提供方。
zookeeper从入门到精通+实战演练,1、介绍和使用, 2、配置使用 3、核心技术、安全、实战
dubbo+zookeeper快速入门程序
ZooKeeper是一个分布式的,开放源码的分布式应用程序协调服务,是Google的Chubby一个开源的实现,是Hadoop和Hbase的重要组件。它是一个为分布式应用提供一致性服务的软件,提供的功能包括:配置维护、域名服务、...
Zookeeper入门到精通
NULL 博文链接:https://425826501.iteye.com/blog/2424450
zookeeper入门材料.pdf
本手册面向对zookeeper技术感兴趣的读者,是使用当中的总结,希望能帮到你们
Hadoop快速入门——第四章、zookeeper安装包
搭建ZOOKEEPER集群服务器 ZOOKEEPER基本操作 ZOOKEEPER临时节点 监控ZOOKEEPER节点