Zookeeper客户端命令、JAVA API、监听原理、写数据原理以及案例

1. Zookeeper节点信息

指定服务端，启动客户端命令：

bin/zkCli.sh -server 服务端主机名:端口号

1）ls /  查看根节点下面的子节点

     ls -s /  查看根节点下面的子节点以及根节点详细信息

其中，cZxid是创建节点的事务id，每次修改Zookeeper的状态都会产生一个事务id；

ctime是节点被创建的毫秒数（从1970年开始），这里是zookeeper自带的默认节点，其ctime就是0；mZxid是节点最后被更新的事务id；

mtime是节点最后修改的毫秒数；pZxid是最后更新的子节点的事务id；ephemeralOwner如果是临时节点则表示拥有这个节点的s

ession id，如果不是临时节点则为0；

dataLength是该节点的数据长度；

numChildren是该节点的子节点数量。

2. Zookeeper节点类型

持久节点：客户端和服务端断开连接后，创建的节点不删除

短暂/临时节点：客户端和服务端断开连接后，创建的节点删除

上面两种节点还可以继续分为带序号和不带序号的，如果带序号，节点名称后面会接一个数值，顺序递增，由父节点维护。

创建永久节点：create path "val"

（注意，ls命令后面的路径不能以/结尾，这里跟Linux不一样）

查询节点的值：get -s path

创建带序号的永久节点：create -s path "val"

以相同的路径再次创建同名节点，带序号的节点会自动序号加1，不带序号的节点创建报错

以上是永久节点，退出客户端之后这些节点依然存在

创建临时节点：create -e path "val"

创建带序号的临时节点只需加上-s即可

因为已经有shuguo，weiguo，wuguo，所以新创建的带序号的临时节点的序号为3。

断开客户端之后，上面创建的临时节点wuguo会被删除。

修改节点的值：set path "newVal"

3. 监听原理

监听主要是通过getChildren和getData来实现，表面上是获取节点子节点或者节点数据的方法，但是第二个参数表示是否监听，一般为true（第二个参数也可以传一个自定义的监听器），所以实现了监听，当子节点发生增减或者节点数据发生变化时，就会通知客户端，触发process方法。getChildren和getData是Java API监听方式，稍后介绍，这里先介绍命令行监听。

命令行开启监听节点数据：get -w path

在另一个会话端修改sanguo的节点值，在本端会产生事件通知：

再次在另一个会话端修改sanguo的节点值，在本端不会产生事件通知，因为监听只生效一次，要想再次监听，需要再次注册，即执行get -w path。

监控子节点变化：ls -w path

再另一个会话端创建一个子节点，在本端会产生一个事件通知

节点删除：delete path

删除节点及其下面的子节点：deleteall path

查看节点状态：stat path

4. Java API

添加pom依赖：

<dependency><groupId>org.apache.zookeeper</groupId><artifactId>zookeeper</artifactId><version>3.5.7</version>
</dependency>

建立Zookeeper连接：

Zookeeper zk = new Zookeeper(connectString, sessionTimeout, new Watcher() {@Overridepublic void process(WatchedEvent watchedEvent) {}        
})

其中connectString是主机地址，如果有多个主机，用逗号隔开，中间不能有空格。sessionTimeout是超时时间，单位是微秒。第三个参数是监听器，里面一般是根据事件类型以及事件路径来做相应的处理，也可在里面继续调用getChildren或者getData方法实现持续监听。

一旦连接上Zookeeper之后就会调用到process方法，里面一般会根据事件类型来对某个countDownLatch变量进行减1操作，在主线程中会等待这个变量为0，即等待Zookeeper连接上。

创建节点：

String node = zk.create(path, data, ZooDfs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);

监控子节点的增删（注册监听）：

List<String> children = zk.getChildren(path, true)for (String child : children) {System.out.println(child);
}

要想验证对子节点增删的监听，首先在java主线程中添加一个睡眠的函数，使其持续运行不至于很快结束，然后在process回调中添加相应的打印代码（比如继续getChildren，打印子节点信息），这样手动去添加节点，会执行到process函数中的打印信息。

判断节点是否存在：

Stat stat = ck.exists(path, false);
System.out.println(stat == null ? "not exist" : "exist");

5. 写数据原理

1）写请求直接发给Leader

其中，只要有半数节点写完，就可以发送ack给客户端，其他没写的服务端稍后再写。

2)  写请求发给Follower

这里也是半数节点写完就发送ack给客户端，所不同的是由接受写请求的Follower发送给客户端，而不是Leader，因为客户端最开始建立连接的是Follower。

6. 服务器动态上下线监听案例

分析：客户端监听服务器的上下线，本质是监听子节点的增删，服务器启动时会去Zookeeper集群注册（临时）子节点，使用的是create操作，而客户端监听则是get操作。注意这里的服务器和客户端对于Zookeeper集群来说都是客户端。

