共计 6036 个字符，预计需要花费 16 分钟才能阅读完成。
作者：雨中散步撒哈拉
起源：https://liudongdong.top
公众号：雨中散步撒哈拉
备注：欢送关注公众号，学习技术，一起成长！文末福利： 上百本电子书，期待你的支付 ^v^
环境阐明:
- 服务器为 centos7 集群
- zk 为 zookeeper-3.4.10.tar.gz 版本
- jdk 为 1.8
一、创立我的项目
1. 增加依赖包，pom 文件如下
<dependencies>
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>RELEASE</version>
</dependency>
<dependency>
<groupId>org.apache.logging.log4j</groupId>
<artifactId>log4j-core</artifactId>
<version>2.8.2</version>
</dependency>
<!--
https://mvnrepository.com/artifact/org.apache.zookeeper/zook
eeper -->
<dependency>
<groupId>org.apache.zookeeper</groupId>
<artifactId>zookeeper</artifactId>
<version>3.4.10</version>
</dependency>
</dependencies>
2. 配置日志文件
资源文件创建日志配置文件 log4j.properties
log4j.rootLogger=INFO, stdout
log4j.appender.stdout=org.apache.log4j.ConsoleAppender
log4j.appender.stdout.layout=org.apache.log4j.PatternLayout
log4j.appender.stdout.layout.ConversionPattern=%d %p [%c] - %m%n
log4j.appender.logfile=org.apache.log4j.FileAppender
log4j.appender.logfile.File=target/spring.log
log4j.appender.logfile.layout=org.apache.log4j.PatternLayout
log4j.appender.logfile.layout.ConversionPattern=%d %p [%c] - %m%n
二、代码实现 zk 命令
0. 创立连贯
连贯集群 ip 和对外端口 2181，集群映射，已在 windows 做了配置
hosts 文件内容：
代码实现连贯:
private static final String IPS = "master:2181,slave1:2181,slave2:2181";
private static final int SESSIONTIMEOUT = 200;
private ZooKeeper zkClient = null;
@Test
public void contectTest() throws Exception{zkClient = new ZooKeeper(IPS, SESSIONTIMEOUT, new Watcher() {
@Override
public void process(WatchedEvent event) {}});
System.out.println("==================");
System.out.println(zkClient.getState());
System.out.println("==================");
}
运行打印后果
image.png
2. 创立节点
创立 /idea 节点，类型为长期节点
private static final String IPS = "master:2181,slave1:2181,slave2:2181";
private static final int SESSIONTIMEOUT = 200;
private ZooKeeper zkClient = null;
@Before
public void contectTest() throws Exception{zkClient = new ZooKeeper(IPS, SESSIONTIMEOUT, new Watcher() {
@Override
public void process(WatchedEvent event) {}});
System.out.println("==================");
System.out.println(zkClient.getState());
System.out.println("==================");
}
@Test
public void createTest() throws Exception{String s = zkClient.create("/idea", "helloworld".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL);
System.out.println(s);
}
打印后果
image.png
3. 监听节点变动
监控根节点下的子节点变动
private static final String IPS = "master:2181,slave1:2181,slave2:2181";
private static final int SESSIONTIMEOUT = 200;
private ZooKeeper zkClient = null;
@Before
public void contectTest() throws Exception{zkClient = new ZooKeeper(IPS, SESSIONTIMEOUT, new Watcher() {
@Override
public void process(WatchedEvent event) {System.out.println(event.getType() + "--" + event.getPath());
try {zkClient.getChildren("/", true);
} catch (KeeperException e) {e.printStackTrace();
} catch (InterruptedException e) {e.printStackTrace();
}
}
});
System.out.println("==================");
System.out.println(zkClient.getState());
System.out.println("==================");
}
@Test
public void childrenTest() throws Exception{List<String> children = zkClient.getChildren("/", true);
for (String ch : children){System.out.println(ch);
}
Thread.sleep(Long.MAX_VALUE);
}
在 xshell 典范增加节点，也能够在代码中模拟增加节点
[zk: localhost:2181(CONNECTED) 0] create -e /java "java"
Created /java
[zk: localhost:2181(CONNECTED) 1] create -e /python "java"
Created /python
打印后果
image.png
4. 判断节点是否存在
private static final String IPS = "master:2181,slave1:2181,slave2:2181";
private static final int SESSIONTIMEOUT = 200;
private ZooKeeper zkClient = null;
@Before
public void contectTest() throws Exception{zkClient = new ZooKeeper(IPS, SESSIONTIMEOUT, new Watcher() {
@Override
public void process(WatchedEvent event) {}});
System.out.println("==================");
System.out.println(zkClient.getState());
System.out.println("==================");
}
@Test
public void exTest() throws Exception{Stat exists = zkClient.exists("/test", false);
System.out.println(exists == null ? "no" : "yes");
}
打印后果
image.png
5. 测试残缺代码
package com.example.demo;
import org.apache.zookeeper.*;
import org.apache.zookeeper.data.Stat;
import org.junit.Before;
import org.junit.Test;
import java.util.List;
public class ZKDemo {
private static final String IPS = "master:2181,slave1:2181,slave2:2181";
private static final int SESSIONTIMEOUT = 200;
private ZooKeeper zkClient = null;
@Before
public void contectTest() throws Exception{zkClient = new ZooKeeper(IPS, SESSIONTIMEOUT, new Watcher() {
@Override
public void process(WatchedEvent event) {/*System.out.println(event.getType() + "--" + event.getPath());
try {zkClient.getChildren("/", true);
} catch (KeeperException e) {e.printStackTrace();
} catch (InterruptedException e) {e.printStackTrace();
}*/
}
});
System.out.println("==================");
System.out.println(zkClient.getState());
System.out.println("==================");
}
@Test
public void createTest() throws Exception{String s = zkClient.create("/idea", "helloworld".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL);
System.out.println(s);
}
@Test
public void childrenTest() throws Exception{List<String> children = zkClient.getChildren("/", true);
for (String ch : children){System.out.println(ch);
}
Thread.sleep(Long.MAX_VALUE);
}
@Test
public void exTest() throws Exception{Stat exists = zkClient.exists("/test", false);
System.out.println(exists == null ? "no" : "yes");
}
}
文末福利
蕴含 c、c++、java、python、linux、html、php 等上百本电子书！
获取形式：
搜寻并关注公众号： 雨中散步撒哈拉
回复关键词：001
正文完
