CuratorFramework怎么用
这篇文章主要介绍“Curator Framework怎么用”的相关知识,小编通过实际案例向大家展示操作过程,操作方法简单快捷,实用性强,希望这篇“Curator Framework怎么用”文章能帮助大家解决问题。
榆树网站制作公司哪家好,找成都创新互联公司!从网页设计、网站建设、微信开发、APP开发、响应式网站设计等网站项目制作,到程序开发,运营维护。成都创新互联公司于2013年开始到现在10年的时间,我们拥有了丰富的建站经验和运维经验,来保证我们的工作的顺利进行。专注于网站建设就选成都创新互联公司。
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(""); // 得到子节点 ListList 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怎么用”的内容就介绍到这里了,感谢大家的阅读。如果想了解更多行业相关的知识,可以关注创新互联行业资讯频道,小编每天都会为大家更新不同的知识点。
当前题目:CuratorFramework怎么用
本文来源:http://azwzsj.com/article/jphide.html