Zookeeper的学习笔记

news2025/1/24 5:40:57

Zookeeper概念

Zookeeper是一个树形目录服务，简称zk。

Zookeeper是一个分布式的、开源的分布式应用程序的协调服务

Zookeeper提供主要的功能包括：配置管理，分布式锁，集群管理

Zookeeper命令操作

zk数据模型

zk中的每一个节点都被称为：ZNode，每个节点上都会保存自己的数据和节点信息。节点可以拥有子节点，同时也允许少量（1MB）数据存储在该节点之下

节点可以分为四大类：

  • PERSISTENT 持久化节点
  • EPHEMERAL 临时节点：-e
  • PERSISTENT_SEQUENTIAL持久化顺序节点：-s
  • EPHEMERAL_SEQUENTIAL临时顺序节点：-es

zk服务端命令

启动zk服务

./zkServer.sh start

zk查看zk服务状态

./zkServer.sh status

停止zk服务

./zkServer.sh stop

重启zk服务

./zkServer.sh restart

zk客户端命令

zkCli.sh连接ZooKeeper服务命令

./zkCli.sh [-server ip地址:2181] （如果是连接本机zk服务，可以省略[]中的内容）

查看zk中的节点

ls /[节点名称]

创建节点方法

create [节点类型] /父节点 [存储信息] (存储信息可以不写)

临时节点创建 -e(服务器关闭，下次连接就会删除)

顺序节点创建 -s

临时顺序节点创建 -es

查看节点存储信息的方法

get /目录

ls -s 是查询结点状态信息

设置节点数据

set /目录 存储信息

删除节点

delete /目录(只能删除空目录)

deleteall /目录(有子结点也可以删除)

在创建节点时，如果没有指定存储数据，那么默认存储的数据是当前服务器的ip地址

Curator介绍

CUrator是Zookeeper的Java客户端库，常见的Zookeeper Java API有三种：

  • 原生Java API
  • ZkClient
  • Curator

相较于原生Java API，Curator使用较为简单，其次，高版本的Curator可以向下兼容zk，但zk无法向下兼容Curator

Curator API常用操作

连接zk服务

一共有两种连接客户端的方式，一种是通过newClient()，一种是通过Builder链式编程创建客户端对象

@Test
public void test() throws Exception {
    //指定重试策略
    RetryPolicy retryPolicy = new ExponentialBackoffRetry(3000, 10);
    //第一种连接zk方式
    /*
    参数1：指定需要连接的zk地址与端口，如果是集群模式，使用,分隔开
    参数2：会话超时时间
    参数3：连接超时时间
    参数4：重试策略
     */
    CuratorFramework client = CuratorFrameworkFactory.newClient("192.168.116.131:2181", 60 * 1000, 15 * 1000, retryPolicy);
    client.start();
    //第二种连接方式，可以指定namespace，其实是指定根目录（此后该客户端对象的curd操作都会在指定的根目录下进行）
    CuratorFramework client2 = CuratorFrameworkFactory.builder().connectString("192.168.116.131:2181")
            .sessionTimeoutMs(60 * 1000)
            .connectionTimeoutMs(15 * 1000)
            .retryPolicy(retryPolicy)
            .namespace("zmt").build();
	client2.start();
}

创建节点

创建节点默认创建节点类型为持久化，返回结果为路径，如果不指定节点存储类型，那么默认存储客户端的ip地址

@Test
public void testCreate() throws Exception {
    //如果不指定参数2，那么该节点的存储数据为客户端的ip地址
    String path = client.create().forPath("/app1","zhangsan".getBytes());
    System.out.println(path);

    //我们可以通过指定withMode来确定需要创建的节点类型，参数为枚举类
    client.create().withMode(CreateMode.EPHEMERAL).forPath("/app2");

    //创建多级节点,创建父结点，如果需要
    client.create().creatingParentsIfNeeded().forPath("/app3/p1");
}

查询节点

我们可以查询节点的存储信息，也可以查询节点的子节点信息，也可以查询节点的状态信息

