ZooKeeper命令及JavaAPI操作

news2024/9/23 21:20:51

ZooKeeper数据模型

  • ZooKeeper是一个树形目录服务，其数据模型和Uiix的文件目录树很类似，拥有一个层次化结构。
  • 这里面的每一个节点都被称为：ZNode，每个节点上都会保存自己的数据和节点信息。
  • 节点可以拥有子节点，同时也允许少量（1MB）数据存储在该节点之下。
  • 节点可以分为四大类：
    • PEFSISTENT持久化节点
    • EPHEMERAL临时节点：-e
    • PERSISTENT_SEQUENTIAL持久化顺序节点：-s
    • EPHEMERAL_SEQUENTIAL临时顺序节点：-es

ZooKeeper服务端常用命令

  • 启动ZooKeeper服务：./zkServer.sh start
  • 查看ZooKeeper服务：./zkServer.sh status
  • 停止ZooKeeper服务：./zkServer.sh stop
  • 重启ZooKeeper服务：./zkServer.sh restart

ZooKeeper客户端命令

  • ./zkCli.sh -server localhost:2181连接服务端，如果是单机后面的可以省略不写。
  • ls [/] ：查看指定节点下子节点
  • create [/app] [hrbu]：创建一个名为/app1的子节点，并存放数据。
  • get [/app] ：获取节点下的数据。
  • set [/app] [hrbu]：给指定节点设置数据
  • delete [/app] ：删除指定节点 ps：此命令无法删除存在子节点的节点，如果要删除带有子节点的节点可以是使用deleteall [/app] 命令。
  • quit 断开连接
  • help 查看命令帮助
  • create -e [/app] 创建临时节点，会话关闭就会删除
  • create -s [/app] 创建顺序节点
  • create -es [/app] 创建临时顺序节点
  • ls -s [/app] 查看节点的详细信息

使用Curator API操作Zookeeper

建立连接

@Test
public void testConnect() {
    //重试策略
    ExponentialBackoffRetry retry = new ExponentialBackoffRetry(3000, 10);
    //第一种方式
    CuratorFramework client = CuratorFrameworkFactory.newClient("192.168.130.120:2181", 60 * 1000, 15 * 1000, retry);

    //第二种方式
    CuratorFramework client1 = CuratorFrameworkFactory.builder().connectString("192.168.130.120:2181")
        .sessionTimeoutMs(60 * 1000)
        .connectionTimeoutMs(15 * 1000)
        .retryPolicy(retry).namespace("hrbu").build();
    //开启连接
    client.start();
}

参数解读

  • connectString – list of servers to connect to （ZooKeeper的地址）
    sessionTimeoutMs – session timeout （会话超时时间）
    connectionTimeoutMs – connection timeout （连接超时时间）
    retryPolicy – retry policy to use （重试策略）

在这里插入图片描述

会话超时时间和连接超时时间有默认值。

第二种链式编程的方式可以指定一个工作空间，在此客户端下的所有操作都会将此工作空间作为根目录。

注意

如果使用的是云服务器需要将指定端口打开

firewall-cmd --zone=public --add-port=2181/tcp --permanent 开放端口

firewall-cmd --zone=public --list-ports 查看已经开放的端口

systemctl restart firewalld 重启防火墙生效

最后别忘了在服务器的安全组里面添加端口，将2181端口打开

添加节点

@Test
public void testCreate1() throws Exception {
    //基本创建
    CreateBuilder createBuilder = client.create();
    //创建时不指定数据，会将当前客户端ip存到里面
    createBuilder.forPath("/app1");
    //指定数据
    createBuilder.forPath("/app2", "hello".getBytes());
}

@Test
public void testCreate2() throws Exception {
    CreateBuilder createBuilder = client.create();

    //设置节点类型，默认的类型是持久化
    //CreateMode是枚举类型
    createBuilder.withMode(CreateMode.EPHEMERAL).forPath("/app3");
}

@Test
public void testCreate3() throws Exception {
    CreateBuilder createBuilder = client.create();
    //创建多级节点，如果父节点不存在，则创建父节点。
    createBuilder.creatingParentContainersIfNeeded().forPath("/app4/app4_1");
}

