zookeeper基本使用

1. zookeeper

1. 1. zookeeper是Apache hadoop 项目下的一个子项目,是一个树形目录服务
2. 2. zookeeper翻译过来就是动物园管理员,用来管理Hadoop(大象),hive(蜜蜂),pig(小猪)的管理员
3. 3. zookeeper是一个分布式的,开源的分布式引用程序的协调服务

复制代码

功能包罗:
1. 配置管理
2. 分布式锁
3. 集群管理
2. zookeeper安装

前提: 安装jdk

• 下载zookeeper
  
• 上传到linux解压
  
• 配置zoo.cfg,安装目次下的conf目次中
  

1. cp zoo_sample.cfg zoo.cfg

复制代码

1. # 数据目录设置
2. dataDir=/path/to/zookeeper_data
3. # 客户端连接端口
4. clientPort=2181

复制代码

3. zookeeper运行

服务端启动:

1. # 使用zkServer start启动
2. zkServer start
3. # 查看服务节点状态
4. zkServer.sh status
5. # 停止节点
6. zkServer.sh stop

复制代码

standalone为单节点模式(孤独的):

4. zookeeper操作

数据模子: zookeeper是一个树形目次服务,其数据模子和Unix的文件系统很类似,拥有一个层次化结构。每一个节点都被称为ZNode,每个节点上都会保存自己的数据和节点信息。节点可以拥有子节点,同时也允许少量(1MB)数据存储在该节点之下。
节点分为四大类:
PERSISTENT 恒久化节点
EPHEMERAL 临时节点 -e
PERSISTENT_SEQUENTIAL 恒久化顺序节点 -s
EPHEMERAL_SEQUENTIAL 临时顺序节点 -es

(1) 服务端常用命令操作

1. zkServer.sh start                                 # 开启服务
2. zkServer.sh stop                                # 停止服务
3. zkServer.sh status                                # 查看状态
4. zkServer.sh restart                                # 重启

复制代码

(2) 客户端常用命令

1. zkCli.sh -server localhost:2181                 # 连接服务端(默认连接本地2181)
2. quit                                                                        # 退出
3. ls         [-s -w -R] path                                                #查看目录文件
4. create [-e -s -es]        path                                # 创建节点默认持久化,支持子节点,,如: /a1/b1
5. get path                                                                # 获取节点数据
6. set path 内容                                                        # 给节点设置内容
7. delete path                                                                # 删除节点
8. deleteall path                                                        # 删除所有节点,包括子节点
9. ls2 path                                                                # 节点详细信息: ls -s (效果相同)
10. help                                                                        # 查看帮助文档

复制代码

(3) javaAPI操作

Curator

Curator是APache Zookeeper的java客户端
常见的zookeeper javaAPI:
原生java API
ZkClient
Curator
Curator项目标目标是简化zookeeper客户端的使用
Curator官网: https://curator.apache.org/
Curator基本操作

maven坐标:

1. <dependency>
2.       <groupId>org.apache.curator</groupId>
3.       <artifactId>curator-recipes</artifactId>
4.       <version>4.0.1</version>
5.     </dependency>
6.     <dependency>
7.       <groupId>org.apache.curator</groupId>
8.       <artifactId>curator-framework</artifactId>
9.       <version>4.1.0</version>
10.     </dependency>

复制代码

建立连接:

1. // 方式一
2.         CuratorFramework clent = CuratorFrameworkFactory.newClient(
3.                 "192.168.72.88:2181", // 连接地址,集群使用,隔开
4.                 5000,           // 会话超时时间
5.                 3000,           // 连接超时时间
6.                 new ExponentialBackoffRetry(3000, 10) // 重试策略
7.         );
8.                 client.start(); //开启连接
9. // 方式二: 如果指定了命名空间,就会以指定的目录为根目录,可以做到隔离和简化效果
10. CuratorFramework build = CuratorFrameworkFactory.builder()
11.                 .connectString("192.168.72.88:2181")
12.                 .sessionTimeoutMs(5000)
13.                 .connectionTimeoutMs(3000)
14.                 .namespace("test") // 命名空间
15.                 .retryPolicy(new ExponentialBackoffRetry(3000, 10))
16.                 .build();
17.         build.start();

复制代码

节点操作

创建节点:

1. // 基本创建, 在根目录下创建xjy节点,数据为hello("可选,默认当前客户端的ip")
2.   client.create().forPath("/xjy", "hello" .getBytes());
3. // 创建指定模式的节点
4. client.create().withMode(CreateMode.CONTAINER).forPath("/xjy2");
5. // 创建多级节点
6. client.create().creatingParentsIfNeeded().forPath("/xjy2/aa");

复制代码

查询节点:

1. // 查询节点数据
2. byte[] bytes = client.getData().forPath("/xjy");
3. String s = new String(bytes);
4. System.out.println(s);
5. // 查询子节点
6. List<String> list = client.getChildren().forPath("/");
7. for (String s : list) {
8.       System.out.println(s);
9. }
10. // 查询节点状态信息
11. Stat stat = new Stat();
12. client.getData().storingStatIn(stat).forPath("xjy");
13. System.out.println(stat);

复制代码

删除数据:

