zookeeper+Springboot实现服务器动态上下线监听

本文阅读 5 分钟
首页 代码,Java 正文

文章目录

zookeeper+Springboot实现服务器动态上下线监听教程

一.什么是服务器动态上下线监听

二.编码实现

三.测试

1.启动客户端,开启监听

 2. 按照下面的流程启动服务器端 

至此,我们zookeeper+Springboot实现服务器动态上下线监听教程就结束啦~

感谢您的阅读,希望我的文章能给你带来帮助!!!

zookeeper+Springboot实现服务器动态上下线监听教程

一.什么是服务器动态上下线监听

客户端能够实时洞察到服务器上下线的变化,现在我们看看下面三个变化给集群、服务器、客户端三者的变化

初始情况

服务器3启动 

 

 服务器2下线

 从上面的图我们可以知道,在集群中,每当一台服务器上线时,都会在集群中注册一个有序且临时的节点,并通知客户端;在服务器下线的时候,服务器所注册的节点也会被删除,并通知客户端。在这样的结构下,客户端便能够通过集群实时监听服务器的上下线。

二.为什么要实现对服务器上下线的监听

在开发中,这种结构应用的非常广泛,核心用处如下:

  • 用于监听节点数据产生的变化,在zk中可以配置集群的通用配置,当配置数据发生了变化之后通知所有订阅该节点的Watcher,该节点发生事件类型
  • 用于监听节点状态的变化,比如创建一个节点、删除一个节点等对节点的操作
  • 管理客户端与服务端连接的生命周期 

三.编码实现

建议大家在实现之前可以先对zookeeper的一些API操作有一些了解,这些我在我的另外一篇文章做了详细的介绍,有需要的小伙伴可以移步去看看喔。

基于Springboot整合zookeeper实现对节点的创建、监听与判断https://blog.csdn.net/weixin_47025166/article/details/125425882?spm=1001.2014.3001.55011.在zookeeper集群中创建一个servers节点

create /servers "servers"

img

 2.创建一个简单的springboot工程并引入zookeeper

img

<!--引入对应的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.启动客户端,开启监听

img

 2. 按照下面的流程启动服务器端 

img

输入对应的服务器名,如我输入的就是:server1

img

启动成功后结果如下所示: 

 img

关注客户端的监听状况,发现已经监听到集群中已经出现了一个节点

img

为了使输出更明显,我们在zookeeper中的servers节点下创建一个server2的持久节点

img

此时客户端也监听到了集群中节点的变化

img

 4.此时我们关闭服务器端,再来观察一下客户端的监听情况

此时我们发现客户端中只输出了server2这个节点

img

至此,我们便成功实现了简单的zookeeper集群对服务器端上下线的监听。

至此,我们zookeeper+Springboot实现服务器动态上下线监听教程就结束啦~

感谢您的阅读,希望我的文章能给你带来帮助!!!

img

本文为互联网自动采集或经作者授权后发布,本文观点不代表立场,若侵权下架请联系我们删帖处理!文章出自:https://blog.csdn.net/weixin_47025166/article/details/125432919
-- 展开阅读全文 --
安全面试之XSS(跨站脚本攻击)
« 上一篇 07-24

发表评论

成为第一个评论的人

热门文章

标签TAG

最近回复