查询节点

@Test
public void testGet() throws Exception {
    //查询数据
    byte[] bytes = client.getData().forPath("/app1");
    System.out.println(new String(bytes));

    //查询子节点
    List<String> strings = client.getChildren().forPath("/app4");
    strings.forEach(System.out::println);

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

修改节点

@Test
public void testSet() throws Exception {
    //修改数据
    client.setData().forPath("/app1","hrbu".getBytes());

    //根据版本修改
    int version  = 0;
    Stat stat = new Stat();
    client.getData().storingStatIn(stat).forPath("/app1");
    version = stat.getVersion();

    client.setData().withVersion(version).forPath("/app1", "HRBU".getBytes());
}

删除节点

@Test
public void testDelete() throws Exception {
    //删除单个节点
    client.delete().forPath("/app4/app4_1");

    //删除带有子节点的节点
    client.delete().deletingChildrenIfNeeded().forPath("/app4");

    //强制删除
    client.delete().guaranteed().forPath("/app4");

    //回调
    client.delete().guaranteed().inBackground(new BackgroundCallback() {
        @Override
        public void processResult(CuratorFramework client, CuratorEvent event) throws Exception {
            System.out.println("执行删除操作");
        }
    }).forPath("/app4");

}

Watch事件监听

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

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

  • ZooKeeper原生支持通过注册Watcher来进行事件监听，但是使用并不是特别方便，需要开发人员自己反复注册Watcher，比较繁琐。

  • Curator引入了Cache来时限对Zookeeper服务端事件的监听。

  • ZooKeeper提供了三种Watcher：

    • NodeCache：只是监听某一个特定的节点。
    • PathChildrenCache：监控一个Node的子节点。
    • TreeCache：可以监控整个树上的所有节点，类似于PathChildrenCache和NodeCache的组合。

NodeCache

@Test
public void testNodeCache() throws Exception {
    //NodeCache:指定一个节点注册监听器

    //创建NodeCache对象
    final NodeCache nodeCache = new NodeCache(client, "/app1");
    //注册监听
    nodeCache.getListenable().addListener(new NodeCacheListener() {
        @Override
        public void nodeChanged() throws Exception {
            System.out.println("app1节点发生变化");

            //获取修改节点后的数据
            byte[] data = nodeCache.getCurrentData().getData();
            System.out.println("变化后的节点："+new String(data));
        }
    });
    //开启监听，如果为true，则开启则开启监听，加载缓冲数据
    nodeCache.start(true);
}

PathChildrenCache

@Test
public void testPathChildrenCache() throws Exception {
    //PathChildrenCache:监听某个节点的所有子节点
    //创建监听对象
    PathChildrenCache pathChildrenCache = new PathChildrenCache(client, "/hrbu", 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)) {
                //获取数据
                byte[] data = pathChildrenCacheEvent.getData().getData();
                System.out.println(new String(data));
            }
        }
    });

    //开启
    pathChildrenCache.start();
}

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();

}

分布式锁实现

概述

  • 我们在进行单机应用开发，涉及并发同步的时候，，我们往往采用synchronized或者lock的方式来解决多线程间的代码同步问题，这时候多线程的运行都是在同一个JVM之下，没有任何问题。
  • 但当我们的应用时分布式集群工作的情况下，属于多JVM下的工作环境，跨JVM之间已经无法通过多线程的锁解决同步问题。
  • 那么就需要一种更加高级的锁机制，来处理跨机器进程之间的数据同步问题，这就是分布式锁。

Zookeeper分布式锁原理

  • 核心思想：当客户端要获取锁，则创建节点，使用完锁，则删除该节点。
    • 1.客户端获取锁时，在lock节点下创建临时顺序节点。
    • 2.然后获取lock下面的所有子节点，客户端获取到所有的子节之后，如果发现自己创建的子节点序号最小，那么就认为该客户端获取到了锁。使用完锁后，将该节点删除。
    • 3.如果发现自己创建的节点并非lock所有子节点中最小的，说明自己还没有获取到锁，此时客户端需要找到比自己小的那个节点，同时对其注册事件监听器，监听删除事件。
    • 4.如果发现比自己小的那个节点被删除，则客户端的Watcher会收到相应通知，此时再次判断自己创建的节点是否时lock子节点中序号最小的，如果是则获取到了锁，如果不是则重复以上步骤继续获取比自己小的一个节点并注册监听。

