Zookeeper

【黑马程序员Zookeeper视频教程，快速入门zookeeper技术】

4 Zookeeper JavaAPI 操作

4.3 Curator API 常用操作

4.3.1 添加节点

直接开始编写 测试方法

先写一下，在每个测试方法 之前运行建立连接、在每个测试方法运行结束后关闭连接 的方法

再来一个释放资源的

    @After
    public void close(){

        if (client != null){
            client.close();
        }
    }

加上判断，防止空指针异常

OK， 这样后面的方法都可以用了

【创建节点】

/**
 * 创建节点：create 持久、临时、顺序、数据
 * 1. 基本创建
 * 2. 创建节点，带有数据
 * 3. 设置节点的类型
 * 4. 创建多级节点
 * */
@Test
public void testCreate() throws Exception {

    //1. 基本创建
    String path = client.create().forPath("/app1");
    System.out.println(path);

}

注意，我们初始化建立 连接的时候，弄了一个命名空间

但是现在

服务器上 是没有dingjiaxiong 这个节点的

直接运行

节点创建 成功，查看服务器上

没错， 自动创建了

没毛病

而且app1这个 节点是有数据 的

这个是当前 机器的IP地址【本地啊，不是服务器】

即 如果创建节点，没有指定数据，则默认将当前客户端的 ip 作为数据存储

【创建带有数据的节点】

@Test
public void testCreate() throws Exception {

    String path = client.create().forPath("/app2","haha".getBytes());
    System.out.println(path);

}

运行结果

OK，创建成功

查看 一下

没毛病

【设置节点类型】

    @Test
    public void testCreate() throws Exception {

        String path = client.create().withMode(CreateMode.EPHEMERAL).forPath("/app3");
        System.out.println(path);

    }

这样就是临时的

运行结果

OK，查看节点

可以看到，啥也没有，这个可以解释一下，我们用API 建立的会话连接 和 在服务器上命令行建立的连接 不是同一个，服务器上一直没关，但是我们 的测试中

方法一完，会话就结束关闭了，所以app3 ，立马删除消失了

现在不要它关，我就要亲眼看看app3 先

在测试方法里面搞个 死循环

@Test
public void testCreate() throws Exception {

    String path = client.create().withMode(CreateMode.EPHEMERAL).forPath("/app3");
    System.out.println(path);
    
    while (true){
        
    }

}

OK，运行结果

OK， 这边这个 会话就相当于没停了 ，直接查看命令行客户端

没毛病

但是测试方法一停

这个地方要多等一会儿， 我们直接点掉 算意外终止

【创建多级节点】

@Test
public void testCreate() throws Exception {

    String path = client.create().creatingParentsIfNeeded().forPath("/app4/p1");
    System.out.println(path);

}

运行结果

创建成功了，【这个在 命令行可做不到】

查看命令行客户端

没毛病

【这就是 创建节点了 】