Curator該如何入門

本篇文章為大家展示了Curator該如何入門，內(nèi)容簡(jiǎn)明扼要并且容易理解，絕對(duì)能使你眼前一亮，通過(guò)這篇文章的詳細(xì)介紹希望你能有所收獲。

Curator是Netflix公司開源的一個(gè)Zookeeper客戶端，與Zookeeper提供的原生客戶端相比，Curator的抽象層次更高，簡(jiǎn)化了Zookeeper客戶端編程。

Maven依賴

  <dependency>
    <groupId>org.apache.zookeeper</groupId>
    <artifactId>zookeeper</artifactId>
    <version>3.4.9</version>
</dependency>


  <dependency>
        <groupId>org.apache.curator</groupId>
        <artifactId>curator-recipes</artifactId>
        <version>2.7.0</version>
    </dependency>

1.創(chuàng)建Curator 連接實(shí)例（2種方式）

CuratorFramework client = CuratorFrameworkFactory.newClient(address, new ExponentialBackoffRetry(1000, 3));

CuratorFramework client = CuratorFrameworkFactory.builder()
                .connectString(address)
                .sessionTimeoutMs(1000)
                .retryPolicy(retryPolicy)
                .build();

CuratorFramework 使用之前必須先調(diào)用

client.start();

完成一系列操作后，調(diào)用client.close();方法，可以使用try-finally語(yǔ)句：

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

2.創(chuàng)建節(jié)點(diǎn)

a. 創(chuàng)建永久性節(jié)點(diǎn)

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

b. 創(chuàng)建臨時(shí)節(jié)點(diǎn)

client.create().withMode(CreateMode.EPHEMERAL).forPath(path, "hello".getBytes());

3.獲取節(jié)點(diǎn)值

byte[] buf = client.getData().forPath(path);System.out.println("get data path:"+path+", data:"+new String(buf));

4.設(shè)置節(jié)點(diǎn)值

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.刪除節(jié)點(diǎn)

client.delete().deletingChildrenIfNeeded().forPath("/pandora");

上述內(nèi)容就是Curator該如何入門，你們學(xué)到知識(shí)或技能了嗎？如果還想學(xué)到更多技能或者豐富自己的知識(shí)儲(chǔ)備，歡迎關(guān)注億速云行業(yè)資訊頻道。