zookeeper动态上下线监听
啊陈晓 人气:0zookeeper+Springboot实现服务器动态上下线监听教程
一.什么是服务器动态上下线监听
客户端能够实时洞察到服务器上下线的变化,现在我们看看下面三个变化给集群、服务器、客户端三者的变化
初始情况
服务器3启动
服务器2下线
从上面的图我们可以知道,在集群中,每当一台服务器上线时,都会在集群中注册一个有序且临时的节点,并通知客户端;在服务器下线的时候,服务器所注册的节点也会被删除,并通知客户端。在这样的结构下,客户端便能够通过集群实时监听服务器的上下线。
二.为什么要实现对服务器上下线的监听
在开发中,这种结构应用的非常广泛,核心用处如下:
- 用于监听节点数据产生的变化,在zk中可以配置集群的通用配置,当配置数据发生了变化之后通知所有订阅该节点的Watcher,该节点发生事件类型
- 用于监听节点状态的变化,比如创建一个节点、删除一个节点等对节点的操作
- 管理客户端与服务端连接的生命周期
三.编码实现
建议大家在实现之前可以先对zookeeper的一些API操作有一些了解,这些我在我的另外一篇文章做了详细的介绍,有需要的小伙伴可以移步去看看喔。
基于Springboot整合zookeeper实现对节点的创建、监听与判断
1.在集1.在zookeeper集群中创建一个servers节点
create /servers "servers"
2.创建一个简单的springboot工程并引入zookeeper
<!--引入对应的zookeeper --> <dependency> <groupId>org.apache.zookeeper</groupId> <artifactId>zookeeper</artifactId> <version>3.7.1</version> </dependency>
3.编写DistributeServer(分布式服务端)
package com.canrioyuan.zookeepertest.zkcase1; import org.apache.zookeeper.*; import java.io.IOException; //分布式服务器端 public class DistributeServer { //对应的zookeeper客户端连接,连接之间不能存在空格 private String connectString = "192.168.154.133:2181,192.168.154.134:2181,192.168.154.135:2181"; //超时时间,我们设置成2s private int sessionTimeout = 2000; //声明zookeeper服务器端 private ZooKeeper zkServer; public static void main(String[] args) throws IOException, InterruptedException, KeeperException { //1.获取zookeeper连接 DistributeServer distributeServer = new DistributeServer(); distributeServer.getConnect(); //2.注册服务器 distributeServer.register(args[0]); //3.启动 distributeServer.business(args[0]); } private void business(String url) throws InterruptedException { System.out.println("url为" + url + "的服务器正在工作中"); Thread.sleep(Long.MAX_VALUE); } private void register(String url) throws InterruptedException, KeeperException { //创建一个节点 zkServer.create("/servers/" + url, url.getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL_SEQUENTIAL); System.out.println("url为" + url + "的服务器已经上线"); } //创建到zookeeper的客户端连接 private void getConnect() throws IOException { zkServer = new ZooKeeper(connectString, sessionTimeout, new Watcher() { @Override public void process(WatchedEvent watchedEvent) { } }); } }
4.分布式客户端
package com.canrioyuan.zookeepertest.zkcase1; import org.apache.zookeeper.*; import java.io.IOException; import java.util.List; //分布式客户端 public class DistributeClient { //对应的zookeeper客户端连接,连接之间不能存在空格 private String connectString = "192.168.154.133:2181,192.168.154.134:2181,192.168.154.135:2181"; //超时时间,我们设置成2s private int sessionTimeout = 2000; //声明zookeeper客户端 private static ZooKeeper zkClient; private final String PARENT_NODE = "/servers"; public static void main(String[] args) throws IOException, InterruptedException, KeeperException { //1.获取zookeeper连接 DistributeClient distributeClient = new DistributeClient(); distributeClient.getConnect(); //2.获取servers中的子节点信息 distributeClient.getServerList(); //3.业务逻辑 distributeClient.business(); } private void business() throws InterruptedException { System.out.println("客户端正在工作中......"); Thread.sleep(Long.MAX_VALUE); } private void getServerList() throws InterruptedException, KeeperException { List<String> children = zkClient.getChildren(PARENT_NODE, true); for (String child : children) { System.out.println(child); } } private void getConnect() throws IOException { zkClient = new ZooKeeper(connectString, sessionTimeout, new Watcher() { @Override public void process(WatchedEvent watchedEvent) { try { getServerList(); } catch (InterruptedException e) { e.printStackTrace(); } catch (KeeperException e) { e.printStackTrace(); } } }); } }
四.测试
1.启动客户端,开启监听
2.按照下面的流程启动服务器端
输入对应的服务器名,如我输入的就是:server1
启动成功后结果如下所示:
关注客户端的监听状况,发现已经监听到集群中已经出现了一个节点
为了使输出更明显,我们在zookeeper中的servers节点下创建一个server2的持久节点
此时客户端也监听到了集群中节点的变化
4.此时我们关闭服务器端,再来观察一下客户端的监听情况
此时我们发现客户端中只输出了server2这个节点
至此,我们便成功实现了简单的zookeeper集群对服务器端上下线的监听。
至此,我们zookeeper+Springboot实现服务器动态上下线监听教程就结束啦~
加载全部内容