1. [/code] [b]修改数据[/b]:
2. [code]client.setData().forPath("xjy","hello".getBytes());
4. // 根据版本修改数据
5. Stat stat = new Stat();
6. client.getData().storingStatIn(stat).forPath("xjy");
7. int version = stat.getVersion();
8. client.setData().withVersion(version).forPath("xjy","haha".getBytes());

复制代码

删除数据:

1. // 删除单个节点
2. client.delete().forPath("xjy");
4. //删除带有子节点的节点
5. client.delete().deletingChildrenIfNeeded().forPath("xjy");
7. // 必须删除
8. client.delete().guaranteed().forPath("xjy");
10. // 回调函数
11. client.delete().guaranteed().inBackground((curatorFramework, curatorEvent) -> {
12.             System.out.println("删除节点: " + curatorEvent.getPath() + " 状态: " + curatorEvent.getResultCode() + " 类型: " + curatorEvent.getType());
13.         }).forPath("xjy");

复制代码

watch事件监听

zookeeper允许用户在指定节点上注册一些watcher,并且在一些特定事件触发的时候,zookeeper服务端会将时间通知到感兴趣的客户端上去,该机制是zookeeper实现分布式协调服务的重要特性
zookeeper引入了watche机制来实现了发布/定略功能,能够让多个定略者,同时监听某一个对象,当一个对象自身状态变化时,会通知到定略者。
curator引入了cache来实现对zookeeper服务端事件的监听
zookeeper提供了三种watcher:
**NodeCache **: 只监听某一个特定的节点
pathChildrenCache: 监控一个ZNode的子节点
TreeCache: 监听整个数的全部节点
监听器实现:

1. NodeCache nodeCache = new NodeCache(client,"/xjy",false); // 是否压缩,获取数据时候需要解压缩(但是数据传输更快)
2.         nodeCache.getListenable().addListener(() -> {
3.             System.out.println("节点数据发生变化,新数据为:" + new String(nodeCache.getCurrentData().getData()));            
4. });
5. nodeCache.start(); //开启监听

复制代码

分布式锁

在举行单机应用开发的时候,涉及到并发同步的时候,我们使用synchronized大概lock的方式啦办理多线程代码同步题目,这里的多线程在同一个jvm之下,
如果是分布式集群,属于多个jvm的工作环境,跨jvm之间无法通过多线程的锁办理同步题目
跨呆板之间,可以使用第三方的举行锁
zookeeper分布式锁原理:
焦颔首脑:

• 当客户端想要获取锁,则创建节点,使用锁,则删除节点
  
• 客户端获取锁时,在lock节点下创建临时顺序的节点
  
• 然后获取lock下面的全部子节点,客户端获取到的全部子节点后,如果发现自己创建的子节点序号最小,那么就认为该客户端获取到了锁,使用完锁后,将该节点删除
  
• 如果发现自己创建的节点并非lock全部子节点最小的,说明没有获取锁,此时客户端需要找到比自己小的那个节点,同时对其注册事件监听器,监听删除事件
  
• 如果发现比自己小的那个节点被删除,则客户端的Watcher会收到通知,如果是则获取到了锁,如果不是则重复以上步调继承获取到比自己小的一个节点并注册监听
  

锁实现:
InterprocessSemaphoreMutex: 分布式排它锁(非可重入锁)
InterProcessMutex: 分布式可重如排它锁
InterProcessReadWriteLock: 分布式读写锁
InterProcessMultiLock: 将多个锁作为单个实体管理的容器
InterProcessSemaphoeV2: 共享信号量

1. InterProcessMutex lock = new InterProcessMutex(client, "/lock");
2.         try {
3.             lock.acquire(3, TimeUnit.SECONDS); //获取锁
4.             // 业务逻辑
5.         }finally {
6.             lock.release(); // 释放锁
7.         }

复制代码

5. zookeeper集群

leader选举:

1. Serverid: 服务id: 编号越大选择算法的权重最大
2. Zxid: 数据ID: 服务器中存放的最大数据Id
3. 投票选举: 选票过半后选举成功

复制代码

角色:
1. leader领导者:
1) 处理事件哀求
2) 激趣内部个服务器的调度者
2. Followe 跟随者
1) 处理客户端非事件哀求,转发事件哀求给Leader服务器
2) 参与Leader选举投票
3. Observer观察者
1) 处理客户端非事件哀求,转发事件哀求给Leader服务器
(1) 集群搭建

• 准备三台zookeeper呆板
  
• 每台呆板的zookeeper安装目次下创还能**myid文件,**编写自己的服务id
  
• 配置zoo.cfg配置文件
  

1. tickTime=2000  
2. initLimit=10
3. syncLimit=5
4. dataDir=/home/kk/export/soft/zookeeper370/data        # 数据目录
5. clientPort=2181
6. server.1=192.168.72.88:2888:3888
7. server.2=192.168.72.89:2888:3888
8. server.3=192.168.72.90:2888:3888

复制代码

(2) 集群启动

1. # 分别在每台上启动即可
2. zkServer.sh start

复制代码

6. 图形化页面工具ZooInspector

下载:
将安装包解压后:

运行jar包:

连接zookeeper:

页面展示:

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。