Hadoop-30 ZooKeeper集群 JavaAPI 客户端 POM Java操作ZK 监听节点 监听数据变化 创建节点 删除节点

本文涉及的产品
服务治理 MSE Sentinel/OpenSergo,Agent数量 不受限
云原生网关 MSE Higress,422元/月
注册配置 MSE Nacos/ZooKeeper,118元/月
简介: Hadoop-30 ZooKeeper集群 JavaAPI 客户端 POM Java操作ZK 监听节点 监听数据变化 创建节点 删除节点

章节内容

上节我们完成了如下的内容:


ZK创建节点:永久、顺序、临时

ZK读取节点:列出、查看、更新

ZK删除节点

背景介绍

这里是三台公网云服务器,每台 2C4G,搭建一个Hadoop的学习环境,供我学习。

之前已经在 VM 虚拟机上搭建过一次,但是没留下笔记,这次趁着前几天薅羊毛的3台机器,赶紧尝试在公网上搭建体验一下。


2C4G 编号 h121

2C4G 编号 h122

2C2G 编号 h123

新建Java工程

这里就跳过了,新建一个Maven工程。

POM文件

<dependency>
    <groupId>org.apache.zookeeper</groupId>
    <artifactId>zookeeper</artifactId>
    <version>3.8.4</version>
</dependency>
<dependency>  
    <groupId>com.101tec</groupId>
    <artifactId>zkclient</artifactId>
    <version>0.11</version>
</dependency>

创建回话

public class Test01 {

    public static void main(String[] args) {
        ZkClient zkClient = new ZkClient("h121.wzk.icu:2181");
        System.out.println("ZooKeeper session created.");
    }

}

运行程序,结果如下:

创建节点

public class Test01 {

    public static void main(String[] args) {
        ZkClient zkClient = new ZkClient("h121.wzk.icu:2181");
        System.out.println("ZooKeeper session created.");
        // true 则可以递归创建目录
        zkClient.createPersistent("/wzk-java/temp", true);
        System.out.println("ZooKeeper craete ZNode");

    }

}

运行程序,结果如下:

删除节点

public class Test01 {

    public static void main(String[] args) {
        ZkClient zkClient = new ZkClient("h121.wzk.icu:2181");
        System.out.println("ZooKeeper session created.");
        // true 则可以递归创建目录
        zkClient.createPersistent("/wzk-java/temp", true);
        System.out.println("ZooKeeper create ZNode");
        // 删除数据
        zkClient.deleteRecursive("/wzk-java/temp");
        System.out.println("ZooKeeper delete recursive");
    }

}

运行程序,结果如下:

监听节点

public class Test02 {

    public static void main(String[] args) throws Exception {
        ZkClient zkClient = new ZkClient("h121.wzk.icu:2181");
        // 监听器 不会对当前目录进行监控 只会监听子目录变化!!!
        zkClient.subscribeChildChanges("/wzk-data", new IZkChildListener() {
            @Override
            public void handleChildChange(String parentPath, List<String> currentChilds) throws Exception {
                System.out.println("parentPath: " + parentPath + ", " + currentChilds);
            }
        });

        // 添加数据
        zkClient.createPersistent("/wzk-data/test-data", true);
        Thread.sleep(1000);

        // 删除数据
        zkClient.deleteRecursive("/wzk-data/test-data");
        Thread.sleep(1000);
    }

}

运行程序,结果如下:

监听数据

public class Test03 {

    public static void main(String[] args) throws Exception {
        ZkClient zkClient = new ZkClient("h121.wzk.icu:2181");
        // 序列化
        zkClient.setZkSerializer(new SerializableSerializer());

        // 判断节点是否存在
        final boolean exists = zkClient.exists("/wzk-data/test-data");
        if (!exists) {
            // 不存在则创建出来
            zkClient.createPersistent("/wzk-data/test-data", true);
            System.out.println("ZooKeeper create ZNode");
        }

        zkClient.subscribeDataChanges("/wzk-data/test-data", new IZkDataListener() {
            @Override
            public void handleDataChange(String dataPath, Object data) throws Exception {
                System.out.println("数据改变: " + dataPath + ", " + data);
            }

            @Override
            public void handleDataDeleted(String dataPath) throws Exception {
                System.out.println("数据删除: " + dataPath);
            }
        });

        // 更新数据 出发监听器
        final Object o = zkClient.readData("/wzk-data/test-data");
        zkClient.writeData("/wzk-data/test-data", "更新了数据");
        Thread.sleep(1000);

        zkClient.deleteRecursive("/wzk-data/test-data");
        Thread.sleep(1000);
    }

}

