千家信息网

Curator Framework怎么用

发表于:2025-01-24 作者:千家信息网编辑
千家信息网最后更新 2025年01月24日,这篇文章主要介绍"Curator Framework怎么用"的相关知识,小编通过实际案例向大家展示操作过程,操作方法简单快捷,实用性强,希望这篇"Curator Framework怎么用"文章能帮助大
千家信息网最后更新 2025年01月24日Curator Framework怎么用

这篇文章主要介绍"Curator Framework怎么用"的相关知识,小编通过实际案例向大家展示操作过程,操作方法简单快捷,实用性强,希望这篇"Curator Framework怎么用"文章能帮助大家解决问题。

Framework 比较简单,就是一些CRUD,Watch :

package curator.framework;import java.util.List;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;public class FrameworkDemo {        public static void main(String[] args) {                connection1();        }        private static void connection1() {                RetryPolicy retryPolicy = new ExponentialBackoffRetry(1000, 3);                CuratorFramework client = CuratorFrameworkFactory.builder()                                .connectString("127.0.0.1:2181")                                .sessionTimeoutMs(5000)                                .connectionTimeoutMs(10000)                                .retryPolicy(retryPolicy)                                .namespace("text").build();                client.start();                try {                        byte[] b = null;                        // 创建                        client.create().withMode(CreateMode.EPHEMERAL).forPath("/xx",new String("").getBytes());                        // 得到值                        client.getData().forPath("");                        // 得到子节点 List                        List ls = client.getChildren().forPath("");                        // 删除                        client.delete().forPath("");                        // 修改                        client.setData().forPath("", b);                } catch (Exception e) {                }                client.close();        }        private static void connection2() {                RetryPolicy retryPolicy = new ExponentialBackoffRetry(1000, 3);                CuratorFramework client = CuratorFrameworkFactory.newClient("127.0.0.1:2181", retryPolicy);                client.start();                client.close();        }                        }

关于"Curator Framework怎么用"的内容就介绍到这里了,感谢大家的阅读。如果想了解更多行业相关的知识,可以关注行业资讯频道,小编每天都会为大家更新不同的知识点。

0