Curator实现分布式锁API

  • 在Curator中有五种锁方案：

    • InterProcessSemaphoreMutex：分布式排它锁（非可重入锁）
    • InterProcessMutex：分布式可重入排它锁
    • InterProcessReadWriteLock：分布式读写锁
    • InterProcessMultiLock：将多个锁作为单个实体管理的容器
    • InterProcessSemaphoreV2：共享信号量

案例

package com.hrbu.curator;

import org.apache.curator.RetryPolicy;
import org.apache.curator.framework.CuratorFramework;
import org.apache.curator.framework.CuratorFrameworkFactory;
import org.apache.curator.framework.recipes.locks.InterProcessMutex;
import org.apache.curator.retry.ExponentialBackoffRetry;

import java.util.concurrent.TimeUnit;

public class Ticket12306 implements Runnable{

    private int tickets = 10;//数据库的票数

    private InterProcessMutex lock ;


    public Ticket12306(){
        //重试策略
        RetryPolicy retryPolicy = new ExponentialBackoffRetry(3000, 10);
        CuratorFramework client = CuratorFrameworkFactory.builder()
                .connectString("8.130.32.75:2181")
                .sessionTimeoutMs(60 * 1000)
                .connectionTimeoutMs(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(tickets > 0){
                    System.out.println(Thread.currentThread()+":"+tickets);
                    Thread.sleep(100);
                    tickets--;
                }
            } catch (Exception e) {
                e.printStackTrace();
            }finally {
                //释放锁
                try {
                    lock.release();
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }
        }
    }
}


package com.hrbu.curator;



public class LockTest {


    public static void main(String[] args) {
        Ticket12306 ticket12306 = new Ticket12306();

        //创建客户端
        Thread t1 = new Thread(ticket12306,"携程");
        Thread t2 = new Thread(ticket12306,"飞猪");

        t1.start();
        t2.start();
    }
}

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

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

相关文章

数据链路层及交换机工作原理

数据链路层及交换机工作原理

目录 一&#xff0c;帧格式 1.1 帧头类型字段的作用 1.2 MAC地址 1.3 MTU值 二&#xff0c;交换机工作原理 2.1 交换机的端口 2.2 端口状态 三&#xff0c;交换机基本工作模式及命令 3.1 交换机的工作模式&#xff1a; 3.2 命令 一&#xff0c;帧格式 其中类型是指&am…
阅读更多...
Linux: 向内核提交补丁

Linux: 向内核提交补丁

文章目录1. 前言2. 提交内核补丁的步骤2.1 从代码仓库下载内核源码2.2 建立本地分支 linux-next_master2.3 制作一个补丁2.4 提交补丁2.4.1 配置发送邮箱2.4.2 配置 git send-email2.4.3 发送补丁1. 前言 限于作者能力水平&#xff0c;本文可能存在谬误&#xff0c;因此而给读…
阅读更多...
汽车制造商与IT公司之间的技术合作案例

汽车制造商与IT公司之间的技术合作案例

如果您对最新汽车技术感兴趣的话,您可能经常听到汽车制造商和IT公司正在合作开发技术的消息。汽车生产商为何自身不进行技术开发,而是与IT企业合作呢?因为最近随着以IT技术为基础的电动汽车等环保汽车或无人驾驶汽车等的登场和发展,汽车制造商单独进行技术开发需要花费很多时间…
阅读更多...
零死角玩转stm32初级篇6-中断

零死角玩转stm32初级篇6-中断

