Curator该如何入门-成都创新互联网站建设

关于创新互联

多方位宣传企业产品与服务 突出企业形象

公司简介 公司的服务 荣誉资质 新闻动态 联系我们

Curator该如何入门

本篇文章为大家展示了Curator该如何入门,内容简明扼要并且容易理解,绝对能使你眼前一亮,通过这篇文章的详细介绍希望你能有所收获。

创新互联专业为企业提供青河网站建设、青河做网站、青河网站设计、青河网站制作等企业网站建设、网页设计与制作、青河企业网站模板建站服务,十多年青河做网站经验,不只是建网站,更提供有价值的思路和整体网络服务。

Curator是Netflix公司开源的一个Zookeeper客户端,与Zookeeper提供的原生客户端相比,Curator的抽象层次更高,简化了Zookeeper客户端编程。

Maven依赖

  
    org.apache.zookeeper
    zookeeper
    3.4.9



  
        org.apache.curator
        curator-recipes
        2.7.0
    
1.创建Curator 连接实例(2种方式)
CuratorFramework client = CuratorFrameworkFactory.newClient(address, new ExponentialBackoffRetry(1000, 3));
CuratorFramework client = CuratorFrameworkFactory.builder()
                .connectString(address)
                .sessionTimeoutMs(1000)
                .retryPolicy(retryPolicy)
                .build();

CuratorFramework 使用之前必须先调用

client.start();

完成一系列操作后,调用client.close();方法,可以使用try-finally语句:

CuratorFramework client = CuratorFrameworkFactory.newClient(address, new ExponentialBackoffRetry(1000, 3));
try{
    client.start();
    ...
}finally {
    if(client!=null)
        client.close();
}
2.创建节点

a. 创建永久性节点

client.create()
      .creatingParentContainersIfNeeded()
      .withMode(CreateMode.PERSISTENT)
      .withACL(ZooDefs.Ids.OPEN_ACL_UNSAFE)
      .forPath(path, "hello, zk".getBytes());

b. 创建临时节点

client.create().withMode(CreateMode.EPHEMERAL).forPath(path, "hello".getBytes());
3.获取节点值
byte[] buf = client.getData().forPath(path);System.out.println("get data path:"+path+", data:"+new String(buf));
4.设置节点值
client.setData().inBackground().forPath(path, "ricky".getBytes());
5.checkExists
Stat stat = client.checkExists().forPath(path);
if(stat==null){
    System.out.println("exec create path:"+path);
}else {
    System.out.println("exec getData");
}
6.删除节点
client.delete().deletingChildrenIfNeeded().forPath("/pandora");

上述内容就是Curator该如何入门,你们学到知识或技能了吗?如果还想学到更多技能或者丰富自己的知识储备,欢迎关注创新互联行业资讯频道。


名称栏目:Curator该如何入门
本文来源:http://kswsj.cn/article/gsoood.html

其他资讯