@Test
public void testGet() throws Exception {
    //获取节点存储信息
    byte[] data = client.getData().forPath("/app1");
    System.out.println(new String(data));

    //获取子节点信息
    List<String> list = client.getChildren().forPath("/app3");
    System.out.println(list);

    //获取节点状态信息
    Stat status = new Stat();
    client.getData().storingStatIn(status).forPath("/app1");
    System.out.println(status);
}

修改节点

因为可能存在多个客户端连接同一个zookeeper，因此可能会出现修改节点数据时，其他节点也在修改的问题，因此为了避免出现同时修改同一个数据的情况发生，我们应该先获取数据的版本，然后修改数据时根据数据的版本是否一致再决定是否进行修改。

@Test
public void testSetForVersion() throws Exception {
    int version;
    Stat stat = new Stat();
    client.getData().storingStatIn(stat).forPath("/app1");
    version = stat.getVersion();
    System.out.println(version);
    client.setData().withVersion(version).forPath("/app1","lisi".getBytes());
}

删除节点

一般我们都要添加guaranteed()方法来避免网络问题产生的删除失败的问题

@Test
public void testDelete() throws Exception {
    //删除单个节点
    client.delete().forPath("/app1");
    //删除多级节点
    client.delete().deletingChildrenIfNeeded().forPath("/app3");
    //删除失败进行重试，直到删除成功
    //比如说网络不好，导致删除失败，可以重复进行删除
    client.delete().guaranteed().forPath("/app2");
    //删除回调
    client.delete().guaranteed().inBackground(new BackgroundCallback() {
        //执行回调方法
        @Override
        public void processResult(CuratorFramework client, CuratorEvent event) throws Exception {
            System.out.println("节点被删除");
            System.out.println(event);
        }
    }).forPath("/app4");
}

Watch事件监听

zk运行用户在指定节点上注册一些Watcher，并且在一些特定事件触发的时候，zk服务端会将事件通知到感兴趣的客户端上去，该机制是zk实现分布式协调服务的重要特性。

zk中引入了Watch机制来实现了发布订阅功能，能够让多个订阅者同时监听某一个对象，当一个对象自身状态发生变化时，会通知所有的订阅者

zk提供了3种Watcher：

  • NodeCache：只监听一个特定结点
  • PathChildrenCache：监控一个Znode的子节点
  • TreeCache：前两个结合，监听自己和自己所有子节点

NodeCache的简单使用

@Test
public void testNodeCache() throws Exception {
    NodeCache nodeCache = new NodeCache(client, "/app1");
    nodeCache.getListenable().addListener(new NodeCacheListener() {
        @Override
        public void nodeChanged() throws Exception {
            System.out.println("节点发生变化");
            //获取节点变化后的值
            byte[] data = nodeCache.getCurrentData().getData();
            System.out.println(new String(data));
        }
    });

    nodeCache.start();
    while (true){

    }
}

PathChildrenCache的简单使用

@Test
public void testChildrenCache() throws Exception {
    PathChildrenCache pathChildrenCache = new PathChildrenCache(client, "/", true);
    pathChildrenCache.getListenable().addListener(new PathChildrenCacheListener() {
        @Override
        public void childEvent(CuratorFramework curatorFramework, PathChildrenCacheEvent pathChildrenCacheEvent) throws Exception {
            System.out.println("节点发生变化");
            System.out.println(pathChildrenCacheEvent);
            PathChildrenCacheEvent.Type type = pathChildrenCacheEvent.getType();
            if (type.equals(PathChildrenCacheEvent.Type.CHILD_UPDATED)){
                //如果是update事件
                byte[] data = pathChildrenCacheEvent.getData().getData();
                System.out.println(new String(data));
            }
        }
    });

    pathChildrenCache.start();

    while (true) {

    }
}

TreeCache的简单使用

@Test
public void testTreeCache() throws Exception {
    TreeCache treeCache = new TreeCache(client,"/");
    treeCache.getListenable().addListener(new TreeCacheListener() {
        @Override
        public void childEvent(CuratorFramework curatorFramework, TreeCacheEvent treeCacheEvent) throws Exception {
            System.out.println("数据发生变化");
            System.out.println(treeCacheEvent);
        }
    });
    treeCache.start();

    while (true) {
        
    }
}

分布式锁

