Zookeeper分布式协调服务

一、初识zookeeper

1、zookeeper简介

在这里插入图片描述

2、特性

一致性
可靠性
顺序性
原子性
实时性

3、角色

Leader：领导者一个
Follower：追随者多个
Observer：观察者

二、zookeeper分布式集群部署

1、下载

在这里插入图片描述

2、上传安装包

在这里插入图片描述

3、解压

在这里插入图片描述

4、配置环境变量

在这里插入图片描述

5、zookeeper的配置文件

在这里插入图片描述

复制

在这里插入图片描述
修改配置

6、创建myid文件

在这里插入图片描述

7、分发文件

在这里插入图片描述

分发环境变量配置文件

在这里插入图片描述

分发myid文件
在这里插入图片描述

修改Hadoop02的myid为2和Hadoop03的myid为3

在这里插入图片描述

8、使环境变量生效

在这里插入图片描述

9.启动zookeeper集群

注意：必须挨个启动

在这里插入图片描述
依次启动zookeeper

10.停止zookeeper集

注意：必须挨个停止

在这里插入图片描述

三． Zookeeper的shell操作

1.启动集群

zkServer.sh start

2.启动shell

zkCli.sh

在这里插入图片描述

3.查看zookeeper某个目录信息

在这里插入图片描述

4.查看某个目录的数据信息

在这里插入图片描述

5.创建节点

在这里插入图片描述

6.获取节点

Get

在这里插入图片描述

7.修改节点

Set
在这里插入图片描述

8.监听节点

Get -w
在这里插入图片描述

9.删除节点

在这里插入图片描述

四．Zookeeper的Java API操作

1. 启动idea，新建一个maven工程

在这里插入图片描述

2. 引入pom依赖

在这里插入图片描述

3. 新建包，在包下新建一个类

1) 测试客户端是否创建成功

package cn.edu.hgu.zookeeper;

import org.apache.zookeeper.*;


import java.io.IOException;
import java.nio.charset.StandardCharsets;

/**
 * ZookeeperDemo
 *
 * @author 落空空
 * @date 2021-11-06 22:12
 */
public class ZookeeperDemo {
    public static void main(String[] args) throws IOException, KeeperException, InterruptedException {
        //1、创建zookeeper的客户端
        ZooKeeper zooKeeper = new ZooKeeper("hadoop01:2181,hadoop02:2181,hadoop03:2181", 30000, new Watcher() {
            public void process(WatchedEvent watchedEvent) {
                System.out.println(watchedEvent.toString());
            }
        });
        System.out.println(zooKeeper);


    }
}