fix:zookeeper Curator 操作java api

src/main/java/com/kwan/shuyu/Ticket12306.java

@@ -27,9 +27,9 @@ public class Ticket12306 implements Runnable {
         //重试策略
         RetryPolicy retryPolicy = new ExponentialBackoffRetry(3000, 10);
         //2.第二种方式
-        //CuratorFrameworkFactory.builder();
         CuratorFramework client = CuratorFrameworkFactory.builder()
-                .connectString("192.168.149.135:2181")
+                //集群节点
+                .connectString("120.79.36.53:2181,120.79.36.53:2182,120.79.36.53:2183")
                 .sessionTimeoutMs(60 * 1000)
                 .connectionTimeoutMs(15 * 1000)
                 .retryPolicy(retryPolicy)

src/test/java/com/kwan/shuyu/LockTest.java → src/test/java/com/kwan/shuyu/Ticket12306LockTest.java

 package com.kwan.shuyu;
 
-public class LockTest {
+
+/**
+ * InterProcessMutex 分布式锁测试
+ *
+ * @author : qinyingjie
+ * @version : 2.2.0
+ * @date : 2023/5/15 09:53
+ */
+public class Ticket12306LockTest {
     public static void main(String[] args) {
         Ticket12306 ticket12306 = new Ticket12306();
         //创建客户端

src/test/java/com/kwan/shuyu/crud/CuratorTest_01_Create.java

+package com.kwan.shuyu.crud;
+
+import org.apache.curator.RetryPolicy;
+import org.apache.curator.framework.CuratorFramework;
+import org.apache.curator.framework.CuratorFrameworkFactory;
+import org.apache.curator.retry.ExponentialBackoffRetry;
+import org.junit.After;
+import org.junit.Before;
+import org.junit.Test;
+
+/**
+ * 创建节点 带有数据
+ *
+ * @author : qinyingjie
+ * @version : 2.2.0
+ * @date : 2023/5/15 09:54
+ */
+public class CuratorTest_01_Create {
+
+    private CuratorFramework client;
+
+    /**
+     * 建立连接
+     */
+    @Before
+    public void testConnect() {
+        /*
+         *
+         * @param connectString       连接字符串。zk server 地址和端口 "120.79.36.53:2181,120.79.36.53:2182,120.79.36.53:2183"
+         * @param sessionTimeoutMs    会话超时时间 单位ms
+         * @param connectionTimeoutMs 连接超时时间 单位ms
+         * @param retryPolicy         重试策略
+         */
+       /* //重试策略
+        RetryPolicy retryPolicy = new ExponentialBackoffRetry(3000,10);
+        //1.第一种方式
+        CuratorFramework client = CuratorFrameworkFactory.newClient("120.79.36.53:2181,120.79.36.53:2182,120.79.36.53:2183",
+                60 * 1000, 15 * 1000, retryPolicy);*/
+        //重试策略
+        RetryPolicy retryPolicy = new ExponentialBackoffRetry(3000, 10);
+        //2.第二种方式
+        //CuratorFrameworkFactory.builder();
+        client = CuratorFrameworkFactory.builder()
+                .connectString("120.79.36.53:2181,120.79.36.53:2182,120.79.36.53:2183")
+                .sessionTimeoutMs(60 * 1000)
+                .connectionTimeoutMs(15 * 1000)
+                .retryPolicy(retryPolicy)
+                .namespace("itheima")
+                .build();
+        //开启连接
+        client.start();
+    }
+
+    @After
+    public void close() {
+        if (client != null) {
+            client.close();
+        }
+    }
+
+    /**
+     * 创建节点：create 持久 临时 顺序 数据
+     * 1. 基本创建 ：create().forPath("")
+     * 2. 创建节点 带有数据:create().forPath("",data)
+     * 3. 设置节点的类型：create().withMode().forPath("",data)
+     * 4. 创建多级节点  /app1/p1 ：create().creatingParentsIfNeeded().forPath("",data)
+     */
+    @Test
+    public void testCreate() throws Exception {
+        //默认是持久无序节点
+        //如果创建节点，没有指定数据，则默认将当前客户端的ip作为数据存储
+        String path = client.create().forPath("/app2", "hehe".getBytes());
+        System.out.println(path);
+    }
+}
\ No newline at end of file

src/test/java/com/kwan/shuyu/crud/CuratorTest_02_Create.java

+package com.kwan.shuyu.crud;
+
+import org.apache.curator.RetryPolicy;
+import org.apache.curator.framework.CuratorFramework;
+import org.apache.curator.framework.CuratorFrameworkFactory;
+import org.apache.curator.retry.ExponentialBackoffRetry;
+import org.junit.After;
+import org.junit.Before;
+import org.junit.Test;
+
+/**
+ * 创建节点 不带数据
+ *
+ * @author : qinyingjie
+ * @version : 2.2.0
+ * @date : 2023/5/15 09:54
+ */
+public class CuratorTest_02_Create {
+
+    private CuratorFramework client;
+
+    /**
+     * 建立连接
+     */
+    @Before
+    public void testConnect() {
+        /*
+         *
+         * @param connectString       连接字符串。zk server 地址和端口 "120.79.36.53:2181,120.79.36.53:2182,120.79.36.53:2183"
+         * @param sessionTimeoutMs    会话超时时间 单位ms
+         * @param connectionTimeoutMs 连接超时时间 单位ms
+         * @param retryPolicy         重试策略
+         */
+       /* //重试策略
+        RetryPolicy retryPolicy = new ExponentialBackoffRetry(3000,10);
+        //1.第一种方式
+        CuratorFramework client = CuratorFrameworkFactory.newClient("120.79.36.53:2181,120.79.36.53:2182,120.79.36.53:2183",
+                60 * 1000, 15 * 1000, retryPolicy);*/
+        //重试策略
+        RetryPolicy retryPolicy = new ExponentialBackoffRetry(3000, 10);
+        //2.第二种方式
+        //CuratorFrameworkFactory.builder();
+        client = CuratorFrameworkFactory.builder()
+                .connectString("120.79.36.53:2181,120.79.36.53:2182,120.79.36.53:2183")
+                .sessionTimeoutMs(60 * 1000)
+                .connectionTimeoutMs(15 * 1000)
+                .retryPolicy(retryPolicy)
+                .namespace("itheima")
+                .build();
+        //开启连接
+        client.start();
+    }
+
+    @After
+    public void close() {
+        if (client != null) {
+            client.close();
+        }
+    }
+
+    /**
+     * 创建节点：create 持久 临时 顺序 数据
+     * 1. 基本创建 ：create().forPath("")
+     * 2. 创建节点 带有数据:create().forPath("",data)
+     * 3. 设置节点的类型：create().withMode().forPath("",data)
+     * 4. 创建多级节点  /app1/p1 ：create().creatingParentsIfNeeded().forPath("",data)
+     */
+    @Test
+    public void testCreate2() throws Exception {
+        //基本创建
+        //如果创建节点，没有指定数据，则默认将当前客户端的ip作为数据存储
+        String path = client.create().forPath("/app1");
+        System.out.println(path);
+    }
+}
\ No newline at end of file

src/test/java/com/kwan/shuyu/crud/CuratorTest_03_Create.java

+package com.kwan.shuyu.crud;
+
+import org.apache.curator.RetryPolicy;
+import org.apache.curator.framework.CuratorFramework;
+import org.apache.curator.framework.CuratorFrameworkFactory;
+import org.apache.curator.retry.ExponentialBackoffRetry;
+import org.apache.zookeeper.CreateMode;
+import org.junit.After;
+import org.junit.Before;
+import org.junit.Test;
+
+/**
+ * 设置节点的类型
+ *
+ * @author : qinyingjie
+ * @version : 2.2.0
+ * @date : 2023/5/15 09:54
+ */
+public class CuratorTest_03_Create {
+
+    private CuratorFramework client;
+
+    /**
+     * 建立连接
+     */
+    @Before
+    public void testConnect() {
+        /*
+         *
+         * @param connectString       连接字符串。zk server 地址和端口 "120.79.36.53:2181,120.79.36.53:2182,120.79.36.53:2183"
+         * @param sessionTimeoutMs    会话超时时间 单位ms
+         * @param connectionTimeoutMs 连接超时时间 单位ms
+         * @param retryPolicy         重试策略
+         */
+       /* //重试策略
+        RetryPolicy retryPolicy = new ExponentialBackoffRetry(3000,10);
+        //1.第一种方式
+        CuratorFramework client = CuratorFrameworkFactory.newClient("120.79.36.53:2181,120.79.36.53:2182,120.79.36.53:2183",
+                60 * 1000, 15 * 1000, retryPolicy);*/
+        //重试策略
+        RetryPolicy retryPolicy = new ExponentialBackoffRetry(3000, 10);
+        //2.第二种方式
+        //CuratorFrameworkFactory.builder();
+        client = CuratorFrameworkFactory.builder()
+                .connectString("120.79.36.53:2181,120.79.36.53:2182,120.79.36.53:2183")
+                .sessionTimeoutMs(60 * 1000)
+                .connectionTimeoutMs(15 * 1000)
+                .retryPolicy(retryPolicy)
+                .namespace("itheima")
+                .build();
+        //开启连接
+        client.start();
+    }
+
+    @After
+    public void close() {
+        if (client != null) {
+            client.close();
+        }
+    }
+
+    /**
+     * 创建节点：create 持久 临时 顺序 数据
+     * 1. 基本创建 ：create().forPath("")
+     * 2. 创建节点 带有数据:create().forPath("",data)
+     * 3. 设置节点的类型：create().withMode().forPath("",data)
+     * 4. 创建多级节点  /app1/p1 ：create().creatingParentsIfNeeded().forPath("",data)
+     */
+    @Test
+    public void testCreate3() throws Exception {
+        //设置节点的类型
+        //默认类型：持久化
+        String path = client.create().withMode(CreateMode.EPHEMERAL).forPath("/app3");
+        System.out.println(path);
+    }
+}
\ No newline at end of file

src/test/java/com/kwan/shuyu/crud/CuratorTest_04_Create.java

+package com.kwan.shuyu.crud;
+
+import org.apache.curator.RetryPolicy;
+import org.apache.curator.framework.CuratorFramework;
+import org.apache.curator.framework.CuratorFrameworkFactory;
+import org.apache.curator.retry.ExponentialBackoffRetry;
+import org.junit.After;
+import org.junit.Before;
+import org.junit.Test;
+
+/**
+ * 创建多级节点
+ *
+ * @author : qinyingjie
+ * @version : 2.2.0
+ * @date : 2023/5/15 09:54
+ */
+public class CuratorTest_04_Create {
+
+    private CuratorFramework client;
+
+    /**
+     * 建立连接
+     */
+    @Before
+    public void testConnect() {
+        /*
+         *
+         * @param connectString       连接字符串。zk server 地址和端口 "120.79.36.53:2181,120.79.36.53:2182,120.79.36.53:2183"
+         * @param sessionTimeoutMs    会话超时时间 单位ms
+         * @param connectionTimeoutMs 连接超时时间 单位ms
+         * @param retryPolicy         重试策略
+         */
+        /**
+         //重试策略
+         RetryPolicy retryPolicy = new ExponentialBackoffRetry(3000,10);
+         //1.第一种方式
+         CuratorFramework client = CuratorFrameworkFactory.newClient("120.79.36.53:2181,120.79.36.53:2182,120.79.36.53:2183",
+         60 * 1000, 15 * 1000, retryPolicy);
+         */
+        //重试策略
+        RetryPolicy retryPolicy = new ExponentialBackoffRetry(3000, 10);
+        //2.第二种方式
+        //CuratorFrameworkFactory.builder();
+        client = CuratorFrameworkFactory.builder()
+                .connectString("120.79.36.53:2181,120.79.36.53:2182,120.79.36.53:2183")
+                .sessionTimeoutMs(60 * 1000)
+                .connectionTimeoutMs(15 * 1000)
+                .retryPolicy(retryPolicy)
+                .namespace("itheima")
+                .build();
+        //开启连接
+        client.start();
+    }
+
+    @After
+    public void close() {
+        if (client != null) {
+            client.close();
+        }
+    }
+
+    /**
+     * 创建节点：create 持久 临时 顺序 数据
+     * 1. 基本创建 ：create().forPath("")
+     * 2. 创建节点 带有数据:create().forPath("",data)
+     * 3. 设置节点的类型：create().withMode().forPath("",data)
+     * 4. 创建多级节点  /app1/p1 ：create().creatingParentsIfNeeded().forPath("",data)
+     */
+    @Test
+    public void testCreate4() throws Exception {
+        //4. 创建多级节点  /app1/p1
+        //creatingParentsIfNeeded():如果父节点不存在，则创建父节点
+        String path = client.create().creatingParentsIfNeeded().forPath("/app4/p1");
+        System.out.println(path);
+    }
+}
\ No newline at end of file

src/test/java/com/kwan/shuyu/crud/CuratorTest_05_Get.java

+package com.kwan.shuyu.crud;
+
+import org.apache.curator.RetryPolicy;
+import org.apache.curator.framework.CuratorFramework;
+import org.apache.curator.framework.CuratorFrameworkFactory;
+import org.apache.curator.retry.ExponentialBackoffRetry;
+import org.junit.After;
+import org.junit.Before;
+import org.junit.Test;
+
+/**
+ * 查询数据
+ *
+ * @author : qinyingjie
+ * @version : 2.2.0
+ * @date : 2023/5/15 09:54
+ */
+public class CuratorTest_05_Get {
+
+    private CuratorFramework client;
+
+    /**
+     * 建立连接
+     */
+    @Before
+    public void testConnect() {
+        /*
+         *
+         * @param connectString       连接字符串。zk server 地址和端口 "120.79.36.53:2181,120.79.36.53:2182,120.79.36.53:2183"
+         * @param sessionTimeoutMs    会话超时时间 单位ms
+         * @param connectionTimeoutMs 连接超时时间 单位ms
+         * @param retryPolicy         重试策略
+         */
+       /* //重试策略
+        RetryPolicy retryPolicy = new ExponentialBackoffRetry(3000,10);
+        //1.第一种方式
+        CuratorFramework client = CuratorFrameworkFactory.newClient("120.79.36.53:2181,120.79.36.53:2182,120.79.36.53:2183",
+                60 * 1000, 15 * 1000, retryPolicy);*/
+        //重试策略
+        RetryPolicy retryPolicy = new ExponentialBackoffRetry(3000, 10);
+        //2.第二种方式
+        //CuratorFrameworkFactory.builder();
+        client = CuratorFrameworkFactory.builder()
+                .connectString("120.79.36.53:2181,120.79.36.53:2182,120.79.36.53:2183")
+                .sessionTimeoutMs(60 * 1000)
+                .connectionTimeoutMs(15 * 1000)
+                .retryPolicy(retryPolicy)
+                .namespace("itheima")
+                .build();
+        //开启连接
+        client.start();
+    }
+
+    @After
+    public void close() {
+        if (client != null) {
+            client.close();
+        }
+    }
+
+    /**
+     * 查询节点：
+     * 1. 查询数据：get: getData().forPath()
+     * 2. 查询子节点： ls: getChildren().forPath()
+     * 3. 查询节点状态信息：ls -s:getData().storingStatIn(状态对象).forPath()
+     */
+    @Test
+    public void testGet1() throws Exception {
+        //1. 查询数据：get
+        byte[] data = client.getData().forPath("/app1");
+        System.out.println(new String(data));
+    }
+}
\ No newline at end of file

src/test/java/com/kwan/shuyu/crud/CuratorTest_06_Get.java

+package com.kwan.shuyu.crud;
+
+import org.apache.curator.RetryPolicy;
+import org.apache.curator.framework.CuratorFramework;
+import org.apache.curator.framework.CuratorFrameworkFactory;
+import org.apache.curator.retry.ExponentialBackoffRetry;
+import org.junit.After;
+import org.junit.Before;
+import org.junit.Test;
+
+import java.util.List;
+
+/**
+ * 查询子节点
+ *
+ * @author : qinyingjie
+ * @version : 2.2.0
+ * @date : 2023/5/15 09:54
+ */
+public class CuratorTest_06_Get {
+    private CuratorFramework client;
+
+    /**
+     * 建立连接
+     */
+    @Before
+    public void testConnect() {
+        /*
+         *
+         * @param connectString       连接字符串。zk server 地址和端口 "120.79.36.53:2181,120.79.36.53:2182,120.79.36.53:2183"
+         * @param sessionTimeoutMs    会话超时时间 单位ms
+         * @param connectionTimeoutMs 连接超时时间 单位ms
+         * @param retryPolicy         重试策略
+         */
+       /* //重试策略
+        RetryPolicy retryPolicy = new ExponentialBackoffRetry(3000,10);
+        //1.第一种方式
+        CuratorFramework client = CuratorFrameworkFactory.newClient("120.79.36.53:2181,120.79.36.53:2182,120.79.36.53:2183",
+                60 * 1000, 15 * 1000, retryPolicy);*/
+        //重试策略
+        RetryPolicy retryPolicy = new ExponentialBackoffRetry(3000, 10);
+        //2.第二种方式
+        //CuratorFrameworkFactory.builder();
+        client = CuratorFrameworkFactory.builder()
+                .connectString("120.79.36.53:2181,120.79.36.53:2182,120.79.36.53:2183")
+                .sessionTimeoutMs(60 * 1000)
+                .connectionTimeoutMs(15 * 1000)
+                .retryPolicy(retryPolicy)
+                .namespace("itheima")
+                .build();
+        //开启连接
+        client.start();
+    }
+
+    @After
+    public void close() {
+        if (client != null) {
+            client.close();
+        }
+    }
+
+    /**
+     * 查询节点：
+     * 1. 查询数据：get: getData().forPath()
+     * 2. 查询子节点： ls: getChildren().forPath()
+     * 3. 查询节点状态信息：ls -s:getData().storingStatIn(状态对象).forPath()
+     */
+    @Test
+    public void testGet2() throws Exception {
+        // 2. 查询子节点： ls
+        List<String> path = client.getChildren().forPath("/");
+        System.out.println(path);
+    }
+}
\ No newline at end of file

src/test/java/com/kwan/shuyu/crud/CuratorTest_07_Get.java

+package com.kwan.shuyu.crud;
+
+import org.apache.curator.RetryPolicy;
+import org.apache.curator.framework.CuratorFramework;
+import org.apache.curator.framework.CuratorFrameworkFactory;
+import org.apache.curator.retry.ExponentialBackoffRetry;
+import org.apache.zookeeper.data.Stat;
+import org.junit.After;
+import org.junit.Before;
+import org.junit.Test;
+
+/**
+ * 查询节点状态信息
+ *
+ * @author : qinyingjie
+ * @version : 2.2.0
+ * @date : 2023/5/15 09:54
+ */
+public class CuratorTest_07_Get {
+    private CuratorFramework client;
+
+    /**
+     * 建立连接
+     */
+    @Before
+    public void testConnect() {
+        /*
+         *
+         * @param connectString       连接字符串。zk server 地址和端口 "120.79.36.53:2181,120.79.36.53:2182,120.79.36.53:2183"
+         * @param sessionTimeoutMs    会话超时时间 单位ms
+         * @param connectionTimeoutMs 连接超时时间 单位ms
+         * @param retryPolicy         重试策略
+         */
+       /* //重试策略
+        RetryPolicy retryPolicy = new ExponentialBackoffRetry(3000,10);
+        //1.第一种方式
+        CuratorFramework client = CuratorFrameworkFactory.newClient("120.79.36.53:2181,120.79.36.53:2182,120.79.36.53:2183",
+                60 * 1000, 15 * 1000, retryPolicy);*/
+        //重试策略
+        RetryPolicy retryPolicy = new ExponentialBackoffRetry(3000, 10);
+        //2.第二种方式
+        //CuratorFrameworkFactory.builder();
+        client = CuratorFrameworkFactory.builder()
+                .connectString("120.79.36.53:2181,120.79.36.53:2182,120.79.36.53:2183")
+                .sessionTimeoutMs(60 * 1000)
+                .connectionTimeoutMs(15 * 1000)
+                .retryPolicy(retryPolicy)
+                .namespace("itheima")
+                .build();
+        //开启连接
+        client.start();
+    }
+
+    @After
+    public void close() {
+        if (client != null) {
+            client.close();
+        }
+    }
+
+    /**
+     * 查询节点：
+     * 1. 查询数据：get: getData().forPath()
+     * 2. 查询子节点： ls: getChildren().forPath()
+     * 3. 查询节点状态信息：ls -s:getData().storingStatIn(状态对象).forPath()
+     */
+    @Test
+    public void testGet3() throws Exception {
+        Stat status = new Stat();
+        System.out.println(status);
+        //3. 查询节点状态信息：ls -s
+        client.getData().storingStatIn(status).forPath("/app1");
+        System.out.println(status);
+    }
+}
\ No newline at end of file

src/test/java/com/kwan/shuyu/crud/CuratorTest_08_Set.java

+package com.kwan.shuyu.crud;
+
+import org.apache.curator.RetryPolicy;
+import org.apache.curator.framework.CuratorFramework;
+import org.apache.curator.framework.CuratorFrameworkFactory;
+import org.apache.curator.retry.ExponentialBackoffRetry;
+import org.junit.After;
+import org.junit.Before;
+import org.junit.Test;
+
+/**
+ * 基本修改数据
+ *
+ * @author : qinyingjie
+ * @version : 2.2.0
+ * @date : 2023/5/15 09:54
+ */
+public class CuratorTest_08_Set {
+    private CuratorFramework client;
+
+    /**
+     * 建立连接
+     */
+    @Before
+    public void testConnect() {
+        /*
+         *
+         * @param connectString       连接字符串。zk server 地址和端口 "120.79.36.53:2181,120.79.36.53:2182,120.79.36.53:2183"
+         * @param sessionTimeoutMs    会话超时时间 单位ms
+         * @param connectionTimeoutMs 连接超时时间 单位ms
+         * @param retryPolicy         重试策略
+         */
+       /* //重试策略
+        RetryPolicy retryPolicy = new ExponentialBackoffRetry(3000,10);
+        //1.第一种方式
+        CuratorFramework client = CuratorFrameworkFactory.newClient("120.79.36.53:2181,120.79.36.53:2182,120.79.36.53:2183",
+                60 * 1000, 15 * 1000, retryPolicy);*/
+        //重试策略
+        RetryPolicy retryPolicy = new ExponentialBackoffRetry(3000, 10);
+        //2.第二种方式
+        //CuratorFrameworkFactory.builder();
+        client = CuratorFrameworkFactory.builder()
+                .connectString("120.79.36.53:2181,120.79.36.53:2182,120.79.36.53:2183")
+                .sessionTimeoutMs(60 * 1000)
+                .connectionTimeoutMs(15 * 1000)
+                .retryPolicy(retryPolicy)
+                .namespace("itheima")
+                .build();
+        //开启连接
+        client.start();
+    }
+
+    @After
+    public void close() {
+        if (client != null) {
+            client.close();
+        }
+    }
+
+    /**
+     * 修改数据
+     * 1. 基本修改数据：setData().forPath()
+     * 2. 根据版本修改: setData().withVersion().forPath()
+     * * version 是通过查询出来的。目的就是为了让其他客户端或者线程不干扰我。
+     *
+     * @throws Exception
+     */
+    @Test
+    public void testSet() throws Exception {
+        client.setData().forPath("/app1", "itcast".getBytes());
+    }
+}
\ No newline at end of file

src/test/java/com/kwan/shuyu/crud/CuratorTest_09_Set.java

+package com.kwan.shuyu.crud;
+
+import org.apache.curator.RetryPolicy;
+import org.apache.curator.framework.CuratorFramework;
+import org.apache.curator.framework.CuratorFrameworkFactory;
+import org.apache.curator.retry.ExponentialBackoffRetry;
+import org.apache.zookeeper.data.Stat;
+import org.junit.After;
+import org.junit.Before;
+import org.junit.Test;
+
+/**
+ * 根据版本修改
+ *
+ * @author : qinyingjie
+ * @version : 2.2.0
+ * @date : 2023/5/15 09:54
+ */
+public class CuratorTest_09_Set {
+    private CuratorFramework client;
+
+    /**
+     * 建立连接
+     */
+    @Before
+    public void testConnect() {
+        /*
+         *
+         * @param connectString       连接字符串。zk server 地址和端口 "120.79.36.53:2181,120.79.36.53:2182,120.79.36.53:2183"
+         * @param sessionTimeoutMs    会话超时时间 单位ms
+         * @param connectionTimeoutMs 连接超时时间 单位ms
+         * @param retryPolicy         重试策略
+         */
+       /* //重试策略
+        RetryPolicy retryPolicy = new ExponentialBackoffRetry(3000,10);
+        //1.第一种方式
+        CuratorFramework client = CuratorFrameworkFactory.newClient("120.79.36.53:2181,120.79.36.53:2182,120.79.36.53:2183",
+                60 * 1000, 15 * 1000, retryPolicy);*/
+        //重试策略
+        RetryPolicy retryPolicy = new ExponentialBackoffRetry(3000, 10);
+        //2.第二种方式
+        //CuratorFrameworkFactory.builder();
+        client = CuratorFrameworkFactory.builder()
+                .connectString("120.79.36.53:2181,120.79.36.53:2182,120.79.36.53:2183")
+                .sessionTimeoutMs(60 * 1000)
+                .connectionTimeoutMs(15 * 1000)
+                .retryPolicy(retryPolicy)
+                .namespace("itheima")
+                .build();
+        //开启连接
+        client.start();
+    }
+
+    @After
+    public void close() {
+        if (client != null) {
+            client.close();
+        }
+    }
+
+    /**
+     * 修改数据
+     * 1. 基本修改数据：setData().forPath()
+     * 2. 根据版本修改: setData().withVersion().forPath()
+     * * version 是通过查询出来的。目的就是为了让其他客户端或者线程不干扰我。
+     *
+     * @throws Exception
+     */
+    @Test
+    public void testSetForVersion() throws Exception {
+        Stat status = new Stat();
+        //3. 查询节点状态信息：ls -s
+        client.getData().storingStatIn(status).forPath("/app1");
+        int version = status.getVersion();//查询出来的 3
+        System.out.println(version);
+        client.setData().withVersion(version).forPath("/app1", "hehe".getBytes());
+    }
+}
\ No newline at end of file

src/test/java/com/kwan/shuyu/crud/CuratorTest_10_Delete.java

+package com.kwan.shuyu.crud;
+
+import org.apache.curator.RetryPolicy;
+import org.apache.curator.framework.CuratorFramework;
+import org.apache.curator.framework.CuratorFrameworkFactory;
+import org.apache.curator.retry.ExponentialBackoffRetry;
+import org.junit.After;
+import org.junit.Before;
+import org.junit.Test;
+
+/**
+ * 删除单个节点
+ *
+ * @author : qinyingjie
+ * @version : 2.2.0
+ * @date : 2023/5/15 09:54
+ */
+public class CuratorTest_10_Delete {
+    private CuratorFramework client;
+
+    /**
+     * 建立连接
+     */
+    @Before
+    public void testConnect() {
+        /*
+         *
+         * @param connectString       连接字符串。zk server 地址和端口 "120.79.36.53:2181,120.79.36.53:2182,120.79.36.53:2183"
+         * @param sessionTimeoutMs    会话超时时间 单位ms
+         * @param connectionTimeoutMs 连接超时时间 单位ms
+         * @param retryPolicy         重试策略
+         */
+       /* //重试策略
+        RetryPolicy retryPolicy = new ExponentialBackoffRetry(3000,10);
+        //1.第一种方式
+        CuratorFramework client = CuratorFrameworkFactory.newClient("120.79.36.53:2181,120.79.36.53:2182,120.79.36.53:2183",
+                60 * 1000, 15 * 1000, retryPolicy);*/
+        //重试策略
+        RetryPolicy retryPolicy = new ExponentialBackoffRetry(3000, 10);
+        //2.第二种方式
+        //CuratorFrameworkFactory.builder();
+        client = CuratorFrameworkFactory.builder()
+                .connectString("120.79.36.53:2181,120.79.36.53:2182,120.79.36.53:2183")
+                .sessionTimeoutMs(60 * 1000)
+                .connectionTimeoutMs(15 * 1000)
+                .retryPolicy(retryPolicy)
+                .namespace("itheima")
+                .build();
+        //开启连接
+        client.start();
+    }
+
+    @After
+    public void close() {
+        if (client != null) {
+            client.close();
+        }
+    }
+
+    /**
+     * 删除节点： delete deleteall
+     * 1. 删除单个节点:delete().forPath("/app1");
+     * 2. 删除带有子节点的节点:delete().deletingChildrenIfNeeded().forPath("/app1");
+     * 3. 必须成功的删除:为了防止网络抖动。本质就是重试。  client.delete().guaranteed().forPath("/app2");
+     * 4. 回调：inBackground
+     *
+     * @throws Exception
+     */
+    @Test
+    public void testDelete() throws Exception {
+        // 1. 删除单个节点
+        client.delete().forPath("/app1");
+    }
+}
\ No newline at end of file

src/test/java/com/kwan/shuyu/crud/CuratorTest_11_Delete.java

+package com.kwan.shuyu.crud;
+
+import org.apache.curator.RetryPolicy;
+import org.apache.curator.framework.CuratorFramework;
+import org.apache.curator.framework.CuratorFrameworkFactory;
+import org.apache.curator.retry.ExponentialBackoffRetry;
+import org.junit.After;
+import org.junit.Before;
+import org.junit.Test;
+
+/**
+ * 删除带有子节点的节点
+ *
+ * @author : qinyingjie
+ * @version : 2.2.0
+ * @date : 2023/5/15 09:54
+ */
+public class CuratorTest_11_Delete {
+    private CuratorFramework client;
+
+    /**
+     * 建立连接
+     */
+    @Before
+    public void testConnect() {
+        /*
+         *
+         * @param connectString       连接字符串。zk server 地址和端口 "120.79.36.53:2181,120.79.36.53:2182,120.79.36.53:2183"
+         * @param sessionTimeoutMs    会话超时时间 单位ms
+         * @param connectionTimeoutMs 连接超时时间 单位ms
+         * @param retryPolicy         重试策略
+         */
+       /* //重试策略
+        RetryPolicy retryPolicy = new ExponentialBackoffRetry(3000,10);
+        //1.第一种方式
+        CuratorFramework client = CuratorFrameworkFactory.newClient("120.79.36.53:2181,120.79.36.53:2182,120.79.36.53:2183",
+                60 * 1000, 15 * 1000, retryPolicy);*/
+        //重试策略
+        RetryPolicy retryPolicy = new ExponentialBackoffRetry(3000, 10);
+        //2.第二种方式
+        //CuratorFrameworkFactory.builder();
+        client = CuratorFrameworkFactory.builder()
+                .connectString("120.79.36.53:2181,120.79.36.53:2182,120.79.36.53:2183")
+                .sessionTimeoutMs(60 * 1000)
+                .connectionTimeoutMs(15 * 1000)
+                .retryPolicy(retryPolicy)
+                .namespace("itheima")
+                .build();
+        //开启连接
+        client.start();
+    }
+
+    @After
+    public void close() {
+        if (client != null) {
+            client.close();
+        }
+    }
+
+    /**
+     * 删除节点： delete deleteall
+     * 1. 删除单个节点:delete().forPath("/app1");
+     * 2. 删除带有子节点的节点:delete().deletingChildrenIfNeeded().forPath("/app1");
+     * 3. 必须成功的删除:为了防止网络抖动。本质就是重试。  client.delete().guaranteed().forPath("/app2");
+     * 4. 回调：inBackground
+     *
+     * @throws Exception
+     */
+    @Test
+    public void testDelete2() throws Exception {
+        //2. 删除带有子节点的节点
+        client.delete().deletingChildrenIfNeeded().forPath("/app4");
+    }
+}
\ No newline at end of file

src/test/java/com/kwan/shuyu/crud/CuratorTest_12_Delete.java

+package com.kwan.shuyu.crud;
+
+import org.apache.curator.RetryPolicy;
+import org.apache.curator.framework.CuratorFramework;
+import org.apache.curator.framework.CuratorFrameworkFactory;
+import org.apache.curator.retry.ExponentialBackoffRetry;
+import org.junit.After;
+import org.junit.Before;
+import org.junit.Test;
+
+/**
+ * 必须成功的删除:为了防止网络抖动。本质就是重试。
+ *
+ * @author : qinyingjie
+ * @version : 2.2.0
+ * @date : 2023/5/15 09:54
+ */
+public class CuratorTest_12_Delete {
+    private CuratorFramework client;
+
+    /**
+     * 建立连接
+     */
+    @Before
+    public void testConnect() {
+        /*
+         *
+         * @param connectString       连接字符串。zk server 地址和端口 "120.79.36.53:2181,120.79.36.53:2182,120.79.36.53:2183"
+         * @param sessionTimeoutMs    会话超时时间 单位ms
+         * @param connectionTimeoutMs 连接超时时间 单位ms
+         * @param retryPolicy         重试策略
+         */
+       /* //重试策略
+        RetryPolicy retryPolicy = new ExponentialBackoffRetry(3000,10);
+        //1.第一种方式
+        CuratorFramework client = CuratorFrameworkFactory.newClient("120.79.36.53:2181,120.79.36.53:2182,120.79.36.53:2183",
+                60 * 1000, 15 * 1000, retryPolicy);*/
+        //重试策略
+        RetryPolicy retryPolicy = new ExponentialBackoffRetry(3000, 10);
+        //2.第二种方式
+        //CuratorFrameworkFactory.builder();
+        client = CuratorFrameworkFactory.builder()
+                .connectString("120.79.36.53:2181,120.79.36.53:2182,120.79.36.53:2183")
+                .sessionTimeoutMs(60 * 1000)
+                .connectionTimeoutMs(15 * 1000)
+                .retryPolicy(retryPolicy)
+                .namespace("itheima")
+                .build();
+        //开启连接
+        client.start();
+    }
+
+    @After
+    public void close() {
+        if (client != null) {
+            client.close();
+        }
+    }
+
+    /**
+     * 删除节点： delete deleteall
+     * 1. 删除单个节点:delete().forPath("/app1");
+     * 2. 删除带有子节点的节点:delete().deletingChildrenIfNeeded().forPath("/app1");
+     * 3. 必须成功的删除:为了防止网络抖动。本质就是重试。  client.delete().guaranteed().forPath("/app2");
+     * 4. 回调：inBackground
+     *
+     * @throws Exception
+     */
+    @Test
+    public void testDelete3() throws Exception {
+        //3. 必须成功的删除
+        client.delete().guaranteed().forPath("/app2");
+    }
+}
\ No newline at end of file

src/test/java/com/kwan/shuyu/CuratorTest.java → src/test/java/com/kwan/shuyu/crud/CuratorTest_13_Delete.java

-package com.kwan.shuyu;
+package com.kwan.shuyu.crud;
 
 import org.apache.curator.RetryPolicy;
 import org.apache.curator.framework.CuratorFramework;
@@ -6,15 +6,18 @@ import org.apache.curator.framework.CuratorFrameworkFactory;
 import org.apache.curator.framework.api.BackgroundCallback;
 import org.apache.curator.framework.api.CuratorEvent;
 import org.apache.curator.retry.ExponentialBackoffRetry;
-import org.apache.zookeeper.CreateMode;
-import org.apache.zookeeper.data.Stat;
 import org.junit.After;
 import org.junit.Before;
 import org.junit.Test;
 
-import java.util.List;
-
-public class CuratorTest {
+/**
+ * 删除回调：inBackground
+ *
+ * @author : qinyingjie
+ * @version : 2.2.0
+ * @date : 2023/5/15 09:54
+ */
+public class CuratorTest_13_Delete {
     private CuratorFramework client;
 
     /**
@@ -24,7 +27,7 @@ public class CuratorTest {
     public void testConnect() {
         /*
          *
-         * @param connectString       连接字符串。zk server 地址和端口 "192.168.149.135:2181,192.168.149.136:2181"
+         * @param connectString       连接字符串。zk server 地址和端口 "120.79.36.53:2181,120.79.36.53:2182,120.79.36.53:2183"
          * @param sessionTimeoutMs    会话超时时间 单位ms
          * @param connectionTimeoutMs 连接超时时间 单位ms
          * @param retryPolicy         重试策略
@@ -32,14 +35,14 @@ public class CuratorTest {
        /* //重试策略
         RetryPolicy retryPolicy = new ExponentialBackoffRetry(3000,10);
         //1.第一种方式
-        CuratorFramework client = CuratorFrameworkFactory.newClient("192.168.149.135:2181",
+        CuratorFramework client = CuratorFrameworkFactory.newClient("120.79.36.53:2181,120.79.36.53:2182,120.79.36.53:2183",
                 60 * 1000, 15 * 1000, retryPolicy);*/
         //重试策略
         RetryPolicy retryPolicy = new ExponentialBackoffRetry(3000, 10);
         //2.第二种方式
         //CuratorFrameworkFactory.builder();
         client = CuratorFrameworkFactory.builder()
-                .connectString("192.168.149.135:2181")
+                .connectString("120.79.36.53:2181,120.79.36.53:2182,120.79.36.53:2183")
                 .sessionTimeoutMs(60 * 1000)
                 .connectionTimeoutMs(15 * 1000)
                 .retryPolicy(retryPolicy)
@@ -48,101 +51,13 @@ public class CuratorTest {
         //开启连接
         client.start();
     }
-//==============================create=============================================================================
-
-    /**
-     * 创建节点：create 持久 临时 顺序 数据
-     * 1. 基本创建 ：create().forPath("")
-     * 2. 创建节点 带有数据:create().forPath("",data)
-     * 3. 设置节点的类型：create().withMode().forPath("",data)
-     * 4. 创建多级节点  /app1/p1 ：create().creatingParentsIfNeeded().forPath("",data)
-     */
-    @Test
-    public void testCreate() throws Exception {
-        //2. 创建节点 带有数据
-        //如果创建节点，没有指定数据，则默认将当前客户端的ip作为数据存储
-        String path = client.create().forPath("/app2", "hehe".getBytes());
-        System.out.println(path);
-    }
-
-    @Test
-    public void testCreate2() throws Exception {
-        //1. 基本创建
-        //如果创建节点，没有指定数据，则默认将当前客户端的ip作为数据存储
-        String path = client.create().forPath("/app1");
-        System.out.println(path);
-    }
-
-    @Test
-    public void testCreate3() throws Exception {
-        //3. 设置节点的类型
-        //默认类型：持久化
-        String path = client.create().withMode(CreateMode.EPHEMERAL).forPath("/app3");
-        System.out.println(path);
-    }
-
-    @Test
-    public void testCreate4() throws Exception {
-        //4. 创建多级节点  /app1/p1
-        //creatingParentsIfNeeded():如果父节点不存在，则创建父节点
-        String path = client.create().creatingParentsIfNeeded().forPath("/app4/p1");
-        System.out.println(path);
-    }
-//===========================get================================================================================
-
-    /**
-     * 查询节点：
-     * 1. 查询数据：get: getData().forPath()
-     * 2. 查询子节点： ls: getChildren().forPath()
-     * 3. 查询节点状态信息：ls -s:getData().storingStatIn(状态对象).forPath()
-     */
-    @Test
-    public void testGet1() throws Exception {
-        //1. 查询数据：get
-        byte[] data = client.getData().forPath("/app1");
-        System.out.println(new String(data));
-    }
-
-    @Test
-    public void testGet2() throws Exception {
-        // 2. 查询子节点： ls
-        List<String> path = client.getChildren().forPath("/");
-        System.out.println(path);
-    }
 
-    @Test
-    public void testGet3() throws Exception {
-        Stat status = new Stat();
-        System.out.println(status);
-        //3. 查询节点状态信息：ls -s
-        client.getData().storingStatIn(status).forPath("/app1");
-        System.out.println(status);
-    }
-    //===========================set================================================================================
-
-    /**
-     * 修改数据
-     * 1. 基本修改数据：setData().forPath()
-     * 2. 根据版本修改: setData().withVersion().forPath()
-     * * version 是通过查询出来的。目的就是为了让其他客户端或者线程不干扰我。
-     *
-     * @throws Exception
-     */
-    @Test
-    public void testSet() throws Exception {
-        client.setData().forPath("/app1", "itcast".getBytes());
-    }
-
-    @Test
-    public void testSetForVersion() throws Exception {
-        Stat status = new Stat();
-        //3. 查询节点状态信息：ls -s
-        client.getData().storingStatIn(status).forPath("/app1");
-        int version = status.getVersion();//查询出来的 3
-        System.out.println(version);
-        client.setData().withVersion(version).forPath("/app1", "hehe".getBytes());
+    @After
+    public void close() {
+        if (client != null) {
+            client.close();
+        }
     }
-    //===========================delete================================================================================
 
     /**
      * 删除节点： delete deleteall
@@ -153,24 +68,6 @@ public class CuratorTest {
      *
      * @throws Exception
      */
-    @Test
-    public void testDelete() throws Exception {
-        // 1. 删除单个节点
-        client.delete().forPath("/app1");
-    }
-
-    @Test
-    public void testDelete2() throws Exception {
-        //2. 删除带有子节点的节点
-        client.delete().deletingChildrenIfNeeded().forPath("/app4");
-    }
-
-    @Test
-    public void testDelete3() throws Exception {
-        //3. 必须成功的删除
-        client.delete().guaranteed().forPath("/app2");
-    }
-
     @Test
     public void testDelete4() throws Exception {
         //4. 回调
@@ -182,11 +79,4 @@ public class CuratorTest {
             }
         }).forPath("/app1");
     }
-
-    @After
-    public void close() {
-        if (client != null) {
-            client.close();
-        }
-    }
 }
\ No newline at end of file

src/test/java/com/kwan/shuyu/CuratorWatcherTest.java → src/test/java/com/kwan/shuyu/watch/CuratorWatcherTest.java

-package com.kwan.shuyu;
+package com.kwan.shuyu.watch;
 
 import org.apache.curator.RetryPolicy;
 import org.apache.curator.framework.CuratorFramework;
@@ -19,7 +19,7 @@ public class CuratorWatcherTest {
     public void testConnect() {
         /*
          *
-         * @param connectString       连接字符串。zk server 地址和端口 "192.168.149.135:2181,192.168.149.136:2181"
+         * @param connectString       连接字符串。zk server 地址和端口 "120.79.36.53:2181,120.79.36.53:2182,120.79.36.53:2183"
          * @param sessionTimeoutMs    会话超时时间 单位ms
          * @param connectionTimeoutMs 连接超时时间 单位ms
          * @param retryPolicy         重试策略
@@ -27,14 +27,14 @@ public class CuratorWatcherTest {
        /* //重试策略
         RetryPolicy retryPolicy = new ExponentialBackoffRetry(3000,10);
         //1.第一种方式
-        CuratorFramework client = CuratorFrameworkFactory.newClient("192.168.149.135:2181",
+        CuratorFramework client = CuratorFrameworkFactory.newClient("120.79.36.53:2181,120.79.36.53:2182,120.79.36.53:2183",
                 60 * 1000, 15 * 1000, retryPolicy);*/
         //重试策略
         RetryPolicy retryPolicy = new ExponentialBackoffRetry(3000, 10);
         //2.第二种方式
         //CuratorFrameworkFactory.builder();
         client = CuratorFrameworkFactory.builder()
-                .connectString("192.168.149.135:2181")
+                .connectString("120.79.36.53:2181,120.79.36.53:2182,120.79.36.53:2183")
                 .sessionTimeoutMs(60 * 1000)
                 .connectionTimeoutMs(15 * 1000)
                 .retryPolicy(retryPolicy)