运行程序,结果如下:

相关实践学习
基于MSE实现微服务的全链路灰度
通过本场景的实验操作,您将了解并实现在线业务的微服务全链路灰度能力。
目录
相关文章
|
30天前
|
分布式计算 大数据 Java
大数据-86 Spark 集群 WordCount 用 Scala & Java 调用Spark 编译并打包上传运行 梦开始的地方
大数据-86 Spark 集群 WordCount 用 Scala & Java 调用Spark 编译并打包上传运行 梦开始的地方
17 1
大数据-86 Spark 集群 WordCount 用 Scala & Java 调用Spark 编译并打包上传运行 梦开始的地方
|
1月前
|
分布式计算 Hadoop Shell
Hadoop-35 HBase 集群配置和启动 3节点云服务器 集群效果测试 Shell测试
Hadoop-35 HBase 集群配置和启动 3节点云服务器 集群效果测试 Shell测试
67 4
|
1月前
|
SQL 分布式计算 Hadoop
Hadoop-37 HBase集群 JavaAPI 操作3台云服务器 POM 实现增删改查调用操作 列族信息 扫描全表
Hadoop-37 HBase集群 JavaAPI 操作3台云服务器 POM 实现增删改查调用操作 列族信息 扫描全表
31 3
|
1月前
|
分布式计算 Hadoop Shell
Hadoop-36 HBase 3节点云服务器集群 HBase Shell 增删改查 全程多图详细 列族 row key value filter
Hadoop-36 HBase 3节点云服务器集群 HBase Shell 增删改查 全程多图详细 列族 row key value filter
55 3
|
1月前
|
分布式计算 NoSQL Java
Hadoop-32 ZooKeeper 分布式锁问题 分布式锁Java实现 附带案例和实现思路代码
Hadoop-32 ZooKeeper 分布式锁问题 分布式锁Java实现 附带案例和实现思路代码
40 2
|
1月前
|
分布式计算 监控 Hadoop
Hadoop-29 ZooKeeper集群 Watcher机制 工作原理 与 ZK基本命令 测试集群效果 3台公网云服务器
Hadoop-29 ZooKeeper集群 Watcher机制 工作原理 与 ZK基本命令 测试集群效果 3台公网云服务器
36 1
|
12天前
|
监控 安全 Java
在 Java 中使用线程池监控以及动态调整线程池时需要注意什么?
【10月更文挑战第22天】在进行线程池的监控和动态调整时,要综合考虑多方面的因素,谨慎操作,以确保线程池能够高效、稳定地运行,满足业务的需求。
91 38
|
9天前
|
安全 Java
java 中 i++ 到底是否线程安全?
本文通过实例探讨了 `i++` 在多线程环境下的线程安全性问题。首先,使用 100 个线程分别执行 10000 次 `i++` 操作,发现最终结果小于预期的 1000000,证明 `i++` 是线程不安全的。接着,介绍了两种解决方法:使用 `synchronized` 关键字加锁和使用 `AtomicInteger` 类。其中,`AtomicInteger` 通过 `CAS` 操作实现了高效的线程安全。最后,通过分析字节码和源码,解释了 `i++` 为何线程不安全以及 `AtomicInteger` 如何保证线程安全。
java 中 i++ 到底是否线程安全?
|
3天前
|
存储 设计模式 分布式计算
Java中的多线程编程:并发与并行的深度解析####
在当今软件开发领域,多线程编程已成为提升应用性能、响应速度及资源利用率的关键手段之一。本文将深入探讨Java平台上的多线程机制,从基础概念到高级应用,全面解析并发与并行编程的核心理念、实现方式及其在实际项目中的应用策略。不同于常规摘要的简洁概述,本文旨在通过详尽的技术剖析,为读者构建一个系统化的多线程知识框架,辅以生动实例,让抽象概念具体化,复杂问题简单化。 ####
|
5天前
|
Java 开发者
在Java多线程编程的世界里,Lock接口正逐渐成为高手们的首选,取代了传统的synchronized关键字
在Java多线程编程的世界里,Lock接口正逐渐成为高手们的首选,取代了传统的synchronized关键字
23 4