这篇文章主要介绍“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<String>
List<String> 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怎么用”的内容就介绍到这里了,感谢大家的阅读。如果想了解更多行业相关的知识,可以关注亿速云行业资讯频道,小编每天都会为大家更新不同的知识点。
亿速云「云服务器」,即开即用、新一代英特尔至强铂金CPU、三副本存储NVMe SSD云盘,价格低至29元/月。点击查看>>
免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。
原文链接:https://my.oschina.net/u/1378390/blog/297058