于是，代码主要分两部分，服务器创建子节点和客户端监听子节点。

// 服务器
private Zookeeper zk;public static void main(String[] args) throws Exception {// 创建本类（服务器类）的对象DistributeServer server = new DistributeServer();// 建立Zookeeper连接server.getConnect()；// 注册，即创建子节点server.register(args[0]);// 服务端业务逻辑（睡觉）server.business();
}private void business() throws Exception {Thread.sleep(Long.MAX_VALUE);
}private void register(String hostName) throws Exception {String create = zk.create("/servers/" + hostName, hostName.getBytes(), ZooDef.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMRAL_SEQUENTIAL);System.out.println(hostName + "is online");
}private void getConnect() throws Exception {zk = new Zookeeper("xxx", 2000, new Watcher() {@Overridepublic void process(WatchedEvent watchedEvent){}});
}
// 客户端
private Zookeeper zk;public static void main(String[] args) throws Exception {// 创建本类（服务器类）的对象DistributeClient client = new DistributeClient();// 建立Zookeeper连接client.getConnect()；// 注册，即创建子节点client.getServerList();// 客户端业务逻辑（睡觉）client.business();
}private void business() throws Exception {Thread.sleep(Long.MAX_VALUE);
}private void getServerList() throws Exception {List<String> children = zk.getChildren("/servers", true);List<String> servers = new ArrayList<>;for (String child : children) {byte[] data = zk.getData("/servers/" + child, false, null);servers.add(new String(data));}System.out.println(servers);
}private void getConnect() throws Exception {zk = new Zookeeper("xxx", 2000, new Watcher() {@Overridepublic void process(WatchedEvent watchedEvent){getServerList();}});
}

验证时，可以先验证客户端功能，服务端可以先用create -e -s 来代替，如果客户端功能ok，再继续验证服务端功能。

7. 分布式锁案例

分析：进程用客户端表示，每个客户端进程会去Zookeeper中创建一个临时带序号的子节点，如果子节点序号最小，则表示获取到锁，否则监听前一个序号更小的节点，持有锁执行完业务之后，会删除节点，表示释放锁，后面的节点/进场即可获取到锁。

private Zookeeper zk;
private String waitPath;
private String currentNode;
private CountDownLatch connectLatch = new CountDownLatch(1);
private CountDownLatch waitLatch = new CountDownLatch(1);public DistributeClient() throws Exception {// 创建本类（服务器类）的对象DistributeClient client = new DistributeClient();// 建立Zookeeper连接getConnect()；connectLatch.await();
}// 加锁，创建临时节点，并判断是否是序号最小的节点，如果是则获取到锁，处理业务，如果不是，则监听前一个序号较小的节点
public void lock() throws Exception {// currentNode是全路径名String currentNode = zk.create("/locks/seq-", null, ZooDefs.Ids.OPEN_ACL_UNSAGE, CreateMode.EPHEMETAL_SEQUENTIAL);List<String> children = zk.getChildren("locks", false);if (children.size() == 1) {return;} else {Collections.sort(children);String thisNode = currentNode.substring("/locks/".length());int index = children.indexOf(thisNode);if (index == -1) {System.out.println("数据异常");} else if (index == 0) {return;} else {// 监听前一个节点waitPath = "/locks/" + children.get(index -1);zk.getData(waitPath, true, null);waitLatch.await();}}}public void unlock()  throws Exception {zk.delete(currentNode, -1);
}private void getConnect() throws Exception {zk = new Zookeeper("xxx", 2000, new Watcher() {@Overridepublic void process(WatchedEvent watchedEvent) {if (watchedEvent.getType() == Event.KeeperState.SyncConnected) {connectLatch.countDown();       }if (watchedEvent.getType() == Event.EventType.NodeDeleted && Event.getPath.equals(waitPath)) {waitLatch.countDown();}}});
}

测试步骤：建立两个线程，每个线程起一个客户端去加锁解锁（加日志打印），加锁解锁之间有睡眠，运行这两个线程，可以看到最终只有1个客户端去持有锁

8. Curator框架

上述分布式锁的案例中，有如下缺点：

1）会话印布链接，需要自己使用CountDownLatch处理

2）监听需要重复注册

3）代码较复杂

4）不支持多节点删除与创建