作用于多个JVM环境，保证多线程安全。

实现分布式锁的原理：当客户端要获取锁时，创建节点，使用完锁，删除该节点

  • 客户端获取锁时，在lock节点下创建临时顺序结点
  • 然后客户端获取lock下面所有的子节点，如果发现自己创建的子节点序号最小，那么就认为该客户端获取到了锁。使用完后把节点删除
  • 如果不是最小的结点，说明此时自己还没有获取到锁，此时客户端需要找到比自己小的哪个结点，同时对其注册事件监听器，监听删除事件。
  • 如果比自己小一个的结点被删除，则客户端的Watcher会收到通知，此时再次判断自己的结点是否最小，如果不是，重复以上步骤

采取临时节点是为了避免客户端在获取到锁之后处理业务时宕机，当客户端宕机之后，会话结束，临时节点会自动删除

Curator实现分布式锁API

一共有五种方案：

  • 分布式排他锁
  • 分布式可重入排他锁
  • 分布式读写锁
  • 将多个锁作为单个实体管理的容器
  • 共享信号量

一个简单的售票案例

public class Ticket12306 implements Runnable {
    //模拟十张票
    private int num = 10;
    //分布式可重入式锁
    private InterProcessMutex lock;

    public Ticket12306() {
        RetryPolicy retryPolicy = new ExponentialBackoffRetry(3000, 2);
        CuratorFramework client = CuratorFrameworkFactory.builder().connectString("192.168.116.131:2181")
                .connectionTimeoutMs(60*1000)
                .sessionTimeoutMs(15*1000)
                .retryPolicy(retryPolicy)
                .build();
        client.start();
        lock = new InterProcessMutex(client, "/lock");
    }

