前言
我的电脑内存只有8G，搭建的集群虚拟机配置如下，本案例也是可以跑的，学习视频为尚硅谷的Zookeeper教程：
https://www.bilibili.com/video/BV1to4y1C7gw?p=1&vd_source=c85b4a015a69e82ad4f202bd9b87697f
需求分析
某分布式系统中，主节点可以有多台，可以动态上下线，任意一台客户端都能实时感知到主节点服务器的上下线
服务器注册
首先开启集群zk服务，再在集群上创建/servers节点
[zk: localhost:2181(CONNECTED) 10] create /servers "servers"
1 package com.atguigu.case1;
2
3 import org.apache.zookeeper.*;
4
5 import java.io.IOException;
6
7 /**
8 * @author 疯了疯了要疯了
9 * @create 2022-08-14-14:28
10 **/
11 public class DistributeServer {
12
13 private String connectString = "hadoop102:2181,hadoop103:2181,hadoop104:2181";
14 private int sessionTimeout = 90000;
15 private ZooKeeper zk;
16
17 public static void main(String[] args) throws IOException, KeeperException, InterruptedException {
18
19 DistributeServer server = new DistributeServer();
20
21 //1. 获取zk连接
22 server.getConnect();
23 //2. 注册服务器到zk集群,其实就是创建节点（临时，带序号）
24 server.regist(args[0]);
25 //3. 启动业务逻辑(睡觉)
26 server.business();
27
28
29 }
30 // 业务功能
31 private void business() throws InterruptedException {
32 Thread.sleep(Long.MAX_VALUE);
33 }
34 // 注册服务器
35 private void regist(String hostname) throws KeeperException, InterruptedException {
36 String create = zk.create("/servers"+hostname, hostname.getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL_SEQUENTIAL);
37
38 System.out.println(hostname + "is online" + create);
39 }
40 // 创建到 zk 的客户端连接
41 private void getConnect() throws IOException {
42
43 zk = new ZooKeeper(connectString, sessionTimeout, new Watcher() {
44
45 @Override
46 public void process(WatchedEvent event) {
47
48 }
49 });
50 }
51 }
注意如果程序报错KeeperErrorCode = ConnectionLoss的话，可以将sessionTimeout的时间设置长些。
服务器监听
客户端代码
1 package com.atguigu.case1;
2
3 import org.apache.zookeeper.KeeperException;
4 import org.apache.zookeeper.WatchedEvent;
5 import org.apache.zookeeper.Watcher;
6 import org.apache.zookeeper.ZooKeeper;
7
8 import java.io.IOException;
9 import java.util.ArrayList;
10 import java.util.List;
11
12 /**
13 * @author 疯了疯了要疯了
14 * @create 2022-08-14-14:45
15 **/
16 public class DistributeClient {
17
18 private String connectString = "hadoop102:2181,hadoop103:2181,hadoop104:2181";
19 private int sessionTimeout = 90000;
20 private ZooKeeper zk;
21
22 public static void main(String[] args) throws IOException, KeeperException, InterruptedException {
23 DistributeClient client = new DistributeClient();
24
25 //1. 获取zk连接
26 client.getConnect();
27 //2. 监听servers下面子节点的增加和删除
28 client.getServerList();
29 //3. 业务逻辑（睡觉）
30 client.business();
31
32 }
33
34 private void business() throws InterruptedException {
35 Thread.sleep(Long.MAX_VALUE);
36 }
37 //1.获取服务器子节点信息，并且对父节点进行监听
38 private void getServerList() throws KeeperException, InterruptedException {
39 List<String> children = zk.getChildren("/servers", true);
40 // 2 存储服务器信息列表
41 ArrayList<String> servers = new ArrayList<>();
42 // 3 遍历所有节点，获取节点中的主机名称信息
43 for (String child : children) {
44 byte[] data = zk.getData("/servers/" + child, false, null);
45
46 servers.add(new String(data));
47 }
48
49 // 4 打印服务器列表信息
50 System.out.println(servers);
51 }
52 //创建到zk的客户端连接
53 private void getConnect() throws IOException {
54 zk = new ZooKeeper(connectString, sessionTimeout, new Watcher() {
55
56 @Override
57 public void process(WatchedEvent event) {
58 try {
59 //再次启动监听
60 getServerList();
61 } catch (KeeperException e) {
62 e.printStackTrace();
63 } catch (InterruptedException e) {
64 e.printStackTrace();
65 }
66 }
67 });
68 }
69 }
测试
1）在 Linux 命令行上操作增加,减少服务器
（1）启动 DistributeClient 客户端
（2）在 hadoop102 上 zk 的客户端/servers 目录上创建临时带序号节点
[zk: localhost:2181(CONNECTED) 1] create -e -s /servers/hadoop101 "hadoop101" [zk: localhost:2181(CONNECTED) 2] create -e -s /servers/hadoop101 "hadoop102"
（3）观察 Idea 控制台变化
（4）执行删除操作
[zk: localhost:2181(CONNECTED) 8] delete /servers/hadoop1010000000004
（5）观察 Idea 控制台变化
2）在 Idea 上操作增加,减少服务器
（1）启动 DistributeClient 客户端（如果已经启动过，不需要重启）
（2）启动 DistributeServer 服务
①点击 Edit Configurations
②在弹出的窗口中（Program arguments）输入想启动的主机，例如，hadoop102
③回到 DistributeServer 的 main 方 法 ， 右 键 ， 在 弹 出 的 窗 口 中 点 击 Run“DistributeServer.main()”
④观察 DistributeServer 控制台，提示 hadoop102 is working
⑤观察 DistributeClient 控制台，提示 hadoop102 已经上线
这样在客户端hadoop101就下线了，因为这里创建的是临时节点，运行102的程序时会把运行101的程序停了然后重新运行，这就会导致101多连接客户端断掉，那101这个临时节点就死了。
标签：zk,void,private,servers,案例,2181,服务器,节点
From： https://www.cnblogs.com/jinci2022/p/16589623.html