因此引入Curator框架，添加pom依赖 
<dependency><groupId>org.apache.curator</groupId><artifactId>curator-framework</artifactId><version>4.3.0</version>
</dependency>
<dependency><groupId>org.apache.curator</groupId><artifactId>curator-recipes</artifactId><version>4.3.0</version>
</dependency>
<dependency><groupId>org.apache.curator</groupId><artifactId>curator-client</artifactId><version>4.3.0</version>
</dependency>
public static void main(String[] args) {// 获取分布式锁1InterProcessMutex lock1 = new InterProcessMutex(getCuratorFramework, "/locks");// 获取分布式锁2InterProcessMutex lock2 = new InterProcessMutex(getCuratorFramework, "/locks");// 启动两个线程，分别加锁释放锁，该锁可重入// 加锁: lock1.acquire(); 释放锁: lock1.release();
}private static CuratorFramework getCuratorFramework() {ExponentialBackoffRetry retry = new ExponentialBackoffRetry(3000, 3);CuratorFramework client =  CuratorFrameworkFactory.builder().connectString("xxx").connectionTimeoutMs(2000).sessionTimeoutMs(2000).retryPolicy(retry).build();client.start();System.out.println("客户端启动成功");return client;
}

9. 面试题

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/707679.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

Rocky Linux 运维工具 firewall-cmd

Rocky Linux 运维工具 firewall-cmd

一、firewall-cmd​的简介 ​​firewall-cmd​是基于firewalld的防火墙管理工具。用户可以使用它来配置、监控和管理防火墙规则&#xff0c;包括开放端口、设置服务规则等。 二、firewall-cmd​​的参数说明 序号参数描述1​​–zone指定防火墙区域2–add-portxxx/tcp允许特定…
阅读更多...
tkinterFrame框架+标签框架LabelFrame+Toplevel窗口的使用

tkinterFrame框架+标签框架LabelFrame+Toplevel窗口的使用

1.在tkinter中&#xff0c;Frame是一个容器小部件用于组织和管理其他小部件。它可以作为一个独立的可见区域&#xff0c;也可以作为其他小部件的父容器。 import tkinter as tk import tkinter.ttk as ttk import tkinter.messagebox as mbm tk.Tk() m.title("tkinter L…
阅读更多...
MSSQL渗透测试

MSSQL渗透测试

目录 mssql数据库连接提权至服务器权限 拿到目标的IP地址&#xff0c;我们先对IP地址进行信息收集&#xff0c;收集信息资产&#xff0c;同时使用nmap对IP地址进行扫描 nmap -sC -sV IP从扫描的结果中&#xff0c;我们能知道目标服务器是windows操作系统&#xff0c;使用的是m…
阅读更多...
DAY10-内容安全过滤技术概述

DAY10-内容安全过滤技术概述

文件过滤技术流程: 应用行为控制技术具体:
阅读更多...
W-TinyLFU 算法实现

W-TinyLFU 算法实现

前言 不同于常见的 LRU 或 LFU&#xff0c;Window TinyLFU 是一种非常高效的缓存设计方案。先来看下 LRU 和 LFU 算法的缺点&#xff1a; LFU 缺点&#xff1a; 需要为每个记录项维护频率信息&#xff0c;这将消耗大量的内存空间可能存在旧数据长期不被淘汰&#xff08;一开…
阅读更多...
快速卷积介绍

快速卷积介绍

快速卷积是一种使用快速傅里叶变换&#xff08;FFT&#xff09;来有效计算两个序列&#xff08;信号、函数等&#xff09;卷积的方法。快速卷积对于数字信号处理、图像处理、音频处理等领域至关重要&#xff0c;因为它大大提高了计算卷积的效率。 卷积的概念 卷积是一种数学运…
阅读更多...
让AI给你写代码，初体验（二）-写一个flask应用

让AI给你写代码，初体验（二）-写一个flask应用

这里我们准备让AI做一个稍微复杂一点任务&#xff0c;写一个前后应用&#xff0c;具体&#xff1a; 前台用html输入股票代码&#xff0c;后台通过akshare的接口程序获取该股票的实时价格&#xff0c;然后返回显示在html 我们先用AI对话看一下&#xff0c;AI会给我们什么编码建…
阅读更多...
Flink Catalog

Flink Catalog

1.Flink侧创建 按照SQL的解析处理流程在Parse解析SQL以后&#xff0c;进入执行流程——executeInternal。   其中有个分支专门处理创建Catalog的SQL命令 } else if (operation instanceof CreateCatalogOperation) {return createCatalog((CreateCatalogOperation) operatio…
阅读更多...
[多进程] 进程间通信-笔记

[多进程] 进程间通信-笔记

文章目录 创建进程的方法Linuxforkexecsystem Windowscreateprocessshellexecutesystem 进程间通信方法管道&#xff08;Pipe&#xff09;管道的种类特点 通过文件通信内存映射&#xff08;文件映射&#xff09;匿名映射 共享内存 信号量(或者锁)消息队列Windows消息队列Linux…
阅读更多...
finedance 测试笔记

finedance 测试笔记