本篇博文目录:一.中断相关概念知识1.STM32 的中断和异常2.NVIC 中断控制器3.NVIC 结构体成员4.抢占优先级和响应优先级5.NVIC 的优先级组6.EXTI 外部中断7.中断服务函数二.按键点灯的二种实现方式1.按键和LED的原理图以及各种输入模式(浮空输入,上拉输入,下拉输入和模拟输入)2.…
阅读更多...
到墨西哥的液体货物国际快递怎么邮寄

到墨西哥的液体货物国际快递怎么邮寄

到墨西哥的液体货物国际快递怎么邮寄?有些时候邮递到墨西哥的物品&#xff0c;采用国际快递是一种很好的国际货物运输方式&#xff0c;但如果货品是液体的话&#xff0c;相对而言便会复杂一些。以下是方联货运物流分享的一些对于如何邮递液体货物国际快递的意见及注意事项&…
阅读更多...
认识进程 -了解进程调度

认识进程 -了解进程调度

前言 本篇通过介绍操作系统OS的重要功能&#xff0c;了解并发并行, 了解操作系统的一项重要功能 “进程管理” , 通过了解进程管理认识进程是操作系统资源分配的基本单位 ,如有错误&#xff0c;请在评论区指正&#xff0c;让我们一起交流&#xff0c;共同进步&#xff01; 文章…
阅读更多...
＜ Linux ＞ 多线程（线程概念 + 线程控制）

＜ Linux ＞ 多线程（线程概念 + 线程控制）

目录 1、Linux线程概念 什么是线程 简单使用线程 二级页表 线程的优点 线程的缺点 线程异常 线程用途 2、Linux进程 VS 线程 进程和线程 进程的多个线程共享 进程和线程的关系 3、Linux线程控制 POSIX线程库 线程创建pthread_create 获取线程ID pthread_self 线程等待pthrea…
阅读更多...
31-java对象内存图

31-java对象内存图

java对象内存图1.java内存分配介绍2.一个对象的内存图3.两个对象的内存图4. 两个引用指向同一个对象5. 基本数据类型和引用数据类型6. this关键字内存图6.1 就近原则的本质6.2 set/get赋值的本质6.3 小结1.java内存分配介绍 2.一个对象的内存图 3.两个对象的内存图 再创建第二个…
阅读更多...
hive中时间函数 YYYY和yyyy，MM和mm，HH和hh 区别

hive中时间函数 YYYY和yyyy，MM和mm，HH和hh 区别

yyyy-MM-dd HH:mm:ss 年-月-日 时:分:秒 YYYY 和 yyyy 区别 y/YMeaning解释yyear-of-era元年&#xff0c;我们平时理解的年&#xff1b;20221231认为是2022年Yweek-based-year基于周的年&#xff0c;只要日期那周跨年&#xff0c;都算下一年&#xff1b;2020-12-27周日&#x…
阅读更多...
Canvas

Canvas

canvas介绍 什么是 Canvas&#xff1f;Canvas 是为了解决 Web 页面中只能显示静态图片这个问题而提出的&#xff0c;一个可以使用 JavaScript 等脚本语言向其中绘制图像的 HTML 标签。 Canvas 解决了什么问题 我在 MSDN&#xff08;《Microsoft Developer Network》是微软一…
阅读更多...
金三银四面试热潮将至，靠这一份软件测试面经，offer拿到手软

金三银四面试热潮将至，靠这一份软件测试面经，offer拿到手软

不知不觉又到了新一年的金三银四&#xff0c; 去年的疫情紧张&#xff0c;造成的一系列影响我相信大家都还历历在目&#xff0c;尤其是工作这块更是如此&#xff0c;找工作的紧迫度&#xff0c;导致很大部分人群在工作发展可能并没有想象中的那样迅速。 作为一名在职的测试人员…
阅读更多...
BI数据可视化分析|套用方案，第一时间摸清家底

BI数据可视化分析|套用方案，第一时间摸清家底

奥威BI软件的通用标准方案是一套从17年经验中针对性整理而来的一套标准化的数据分析解决方案&#xff0c;无缝对接金蝶、用友全版本ERP&#xff0c;覆盖财务、库存、采购、销售多个主题&#xff0c;提供多个实用型数据分析模型和BI数据可视化报表&#xff0c;套用即生效&#x…
阅读更多...
如何解决执行webgoat-2023.4遇到的错误java.lang.UnsupportedClassVersionError

