本篇文章為大家展示了Curator該如何入門,內(nèi)容簡(jiǎn)明扼要并且容易理解,絕對(duì)能使你眼前一亮,通過這篇文章的詳細(xì)介紹希望你能有所收獲。
創(chuàng)新互聯(lián)專業(yè)為企業(yè)提供青河網(wǎng)站建設(shè)、青河做網(wǎng)站、青河網(wǎng)站設(shè)計(jì)、青河網(wǎng)站制作等企業(yè)網(wǎng)站建設(shè)、網(wǎng)頁(yè)設(shè)計(jì)與制作、青河企業(yè)網(wǎng)站模板建站服務(wù),十多年青河做網(wǎng)站經(jīng)驗(yàn),不只是建網(wǎng)站,更提供有價(jià)值的思路和整體網(wǎng)絡(luò)服務(wù)。
Curator是Netflix公司開源的一個(gè)Zookeeper客戶端,與Zookeeper提供的原生客戶端相比,Curator的抽象層次更高,簡(jiǎn)化了Zookeeper客戶端編程。
Maven依賴
org.apache.zookeeper zookeeper 3.4.9 org.apache.curator curator-recipes 2.7.0
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(); }
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());
byte[] buf = client.getData().forPath(path);System.out.println("get data path:"+path+", data:"+new String(buf));
client.setData().inBackground().forPath(path, "ricky".getBytes());
Stat stat = client.checkExists().forPath(path); if(stat==null){ System.out.println("exec create path:"+path); }else { System.out.println("exec getData"); }
client.delete().deletingChildrenIfNeeded().forPath("/pandora");
上述內(nèi)容就是Curator該如何入門,你們學(xué)到知識(shí)或技能了嗎?如果還想學(xué)到更多技能或者豐富自己的知識(shí)儲(chǔ)備,歡迎關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道。