目录 依赖库&#xff1a; 预测流程&#xff1a; 音乐wav切割120帧 general_all.py改进 smplx 学习笔记&#xff1a; 依赖库&#xff1a; import pickle5 as picklepypi尚pickle5最高python版本3.7&#xff1a; pickle5 PyPI 解决方法&#xff0c;改为 import pickle …
阅读更多...
cpp基础学习笔记01

cpp基础学习笔记01

C和C的区别 1.语言类型&#xff1a;C 是一种过程性编程语言&#xff0c;着重于以函数为基础的结构化编程&#xff1b;而 C 是一种多范式编程语言&#xff0c;支持面向对象编程&#xff08;OOP&#xff09;和泛型编程等多种编程范式。 2.对象模型&#xff1a;C 支持类和对象的概…
阅读更多...
switch其他知识点

switch其他知识点

1.default的位置在整体输出语句中&#xff0c;放哪都可以&#xff1b; 省略的话结果会不显示&#xff1b; 2.case穿透&#xff0c;还是比较好理解的&#xff0c;因为缺少break导致会把下面的也打印&#xff0c;结果是输出多个 3.switch新特性&#xff1a;是用->减号和大于…
阅读更多...
Mysql ＜=＞ 安全等于

Mysql ＜=＞ 安全等于

<> 安全等于&#xff0c;为NULL安全的等值比较运算符&#xff08;NULL-safe equal&#xff09;&#xff0c;该操作符作用类似“”。 区别为当符号两边出现NULL值时&#xff0c;操作符会返回NULL&#xff0c;而<>会返回1&#xff08;两边操作数都为NULL时&#xff…
阅读更多...
柯桥会计培训学校，会计职称考试，考中级会计怎么证明工作年限？

柯桥会计培训学校，会计职称考试，考中级会计怎么证明工作年限？

中级会计考试是会计从业人员的重要考试之一&#xff0c;对于中级考生来说&#xff0c;工作年限证明是必不可少的一步。因此&#xff0c;在考中级会计之前&#xff0c;需要对如何证明工作年限进行了解和掌握。 为大家整理了工作年限证明相关信息&#xff0c;一起来看看吧~ 一、…
阅读更多...
Rocky Linux 运维工具 ls

Rocky Linux 运维工具 ls

一、ls 的简介 ​​ls​ 用于列出当前目录下的文件和目录&#xff0c;以及它们的属性信息。通过 ​ls​命令可以查看文件名、文件大小、创建时间等信息&#xff0c;并方便用户浏览和管理文件。 二、ls 的参数说明 序号参数描述1-a显示所有文件&#xff0c;包括以 ​.​开头的…
阅读更多...
java单元测试技巧

java单元测试技巧

Test装饰器指定断言类型 在JUnit 4中&#xff0c;你可以使用expected属性在Test注解中声明期望的异常类型。如&#xff1a; Test(expected Exception.class) public void testSqlSessionFactoryBeanWithNullDataSource() throws Exception {
阅读更多...
5G双域快网

5G双域快网

目录 一、业务场景 二、三类技术方案 2.1、专用DNN方案 2.2、ULCL方案&#xff1a;通用/专用DNNULCL分流 2.3、 多DNN方案-定制终端无感分流方案 漫游场景 一、业务场景 初期双域专网业务可划分为三类业务场景&#xff0c;学校、政务、文旅等行业均已提出公/专网融合访问需…
阅读更多...
Spring MVC HandlerAdapter原理解析

Spring MVC HandlerAdapter原理解析

在Spring MVC框架中&#xff0c;HandlerAdapter&#xff08;处理器适配器&#xff09;是一个非常重要的组件&#xff0c;它负责调用处理器&#xff08;Handler&#xff09;来处理客户端的请求。HandlerAdapter在请求处理流程中起到了桥梁的作用&#xff0c;连接了DispatcherSer…
阅读更多...
【DDD】学习笔记-领域驱动设计对持久化的影响

【DDD】学习笔记-领域驱动设计对持久化的影响

资源库的实现 如何重用资源库的实现&#xff0c;以及如何隔离领域层与基础设施层的持久化实现机制&#xff0c;具体的实现还要取决于开发者对 ORM 框架的选择。Hibernate、MyBatis、jOOQ 或者 Spring Data JPA&#xff08;当然也包括基于 .NET 的 Entity Framework、NHibernat…
阅读更多...
Acwing周赛记录

Acwing周赛记录

很难得参加一次周赛hhhhh这次参加的是第144场周赛&#xff0c;一共有三道题 AcWing 5473. 简单数对推理 给定两个整数数对&#xff0c;每个数对都包含两个 1∼9 之间的不同整数。 这两个数对恰好包含一个公共数&#xff0c;即恰好有一个整数同时包含于这两个数对。 给定这两…
阅读更多...
最新文章

Copyright @ 2022~2023