如何解决执行webgoat-2023.4遇到的错误java.lang.UnsupportedClassVersionError

问题执行java -jar webgoat-2023.4.jar报如下错误&#xff0c;Exception in thread “main“ java.lang.UnsupportedClassVersionError&#xff0c;报错截图&#xff1a;2. 原因jvm&#xff08;java命令&#xff09;和jdk&#xff08;javac命令&#xff09;版本不一致。如果是w…
阅读更多...
前沿气候预测方法（精选）

前沿气候预测方法（精选）

气候预测方法ClimaxGraphcastCLCRNEarthformerPangu另一些值得关注的方法物理约束相关模型模式误差订正模型时空预测模型其他总结Climax 基于vit的backbone 不同尺度的lead time 输入的每个时间片都像往常一样经过变量标记化、变量聚合和注意层&#xff0c;输出形状为T ℎ …
阅读更多...
CAN总线协议

CAN总线协议

阅读指引&#xff1a;术语过多&#xff0c;故各术语在第一次出现时解释&#xff0c;跳读时遇到不明的词可向上搜索看看&#xff1b;信息量过大&#xff0c;很多细节没有展开&#xff0c;正文只写多数人可以了解的基础知识&#xff0c;请按需点击文中链接阅读更多详情。1 综述CA…
阅读更多...
9 自编码器(Auto encoder)及python实现

9 自编码器(Auto encoder)及python实现

1 数据集介绍 1.1 Mnist 手写数字数据库 &#xff08;LeCun 在1998年创造&#xff09; &#xff08;1&#xff09;手写数字 0-9共10类 &#xff08;2&#xff09;训练样本60000个&#xff0c;测试样本10000个。 &#xff08;3&#xff09;图像大小 28*28 二值图像。 &#xf…
阅读更多...
[深入理解SSD系列 闪存实战2.1.5] NAND FLASH基本读操作及原理_NAND FLASH Read Operation源码实现

[深入理解SSD系列 闪存实战2.1.5] NAND FLASH基本读操作及原理_NAND FLASH Read Operation源码实现

前言 上面是我使用的NAND FLASH的硬件原理图，面对这些引脚，很难明白他们是什么含义, 下面先来个热身： 问1. 原理图上NAND FLASH只有数据线，怎么传输地址？ 答1．在DATA0～DATA7上既传输数据，又传输地址 当ALE为高电平时传输的是地址， 问2. 从NAND FLASH芯片手册可知，要…
阅读更多...
TryHackMe-Lockdown（boot2root）

TryHackMe-Lockdown（boot2root）

Lockdown 停留在 127.0.0.1。穿255.255.255.0。 端口扫描 循例 nmap Web枚举 进入80 发现跳转到了contacttracer.thm&#xff0c;将其添加进/etc/hosts 这里试了一下注入 结果这就进去了 在后台逛了一圈&#xff0c;最后还是把目光放在了图片上传点 试了一会&#xff0c;貌似…
阅读更多...
SVN 版本控制软件

SVN 版本控制软件

SVN 版本控制软件 属于C/S结构软件&#xff08;客户端与服务端&#xff09; 服务端软件&#xff1a;VisualSVN 网址&#xff1a;Downloads | VisualSVN 下载好&#xff1a;VisualSVN-Server-5.1.3-x64.msi 客户端软件&#xff1a;TortoiseSVN 网址&#xff1a;http://tor…
阅读更多...
AI技术的应用场景和要注意的问题

AI技术的应用场景和要注意的问题

AI技术可以应用到许多不同的业务场景中&#xff0c;以下这些仅仅是AI技术的一些应用场景&#xff0c;实际上&#xff0c;AI技术可以应用于任何需要处理大量数据、自动化决策和复杂问题的领域。今天和大家分享一下AI技术的应用场景和要注意的问题&#xff0c;希望对大家有所帮助…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023