一.ZooKeeper简介

Zookeeper是一个开源的分布式的，为分布式应用提供协调服务的Apache项目

Zookeeper=文件系统+通知机制

Zookeeper从设计模式上来看是一个基于观察者模式设计的分布式服务管理框架，它负责存储和管理大家都关心的数

据，然后接受观察者的注册

一旦数据的状态发生变化，Zookeeper就将负责通知已经在Zookeeper上注册的那些观察者做出相应的反应，从而实现集群中类似Master/Slave管理模式

二. ZooKeeper数据结构

znode

ZooKeeper数据模型的结构与Linux文件系统很像，整体上可以看作是一棵树，树的每个节点称做一个znode。每一个znode默认能够存储

1MB的数据，每个znode都可以通过其路径唯一标识

节点类型

PERSISTENT：持久化节点，默认类型

PERSISTENT_SEQUENTIAL：持久化顺序编号节点

EPHEMERAL：临时节点

EPHEMERAL_SEQUENTIAL：临时顺序编号节点

三. ZooKeeper客户端命令

首先输入zkCli.sh进入命令行模式

命令基本语法	命令功能描述
help	显示所有操作命令
ls path	使用ls命令查看当前znode中所包含的内容
ls2	查看当前节点数据并能看到更新次数等数据
create	创建节点，默认是持久化节点 create -s：创建带序列的节点 create -e：创建临时节点
get path	获取节点的值
set	设置节点的具体值
stat	查看节点状态
delete	删除节点,不可删除带有子节点的节点
rmr	递归删除节点
quit	退出zk客户端

使用Java API访问zookeeper

1.创建maven工程添加依赖


         
    
     org.apache.zookeeper
          
    
     zookeeper
          
    
     3.4.6

2.代码实现

package hadoop;import org.apache.zookeeper.*;import org.apache.zookeeper.data.Stat;import org.junit.Before;import org.junit.Test;import java.io.IOException;import java.util.List;/** * @author sunyong * @date 2020/07/06 * @description */public class ZKClientDemo {
       private static  final  String CONNECTSTRING = "hadoop110,hadoop111,hadoop112:2181";//zk的集群连接信息    private static final int SESSIONTIMEOUT = 2000;//集群超时时间    private static ZooKeeper zkClient;//zk对象    //初始化zk对象    @Before    public void init() throws IOException {
           zkClient=new ZooKeeper(CONNECTSTRING,SESSIONTIMEOUT, new Watcher() {
               @Override            public void process(WatchedEvent watchedEvent) {
               }        });    }    //创建节点    @Test    public void CareateNode() throws KeeperException, InterruptedException {
         String path =   zkClient.create("/kgc/hadoop110","hadoop110".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);        System.out.println(path);    }    //获取所有子节点    @Test    public void getChildrenNode() throws KeeperException, InterruptedException {
         List
   
     children=  zkClient.getChildren("/kgc",true);        for (String child : children) {
               System.out.println(child);        }    }    //判断节点是否存在    @Test    public void existsNode() throws KeeperException, InterruptedException {
          Stat exists =  zkClient.exists("/kgc/1",false);        System.out.println(exists==null?"不存在":"存在");    }}