create /servers "servers"

 <!--引入對應(yīng)的zookeeper -->
        <dependency>
            <groupId>org.apache.zookeeper</groupId>
            <artifactId>zookeeper</artifactId>
            <version>3.7.1</version>
        </dependency>

package com.canrioyuan.zookeepertest.zkcase1;
 
import org.apache.zookeeper.*;
 
import java.io.IOException;
 
//分布式服務(wù)器端
public class DistributeServer {
 
    //對應(yīng)的zookeeper客戶端連接,連接之間不能存在空格
    private String connectString = "192.168.154.133:2181,192.168.154.134:2181,192.168.154.135:2181";
    //超時(shí)時(shí)間，我們設(shè)置成2s
    private int sessionTimeout = 2000;
    //聲明zookeeper服務(wù)器端
    private ZooKeeper zkServer;
 
    public static void main(String[] args) throws IOException, InterruptedException, KeeperException {
        //1.獲取zookeeper連接
        DistributeServer distributeServer = new DistributeServer();
        distributeServer.getConnect();
 
        //2.注冊服務(wù)器
        distributeServer.register(args[0]);
 
 
        //3.啟動(dòng)
        distributeServer.business(args[0]);
    }
 
    private void business(String url) throws InterruptedException {
        System.out.println("url為" + url + "的服務(wù)器正在工作中");
        Thread.sleep(Long.MAX_VALUE);
    }
 
    private void register(String url) throws InterruptedException, KeeperException {
        //創(chuàng)建一個(gè)節(jié)點(diǎn)
        zkServer.create("/servers/" + url, url.getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL_SEQUENTIAL);
 
        System.out.println("url為" + url + "的服務(wù)器已經(jīng)上線");
    }
 
 
    //創(chuàng)建到zookeeper的客戶端連接
    private void getConnect() throws IOException {
        zkServer = new ZooKeeper(connectString, sessionTimeout, new Watcher() {
            @Override
            public void process(WatchedEvent watchedEvent) {
 
            }
        });
    }
}

package com.canrioyuan.zookeepertest.zkcase1;
 
import org.apache.zookeeper.*;
 
import java.io.IOException;
 
import java.util.List;
 
//分布式客戶端
public class DistributeClient {
    //對應(yīng)的zookeeper客戶端連接,連接之間不能存在空格
    private String connectString = "192.168.154.133:2181,192.168.154.134:2181,192.168.154.135:2181";
    //超時(shí)時(shí)間，我們設(shè)置成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中的子節(jié)點(diǎn)信息
        distributeClient.getServerList();
 
        //3.業(yè)務(wù)邏輯
        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();
                }
            }
        });
    }
}