本地java【动态监听】zk集群节点变化

【README】搭建zk cluster， refer 2 https://blog.csdn.net/PacosonSWJTU/article/details/111404364

【1】动态监听代码，需要写在建立zk 连接的watcher 实现类里，如下：

public class TestZK {/*** zk server 连接串 */private String connectString  = "192.168.163.201:2181,192.168.163.202:2181,192.168.163.203:2181";/*** 超时时间*/private int sessionTimeout = 3000;  /*** zk客户端实例 */private ZooKeeper zkClient; /*** 0-获取zk连接 * @throws IOException*/@Before  public void init() throws IOException {/* 连接zk服务器   */zkClient = new ZooKeeper(connectString, sessionTimeout, new Watcher() {@Overridepublic void process(WatchedEvent event) {try {/*3-获取子节点并监控节点变化*/System.out.println("-------watcher start---------");zkClient.getChildren("/", true).stream().forEach(System.out::println);System.out.println("-------watcher end ---------");} catch (KeeperException e) {e.printStackTrace();} catch (InterruptedException e) {e.printStackTrace();}}});}/*** 2-获取子节点 * @throws InterruptedException * @throws KeeperException */@Testpublic void getNode() throws KeeperException, InterruptedException {System.out.println("-------getNode start---------");zkClient.getChildren("/", false).stream().forEach(System.out::println);System.out.println("-------getNode end---------");try {System.in.read(); // 阻塞，主线程不结束 } catch (IOException e) {e.printStackTrace();} }/*sichuanzookeeperstar*/}

【2】 centos8 zk 客户端新建和删除节点

log: zk client operation on centos 8

[zk: localhost:2181(CONNECTED) 0] ls /
[sichuan, zookeeper, guangdong]
[zk: localhost:2181(CONNECTED) 1] rmr /guangdong
[zk: localhost:2181(CONNECTED) 2]
[zk: localhost:2181(CONNECTED) 2] ls /
[sichuan, zookeeper]
[zk: localhost:2181(CONNECTED) 3] create /shanghai "shanghai city"
Created /shanghai
[zk: localhost:2181(CONNECTED) 4] ls /
[shanghai, sichuan, zookeeper]
[zk: localhost:2181(CONNECTED) 5] create /beijing "beijinj city"
Created /beijing
[zk: localhost:2181(CONNECTED) 6] ls /
[shanghai, sichuan, beijing, zookeeper]
[zk: localhost:2181(CONNECTED) 7]

java log

 -------getNode start---------
2020-12-19 15:07:05,968 INFO [org.apache.zookeeper.ClientCnxn] - Opening socket connection to server 192.168.163.201/192.168.163.201:2181. Will not attempt to authenticate using SASL (unknown error)2020-12-19 15:07:06,004 INFO [org.apache.zookeeper.ClientCnxn] - Socket connection established to 192.168.163.201/192.168.163.201:2181, initiating session2020-12-19 15:07:06,011 INFO [org.apache.zookeeper.ClientCnxn] - Session establishment complete on server 192.168.163.201/192.168.163.201:2181, sessionid = 0x1767ab9b8f10001, negotiated timeout = 4000-------watcher start---------
sichuan
zookeeper
guangdong
-------watcher end ---------
sichuan
zookeeper
guangdong
-------getNode end---------
-------watcher start---------
sichuan
zookeeper
-------watcher end ---------
-------watcher start---------
shanghai
sichuan
zookeeper
-------watcher end ---------
-------watcher start---------
shanghai
sichuan
beijing
zookeeper
-------watcher end ---------

bingo !

本地java【动态监听】zk集群节点变化相关推荐

Zookeeper——服务器动态上下线、客户端动态监听
文章目录: 1.前言 2.实操步骤 2.1 服务端代码 2.2 客户端代码 2.3 测试 1.前言某分布式系统中,主节点可以有多台,可以动态上下线,任意一台客户端都能实时感知到主节点服务器的上下线. ...
java本地监听zk服务器节点【动态上下线】
[README] java本地访问 zk cluster, refer 2 https://blog.csdn.net/PacosonSWJTU/article/details/111404364 [ ...
zookeeper专题：使用zookeeper客户端实现动态监听节点并获取数据
文章目录 1. zookeeper原生客户端 2. Curator客户端 1. zookeeper原生客户端 zookeeper原生客户端就是zookeeper官方自带的客户端,作为代码与zk服务器交 ...
Zk监听机制入门和节点属性信息
zk监听主要是监听:节点创建,节点删除,节点改变.子节点改变我这里用node-1和node-3同时连接node-1 zk客户端监听功能一般步骤: 1.客户端设置监听事件命令:get 节点 watc ...
java 持久监听blockqueue的变化_Curator目录监听
Curator目录监听 write by donaldhan, 2018-06-29 09:40 引言上一篇文章,我们简单看一下Curator的CDRWA相关的构造器,及Curator框架实现,[C ...
Zookeeper在Dubbo中的作用及Zk集群的选举原理
强烈推荐一个大神的人工智能的教程:http://www.captainbed.net/zhanghan Zk在Dubbo中的作用 zk在dubbo中是服务注册与发现的注册中心,dubbo的调用过程是c ...
ZooKeeper实战篇之zk集群搭建、zkCli.sh操作、权限控制ACL、ZooKeeper JavaAPI使用
在看了史上最全的Zookeeper原理详解(万字长文),了解Zookeeper的原理后,你是不是蠢蠢欲动想着手实践呢?这篇文章将手把手教你在Linux上搭建ZooKeeper集群,并调用相关API实现 ...
Apache ZooKeeper - 使用源码启动ZK集群模式
文章目录 Pre 配置总览端口说明 Node 1 [zoo1.cfg ] [myid] Node 2 [zoo2.cfg ] [myid] Node 3 [zoo3.cfg ] [myid] 启动集 ...
判断zk是否挂掉_Zookeeper入门学习第一天，zk集群简单介绍
一.Zookeeper集群搭建及基本使用 1.centOs虚拟机三台 ,集群最好是奇数台容灾性好一些,由于允许不过半节点宕机,例五台可以挂掉两台,四台可以挂掉一台.简单说就是过半可用. 2.Zooke ...

本地java【动态监听】zk集群节点变化

本地java【动态监听】zk集群节点变化相关推荐

最新文章

热门文章