ZooKeeper学习：服务器动态上下线案例分析

2023-01-17 114

版权

本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

本文涉及的产品

云原生网关 MSE Higress，422元/月

服务治理 MSE Sentinel/OpenSergo，Agent数量不受限

注册配置 MSE Nacos/ZooKeeper，118元/月

简介： ZooKeeper学习：服务器动态上下线案例分析

一、✌题目要求

> 动态监视服务器上下线的过程

二、✌代码实现

1.✌Server服务器类

public class Server {
    private static String connectString = "hadoop151:2181,hadoop152:2181,hadoop153:2181";
    private static int sessionTimeout = 2000;
    private ZooKeeper zk = null;
    public static void main(String[] args) throws IOException, KeeperException, InterruptedException {
        args = new String[]{"hadoop153"};
        Server server = new Server();
        server.getConnect();
        server.regist(args[0]);
        server.business();
    }
  //连接ZooKeeper集群
    private void getConnect() throws IOException {
        zk = new ZooKeeper(connectString, sessionTimeout, new Watcher() {
            @Override
            public void process(WatchedEvent watchedEvent) {
            }
        });
    }
  //注册服务器，将主机名写入ZooKeeper中
    private void regist(String hostname) throws KeeperException, InterruptedException {
        String create = zk.create("/servers/server", hostname.getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL_SEQUENTIAL);
        System.out.println(hostname + " is online" + create);
    }
  //业务代码
    private void business() throws InterruptedException {
    //保持代码不结束，监控整个过程
        Thread.sleep(Long.MAX_VALUE);
    }
}

2.✌Client客户端类

public class Client {
    private static String connectString = "hadoop151:2181,hadoop152:2181,hadoop153:2181";
    private static int sessionTimeout = 2000;
    private ZooKeeper zk = null;
    public static void main(String[] args) throws InterruptedException, IOException, KeeperException {
        Client client = new Client();
        client.getConnect();
        client.getServerList();
        client.business();
    }
  //连接ZooKeeper，并实现方法
    private void getConnect() throws IOException {
        zk = new ZooKeeper(connectString, sessionTimeout, new Watcher() {
            @Override
            public void process(WatchedEvent watchedEvent) {
                try {
                    getServerList();
                } catch (KeeperException e) {
                    e.printStackTrace();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        });
    }
  //获取文件子目录文件
    private void getServerList() throws KeeperException, InterruptedException {
        List<String> children = zk.getChildren("/servers", true);
        ArrayList<String> servers = new ArrayList<>();
        for (String child : children) {
            byte[] data = zk.getData("/servers/" + child, false, null);
            servers.add(new String(data));
        }
        System.out.println(servers);
    }
    private void business() throws InterruptedException {
        Thread.sleep(Long.MAX_VALUE);
    }
}