    @Override
    public void run() {
        while (true) {
            try {
                lock.acquire(3, TimeUnit.SECONDS);
                if (num > 0) {
                    Thread.sleep(100);
                    System.out.println(Thread.currentThread().getName() + "出售了一张票：" + num);
                    num--;
                }
            } catch (Exception e) {
                System.out.println("我出错了？？");
                e.printStackTrace();
            } finally {
                try {
                    lock.release();
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }
        }
    }
}

测试 

public class TestTicket {
    @Test
    public void testTicket() throws Exception {
        Ticket12306 ticket = new Ticket12306();
        Thread t1 = new Thread(ticket, "携程");
        Thread t2 = new Thread(ticket, "飞猪");
        t1.start();
        t2.start();
        while(true){

        }
    }
}

实现分布式锁的核心代码如下

new 一个锁类型对象lock

lock.acquire()//获取锁

需要上锁的功能

lock.release();//释放锁

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

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

相关文章

初识大数据，一文掌握大数据必备知识文集(3)

初识大数据，一文掌握大数据必备知识文集(3)

&#x1f3c6;作者简介&#xff0c;普修罗双战士&#xff0c;一直追求不断学习和成长&#xff0c;在技术的道路上持续探索和实践。 &#x1f3c6;多年互联网行业从业经验&#xff0c;历任核心研发工程师&#xff0c;项目技术负责人。 &#x1f389;欢迎 &#x1f44d;点赞✍评论…
阅读更多...
SpringMVC基础知识（持续更新中~）

SpringMVC基础知识（持续更新中~）

笔记&#xff1a; https://gitee.com/zhengguangqq/ssm-md/blob/master/ssm%20md%E6%A0%BC%E5%BC%8F%E7%AC%94%E8%AE%B0/%E4%B8%89%E3%80%81SpringMVC.md 细节补充&#xff1a; ​​​​​​​
阅读更多...
你还不会排序算法吗

你还不会排序算法吗

>欢迎关注博主 Mindtechnist 或加入【智能科技社区】一起学习和分享Linux、C、C、Python、Matlab&#xff0c;机器人运动控制、多机器人协作&#xff0c;智能优化算法&#xff0c;滤波估计、多传感器信息融合&#xff0c;机器学习&#xff0c;人工智能等相关领域的知识和技术…
阅读更多...
用C实现字符串比较和用C实现字符串逆序输出-----(C每日一编程)

用C实现字符串比较和用C实现字符串逆序输出-----(C每日一编程)

一&#xff0c;字符串比较 参考代码&#xff1a; int fun(char* p, char* q) {int i 0;while (*p *q) {if (*p \0)return 0;else p, q;}return *p - *q; } void main() {int n fun("goods", "people");printf("%d", n); }运行结果&#xf…
阅读更多...
九州未来大模型一体机，加速AI应用落地

九州未来大模型一体机，加速AI应用落地

2023年已接近尾声&#xff0c;对于中国人工智能产业而言&#xff0c;这一年注定成为一个重要的转折点。在不同行业中&#xff0c;人工智能的应用不断涌现&#xff0c;众多大模型如雨后春笋般涌现。然而&#xff0c;在这一发展过程中也不可避免地出现了一系列问题&#xff0c;包…
阅读更多...
Python电能质量扰动信号分类(二)基于CNN模型的一维信号分类

Python电能质量扰动信号分类(二)基于CNN模型的一维信号分类

目录 前言 1 电能质量数据集制作与加载 1.1 导入数据 1.2 制作数据集 2 CNN-2D分类模型和训练、评估 2.1 定义CNN-2d分类模型 2.2 定义模型参数 2.3 模型结构 2.4 模型训练 2.5 模型评估 3 CNN-1D分类模型和训练、评估 3.1 定义CNN-1d分类模型 3.2 定义模型参数 …
阅读更多...
六西格玛的科技漩涡——张驰咨询如何促成企业变革

六西格玛的科技漩涡——张驰咨询如何促成企业变革

在管理的海洋里&#xff0c;六西格玛管理是一艘稳健的航船&#xff0c;在质量管理的汪洋中乘风破浪&#xff0c;尽管质疑之声像远处的风暴不断逼近&#xff0c;但张驰咨询公司依靠这艘航船坚持初心&#xff0c;驭风而行。 20载耕耘&#xff0c;张驰咨询不仅仅是培养了超过8000…
阅读更多...
C++_面向对象介绍

C++_面向对象介绍

介绍 面向对象 What(为什么使用面向对象) 1.适合开发大型软件 2.数据抽象、代码复用、提升效率、降低成本 3.可利用已有现成的设计模式和应用框架Where(什么是面向对象) 1.将软件看成对象组成的空间&#xff0c;每个对象都拥有足够智能&#xff0c;能了解其他对象信息&#xf…
阅读更多...
IntelliJ IDEA 2020将SpringMVC项目打成war包

IntelliJ IDEA 2020将SpringMVC项目打成war包

一 、打开 Project Structure 进行配置 1. 打开方式 &#xff08;1&#xff09;CtrlAltShiftS &#xff08;2&#xff09;File->Project Structure &#xff08;3&#xff09;点击如下图标&#xff1a; 2. 进入 Project Structure&#xff0c;添加Artifacts Web Applica…
阅读更多...
【每日一题】得到山形数组的最少删除次数

【每日一题】得到山形数组的最少删除次数

文章目录 Tag题目来源解题思路方法一&#xff1a;最长递增子序列 写在最后 Tag 【最长递增子序列】【数组】【2023-12-22】 题目来源 1671. 得到山形数组的最少删除次数 解题思路 方法一&#xff1a;最长递增子序列 前后缀分解 根据前后缀思想&#xff0c;以 nums[i] 为山…
阅读更多...
第11章 GUI Page417~418 步骤五 支持方框

第11章 GUI Page417~418 步骤五 支持方框

运行效果&#xff1a; 关键代码&#xff1a; 添加头文件&#xff1a;item_rectangle.hpp //item_rectangle.hpp #ifndef ITEM_RECTANGLE_HPP_INCLUDED #define ITEM_RECTANGLE_HPP_INCLUDED #include "item_i.hpp"class RectangleItem : public IItem { public:Rec…
阅读更多...
C语言struct，union内存对齐

C语言struct，union内存对齐

测试环境&#xff1a; #include<stdio.h> int main(){//1字节对齐struct XXX{unsigned char ch;unsigned int in;unsigned short si;}__attribute__((packed));struct XXX xxx;printf("%zd\n",sizeof(xxx));//7#pragma pack(1)struct YYY{unsigned char ch;u…
阅读更多...
java-sec-code中rmi

java-sec-code中rmi

java-sec-code中rmi 暂时没有搞懂原理&#xff0c;这里只说明利用方法 java-sec-code 作者给出的是使用ysoserial进行利用 测试环境搭建 docker环境下&#xff0c;1099端口默认不开启&#xff0c;这里使用idea运行org.joychou.RMI.Server即可 个人电脑java环境分为1.8.381 1.8.…
阅读更多...
Linux下编写zlg7290驱动(3)-键盘驱动编写

Linux下编写zlg7290驱动(3)-键盘驱动编写

2.3. 数据处理实现 执行上述代码后系统中就注册了我们的input设备&#xff0c;接下来我们要做的是活得键盘的键值&#xff0c;zlg7290多可以支持64个按键&#xff0c;每个按键按下后都会产生一个中断&#xff0c;我们写驱动是可以使用轮询不断检测是否有按键也可以触发中断来判…
阅读更多...
2024年PMP考试新考纲-PMBOK第七版-项目管理原则真题解析（续1）

2024年PMP考试新考纲-PMBOK第七版-项目管理原则真题解析（续1）

从战争中学习战争。对于参加2024年PMP考试的小伙伴来说&#xff0c;最有效的学习方式是这样地&#xff1a;①阅读了教材&#xff08;PMBOK6、7和敏捷&#xff09;&#xff0c;了解基本概念&#xff1b;②反复刷近期的PMP考试真题&#xff0c;查漏补缺。 自从PMI和中国国际人才…
阅读更多...
智能优化算法应用：基于鹰栖息算法3D无线传感器网络(WSN)覆盖优化 - 附代码

智能优化算法应用：基于鹰栖息算法3D无线传感器网络(WSN)覆盖优化 - 附代码

智能优化算法应用&#xff1a;基于鹰栖息算法3D无线传感器网络(WSN)覆盖优化 - 附代码 文章目录 智能优化算法应用&#xff1a;基于鹰栖息算法3D无线传感器网络(WSN)覆盖优化 - 附代码1.无线传感网络节点模型2.覆盖数学模型及分析3.鹰栖息算法4.实验参数设定5.算法结果6.参考文…
阅读更多...
Linux内核编码规范

Linux内核编码规范

学习linux内核或者linux驱动的人应该先掌握内核编码规范&#xff0c;这样才能更好的驾驭linux内核、驱动。 下面就从这几个方面讲解一下linux内核编码规范。 注释风格、排版风格、头文件风格、变量定义、宏定义、函数 1 注释风格 1.1 注释的原则是有助于对程序的阅读和理解&…
阅读更多...
vue-内网，离线使用百度地图（地图瓦片图下载静态资源展示定位）

vue-内网，离线使用百度地图（地图瓦片图下载静态资源展示定位）

前言 最近发现很多小伙伴都在问内网怎么使用百度地图&#xff0c;或者是断网情况下能使用百度地图吗 后面经过一番研究&#xff0c;主要难点是&#xff0c;正常情况下我们是访问公网百度图片&#xff0c;数据&#xff0c;才能使用 内网时访问不了百度地图资源时就会使用不了&…
阅读更多...
CVE-2023-49898 Apache incubator-streampark 远程命令执行漏洞

CVE-2023-49898 Apache incubator-streampark 远程命令执行漏洞

项目介绍 Apache Flink 和 Apache Spark 被广泛用作下一代大数据流计算引擎。基于大量优秀经验结合最佳实践&#xff0c;我们将任务部署和运行时参数提取到配置文件中。这样&#xff0c;带有开箱即用连接器的易于使用的 RuntimeContext 将带来更轻松、更高效的任务开发体验。它…
阅读更多...
RIPV1配置实验

RIPV1配置实验

查看路由器路由表&#xff1a; 删除手工配置的静态路由项&#xff1a; Route1->Config->static Remove删除路由项 删除Route3的路由项&#xff0c;方法同上删除Route2的路由项&#xff0c;方法同上 完成路由器RIP配置&#xff1a; Route1->Config->RIP->Ne…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023