fix:Watcher监听

src/test/java/com/kwan/shuyu/watch/Watcher_01_NodeCache.java

+package com.kwan.shuyu.watch;
+
+import org.apache.curator.RetryPolicy;
+import org.apache.curator.framework.CuratorFramework;
+import org.apache.curator.framework.CuratorFrameworkFactory;
+import org.apache.curator.framework.recipes.cache.*;
+import org.apache.curator.retry.ExponentialBackoffRetry;
+import org.junit.After;
+import org.junit.Before;
+import org.junit.Test;
+
+/**
+ * Watcher监听
+ *
+ * @author : qinyingjie
+ * @version : 2.2.0
+ * @date : 2023/5/15 10:29
+ */
+public class Watcher_01_NodeCache {
+
+    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();
+        }
+    }
+
+    /**
+     * 演示 NodeCache：给指定一个节点注册监听器
+     */
+    @Test
+    public void testNodeCache() throws Exception {
+        //1. 创建NodeCache对象
+        final NodeCache nodeCache = new NodeCache(client, "/app1");
+        //2. 注册监听
+        nodeCache.getListenable().addListener(new NodeCacheListener() {
+            @Override
+            public void nodeChanged() throws Exception {
+                System.out.println("节点变化了~");
+                //获取修改节点后的数据
+                byte[] data = nodeCache.getCurrentData().getData();
+                System.out.println(new String(data));
+            }
+        });
+        //3. 开启监听.如果设置为true，则开启监听是，加载缓冲数据
+        nodeCache.start(true);
+        while (true) {
+        }
+    }
+}
\ No newline at end of file

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

@@ -9,7 +9,15 @@ import org.junit.After;
 import org.junit.Before;
 import org.junit.Test;
 
-public class CuratorWatcherTest {
+/**
+ * Watcher监听
+ *
+ * @author : qinyingjie
+ * @version : 2.2.0
+ * @date : 2023/5/15 10:29
+ */
+public class Watcher_02_PathChildrenCache {
+
     private CuratorFramework client;
 
     /**
@@ -51,29 +59,6 @@ public class CuratorWatcherTest {
         }
     }
 
-    /**
-     * 演示 NodeCache：给指定一个节点注册监听器
-     */
-    @Test
-    public void testNodeCache() throws Exception {
-        //1. 创建NodeCache对象
-        final NodeCache nodeCache = new NodeCache(client, "/app1");
-        //2. 注册监听
-        nodeCache.getListenable().addListener(new NodeCacheListener() {
-            @Override
-            public void nodeChanged() throws Exception {
-                System.out.println("节点变化了~");
-                //获取修改节点后的数据
-                byte[] data = nodeCache.getCurrentData().getData();
-                System.out.println(new String(data));
-            }
-        });
-        //3. 开启监听.如果设置为true，则开启监听是，加载缓冲数据
-        nodeCache.start(true);
-        while (true) {
-        }
-    }
-
     /**
      * 演示 PathChildrenCache：监听某个节点的所有子节点们
      */
@@ -103,25 +88,4 @@ public class CuratorWatcherTest {
         while (true) {
         }
     }
-
-    /**
-     * 演示 TreeCache：监听某个节点自己和所有子节点们
-     */
-    @Test
-    public void testTreeCache() throws Exception {
-        //1. 创建监听器
-        TreeCache treeCache = new TreeCache(client, "/app2");
-        //2. 注册监听
-        treeCache.getListenable().addListener(new TreeCacheListener() {
-            @Override
-            public void childEvent(CuratorFramework client, TreeCacheEvent event) throws Exception {
-                System.out.println("节点变化了");
-                System.out.println(event);
-            }
-        });
-        //3. 开启
-        treeCache.start();
-        while (true) {
-        }
-    }
 }
\ No newline at end of file

src/test/java/com/kwan/shuyu/watch/Watcher_03_TreeCache.java

+package com.kwan.shuyu.watch;
+
+import org.apache.curator.RetryPolicy;
+import org.apache.curator.framework.CuratorFramework;
+import org.apache.curator.framework.CuratorFrameworkFactory;
+import org.apache.curator.framework.recipes.cache.*;
+import org.apache.curator.retry.ExponentialBackoffRetry;
+import org.junit.After;
+import org.junit.Before;
+import org.junit.Test;
+
+/**
+ * Watcher监听
+ *
+ * @author : qinyingjie
+ * @version : 2.2.0
+ * @date : 2023/5/15 10:29
+ */
+public class Watcher_03_TreeCache {
+
+    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();
+        }
+    }
+
+    /**
+     * 演示 TreeCache：监听某个节点自己和所有子节点们
+     */
+    @Test
+    public void testTreeCache() throws Exception {
+        //1. 创建监听器
+        TreeCache treeCache = new TreeCache(client, "/app2");
+        //2. 注册监听
+        treeCache.getListenable().addListener(new TreeCacheListener() {
+            @Override
+            public void childEvent(CuratorFramework client, TreeCacheEvent event) throws Exception {
+                System.out.println("节点变化了");
+                System.out.println(event);
+            }
+        });
+        //3. 开启
+        treeCache.start();
+        while (true) {
+        }
+    }
+}
\ No newline at end of file