2. 程式人生 > >基於Curator操作ZooKeeper（一）-基本操作

基於Curator操作ZooKeeper（一）-基本操作

阿新 • • 發佈：2018-11-12

Java原生API操作ZooKeeper可參看：

Java原生API操作Zookeeper（一）

Java原生API操作Zookeeper（二）

相關內容：

基於Curator操作ZooKeeper（二）-Watcher操作

基於Curator操作ZooKeeper（二）-Watcher操作-補充TreeCache

Java原生操作API有以下幾個不足之處：

  • 超時重連，不支援自動，必須要手動實現；
  • Watcher註冊一次後只能使用一次；
  • 不支援遞迴建立節點；

一般企業操作ZooKeeper的客戶端都會使用Apache Curator。和ZkClient一樣，Curator解決了很ZooKeeper客戶端非常底層的細節開發工作，包括連線重連、反覆註冊Watcher和NodeExistsException異常等，目前已經成為了Apache的頂級專案，是全世界範圍內使用最廣泛的ZooKeeper客戶端之一。

除了封裝一些開發人員不需要特別關注的底層細節之外，Curator還在ZooKeeperAPI的基礎上進行了包裝，提供了一套易用性和可讀性更強的Fluent風格的客戶端API框架。除此之外，Curator中還提供了ZooKeeper各種應用場景(Recipe，如共享鎖服務、Master選舉機制和分散式計數器等)的抽象封裝。

引入相關的依賴

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

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

建立客戶端

import org.apache.curator.RetryPolicy;
import org.apache.curator.framework.CuratorFramework;
import org.apache.curator.framework.CuratorFrameworkFactory;
import org.apache.curator.retry.ExponentialBackoffRetry;

public class CuratorOperator {

	public CuratorFramework client = null;
	public static final String zkServerPath = "192.168.220.135:2181,192.168.220.136:2181,192.168.220.137:2181";

	/**
	 * 例項化zk客戶端
	 */
	public CuratorOperator() {
		/**
		 * 同步建立zk示例，原生api是非同步的
		 * 
		 * curator連結zookeeper的重試策略:
		 *
		 * 1>ExponentialBackoffRetry【推薦】
			 * baseSleepTimeMs：初始sleep時間(ms)
			 * maxRetries：最大重試次數，超過時間就不連結了
			 * maxSleepMs：最大重試時間(ms)
		 *
		 * 給定一個初始sleep時間base5leep丁imeMs，在這個基礎上結合重試次數，通過以下公式計算出當前需要sleep的時間:
		   當前sleep時間=baseSleepTimeMs*Math.max(1, random.nextInt(1<<(retryCount+1)))
		   可以看出，隨著重試次數的增加，計算出的sleep時間會越來越大。如果該sleep時間在maxSleepMs的範圍之內，那麼就使用該sleep時間，否則使用maxSleepMs。另外，
		   maxRetries引數控制了最大重試次數，以避免無限制的重試。
		 */
		RetryPolicy retryPolicy = new ExponentialBackoffRetry(1000, 5);
		
		/**
		 * curator連結zookeeper的策略:
		 * 2>RetryNTimes【推薦】
			 * n：重試的次數
			 * sleepMsBetweenRetries：每次重試間隔的時間(ms)
		 */
//		RetryPolicy retryPolicy = new RetryNTimes(3, 5000);
		
		/**
		 * curator連結zookeeper的策略:
		 * 3>RetryOneTime
		 * sleepMsBetweenRetry:只重試一次，重試間隔的時間
		 */
//		RetryPolicy retryPolicy2 = new RetryOneTime(3000);
		
		/**
		 * 4>
		 * 永遠重試，不推薦使用
		 */
//		RetryPolicy retryPolicy3 = new RetryForever(retryIntervalMs)
		
		/**
		 * curator連結zookeeper的策略:
		 * 5>RetryUntilElapsed
		 * maxElapsedTimeMs:最大重試時間
		 * sleepMsBetweenRetries:每次重試間隔
		 * 重試時間超過maxElapsedTimeMs後，就不再重試
		 */
//		RetryPolicy retryPolicy4 = new RetryUntilElapsed(2000, 3000);

		//建立客戶端
		client = CuratorFrameworkFactory.builder()  //builder
				.connectString(zkServerPath)
				.sessionTimeoutMs(10000)  //session超時時間
				.retryPolicy(retryPolicy)  //重試策略
				.build();
		/**
		 * CuratorFrameworkFactory工廠在創建出一個客戶端CuratorFramework例項之後，實質上並沒有完成會話的建立，而是需要呼叫
		   CuratorFramework的sta rt)方法來完成會話的建立。
		 */
		client.start();
	}
	
	/**
	 * 
	 * @Description: 關閉zk客戶端連線
	 */
	public void closeZKClient() {
		if (client != null) {
			this.client.close();
		}
	}
	
	public static void main(String[] args) throws Exception {
		// 例項化
		CuratorOperator cto = new CuratorOperator();
		boolean isZkCuratorStarted = cto.client.isStarted();
		System.out.println("當前客戶的狀態：" + (isZkCuratorStarted ? "連線中" : "已關閉"));
		
		Thread.sleep(3000);
		
		cto.closeZKClient();
		boolean isZkCuratorStarted2 = cto.client.isStarted();
		System.out.println("當前客戶的狀態：" + (isZkCuratorStarted2 ? "連線中" : "已關閉"));
	}
	
}

執行結果：

namespace

在3.2.0及其之後版本的ZooKeeper中，添加了“Chroot”特性，該特性允許每個客戶端為自己設定一個名稱空間 ( Namespace )。如果一個ZooKeeper客戶端設定了Chroot，那麼該客戶端對伺服器的任何操作，都將會被限制在其自己的名稱空間下。

舉個例子來說，如果我們希望為應用X分配/apps/X下的所有子節點，那麼該應用可以將其所有ZooKeeper客戶端的Chroot設定為/apps/X的。一旦設定了Chroot之後，那麼對這個客戶端來說，所有的節點路徑都以/apps/X為根節點，它和ZooKeeper發起的所有請求中相關的節點路徑，都將是一個相對路徑—相對於/apps/X的路徑。例如通過ZooKeeper客戶端API建立點/test_chroot，那麼實際上在服務端被建立的節點是/apps/X/test_ chroot，通過設定Chroot，我們能夠將一個客戶端應用與ZooKeeper服務端
的一棵子樹相對應，在那些多個應用共用一個ZooKeeper叢集的場景下，這對於實現不同應用之間的相互隔離非常有幫助。

節點的增刪改查（同步）

新增節點：

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;
import org.apache.zookeeper.ZooDefs;

public class CuratorOperator {

	public CuratorFramework client = null;
	public static final String zkServerPath = "192.168.220.135:2181,192.168.220.136:2181,192.168.220.137:2181";

	/**
	 * 例項化zk客戶端
	 */
	public CuratorOperator() {
		/**
		 * 同步建立zk示例，原生api是非同步的
		 * 
		 * curator連結zookeeper的重試策略:
		 *
		 * 1>ExponentialBackoffRetry【推薦】
			 * baseSleepTimeMs：初始sleep時間(ms)
			 * maxRetries：最大重試次數，超過時間就不連結了
			 * maxSleepMs：最大重試時間(ms)
		 *
		 * 給定一個初始sleep時間base5leep丁imeMs，在這個基礎上結合重試次數，通過以下公式計算出當前需要sleep的時間:
		   當前sleep時間=baseSleepTimeMs*Math.max(1, random.nextInt(1<<(retryCount+1)))
		   可以看出，隨著重試次數的增加，計算出的sleep時間會越來越大。如果該sleep時間在maxSleepMs的範圍之內，那麼就使用該sleep時間，否則使用maxSleepMs。另外，
		   maxRetries引數控制了最大重試次數，以避免無限制的重試。
		 */
		RetryPolicy retryPolicy = new ExponentialBackoffRetry(1000, 5);
		
		/**
		 * curator連結zookeeper的策略:
		 * 2>RetryNTimes【推薦】
			 * n：重試的次數
			 * sleepMsBetweenRetries：每次重試間隔的時間(ms)
		 */
//		RetryPolicy retryPolicy = new RetryNTimes(3, 5000);
		
		/**
		 * curator連結zookeeper的策略:
		 * 3>RetryOneTime
		 * sleepMsBetweenRetry:只重試一次，重試間隔的時間
		 */
//		RetryPolicy retryPolicy2 = new RetryOneTime(3000);
		
		/**
		 * 4>
		 * 永遠重試，不推薦使用
		 */
//		RetryPolicy retryPolicy3 = new RetryForever(retryIntervalMs)
		
		/**
		 * curator連結zookeeper的策略:
		 * 5>RetryUntilElapsed
		 * maxElapsedTimeMs:最大重試時間
		 * sleepMsBetweenRetries:每次重試間隔
		 * 重試時間超過maxElapsedTimeMs後，就不再重試
		 */
//		RetryPolicy retryPolicy4 = new RetryUntilElapsed(2000, 3000);

		//建立客戶端
		client = CuratorFrameworkFactory.builder()  //builder
				.connectString(zkServerPath)
				.sessionTimeoutMs(10000)  //session超時時間
				.retryPolicy(retryPolicy)  //重試策略
				//namespace
				.namespace("testCRUD")
				.build();
		/**
		 * CuratorFrameworkFactory工廠在創建出一個客戶端CuratorFramework例項之後，實質上並沒有完成會話的建立，而是需要呼叫
		   CuratorFramework的sta rt)方法來完成會話的建立。
		 */
		client.start();
	}
	
	/**
	 * 
	 * @Description: 關閉zk客戶端連線
	 */
	public void closeZKClient() {
		if (client != null) {
			this.client.close();
		}
	}
	
	public static void main(String[] args) throws Exception {
		// 例項化
		CuratorOperator cto = new CuratorOperator();
		boolean isZkCuratorStarted = cto.client.isStarted();
		System.out.println("當前客戶的狀態：" + (isZkCuratorStarted ? "連線中" : "已關閉"));

		//建立節點
		String nodePath = "/dongguabai/test";
        byte[] data = "abcd".getBytes();
        cto.client.create()
                .creatingParentContainersIfNeeded()   //遞迴建立節點
                .withMode(CreateMode.PERSISTENT)      //節點模式
                .withACL(ZooDefs.Ids.OPEN_ACL_UNSAFE) //ACL
                .forPath(nodePath,data); //不指定內容，則內容為空

        Thread.sleep(3000);
		
		cto.closeZKClient();
		boolean isZkCuratorStarted2 = cto.client.isStarted();
		System.out.println("當前客戶的狀態：" + (isZkCuratorStarted2 ? "連線中" : "已關閉"));
	}
	
}

有個要注意的地方是：

由於在ZooKeeper中規定了所有非葉子節點必須為持久節點，呼叫上面這個API之後，只有path引數對應的資料節點是臨時節點，其父節點均為持久節點。

查詢某個節點下的資料：

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;
import org.apache.zookeeper.ZooDefs;
import org.apache.zookeeper.data.Stat;

public class CuratorOperator {

	public CuratorFramework client = null;
	public static final String zkServerPath = "192.168.220.135:2181,192.168.220.136:2181,192.168.220.137:2181";

	/**
	 * 例項化zk客戶端
	 */
	public CuratorOperator() {
		/**
		 * 同步建立zk示例，原生api是非同步的
		 * 
		 * curator連結zookeeper的重試策略:
		 *
		 * 1>ExponentialBackoffRetry【推薦】
			 * baseSleepTimeMs：初始sleep時間(ms)
			 * maxRetries：最大重試次數，超過時間就不連結了
			 * maxSleepMs：最大重試時間(ms)
		 *
		 * 給定一個初始sleep時間base5leep丁imeMs，在這個基礎上結合重試次數，通過以下公式計算出當前需要sleep的時間:
		   當前sleep時間=baseSleepTimeMs*Math.max(1, random.nextInt(1<<(retryCount+1)))
		   可以看出，隨著重試次數的增加，計算出的sleep時間會越來越大。如果該sleep時間在maxSleepMs的範圍之內，那麼就使用該sleep時間，否則使用maxSleepMs。另外，
		   maxRetries引數控制了最大重試次數，以避免無限制的重試。
		 */
		RetryPolicy retryPolicy = new ExponentialBackoffRetry(1000, 5);
		
		/**
		 * curator連結zookeeper的策略:
		 * 2>RetryNTimes【推薦】
			 * n：重試的次數
			 * sleepMsBetweenRetries：每次重試間隔的時間(ms)
		 */
//		RetryPolicy retryPolicy = new RetryNTimes(3, 5000);
		
		/**
		 * curator連結zookeeper的策略:
		 * 3>RetryOneTime
		 * sleepMsBetweenRetry:只重試一次，重試間隔的時間
		 */
//		RetryPolicy retryPolicy2 = new RetryOneTime(3000);
		
		/**
		 * 4>
		 * 永遠重試，不推薦使用
		 */
//		RetryPolicy retryPolicy3 = new RetryForever(retryIntervalMs)
		
		/**
		 * curator連結zookeeper的策略:
		 * 5>RetryUntilElapsed
		 * maxElapsedTimeMs:最大重試時間
		 * sleepMsBetweenRetries:每次重試間隔
		 * 重試時間超過maxElapsedTimeMs後，就不再重試
		 */
//		RetryPolicy retryPolicy4 = new RetryUntilElapsed(2000, 3000);

		//建立客戶端
		client = CuratorFrameworkFactory.builder()  //builder
				.connectString(zkServerPath)
				.sessionTimeoutMs(10000)  //session超時時間
				.retryPolicy(retryPolicy)  //重試策略
				//namespace：
				.namespace("testCRUD")
				.build();
		/**
		 * CuratorFrameworkFactory工廠在創建出一個客戶端CuratorFramework例項之後，實質上並沒有完成會話的建立，而是需要呼叫
		   CuratorFramework的sta rt)方法來完成會話的建立。
		 */
		client.start();
	}
	
	/**
	 * 
	 * @Description: 關閉zk客戶端連線
	 */
	public void closeZKClient() {
		if (client != null) {
			this.client.close();
		}
	}
	
	public static void main(String[] args) throws Exception {
		// 例項化
		CuratorOperator cto = new CuratorOperator();
		boolean isZkCuratorStarted = cto.client.isStarted();
		System.out.println("當前客戶的狀態：" + (isZkCuratorStarted ? "連線中" : "已關閉"));

		//建立節點
		String nodePath = "/dongguabai/test";
        byte[] data = "abcd".getBytes();
        cto.client.create()
                .creatingParentContainersIfNeeded()   //遞迴建立節點
                .withMode(CreateMode.PERSISTENT)      //節點模式
                .withACL(ZooDefs.Ids.OPEN_ACL_UNSAFE) //ACL
                .forPath(nodePath,data); //不指定內容，則內容為空

        //獲取節點
        byte[] bytes = cto.client.getData().forPath(nodePath);
        System.out.println("第一次獲取節點資料為："+new String(bytes));

        Stat stat = new Stat();
        byte[] bytes1 = cto.client.getData().storingStatIn(stat).forPath(nodePath);
        System.out.println("第二次獲取節點資料為："+new String(bytes1));
        System.out.println("獲取的Stat為："+ JsonUtil.toJSON(stat));


        Thread.sleep(3000);
		
		cto.closeZKClient();
		boolean isZkCuratorStarted2 = cto.client.isStarted();
		System.out.println("當前客戶的狀態：" + (isZkCuratorStarted2 ? "連線中" : "已關閉"));
	}
	
}

輸出結果：

查詢子節點：

資料準備：

import org.apache.curator.RetryPolicy;
import org.apache.curator.framework.CuratorFramework;
import org.apache.curator.framework.CuratorFrameworkFactory;
import org.apache.curator.retry.ExponentialBackoffRetry;

import java.util.List;

public class CuratorOperator {

	public CuratorFramework client = null;
	public static final String zkServerPath = "192.168.220.135:2181,192.168.220.136:2181,192.168.220.137:2181";

	/**
	 * 例項化zk客戶端
	 */
	public CuratorOperator() {
		/**
		 * 同步建立zk示例，原生api是非同步的
		 * 
		 * curator連結zookeeper的重試策略:
		 *
		 * 1>ExponentialBackoffRetry【推薦】
			 * baseSleepTimeMs：初始sleep時間(ms)
			 * maxRetries：最大重試次數，超過時間就不連結了
			 * maxSleepMs：最大重試時間(ms)
		 *
		 * 給定一個初始sleep時間base5leep丁imeMs，在這個基礎上結合重試次數，通過以下公式計算出當前需要sleep的時間:
		   當前sleep時間=baseSleepTimeMs*Math.max(1, random.nextInt(1<<(retryCount+1)))
		   可以看出，隨著重試次數的增加，計算出的sleep時間會越來越大。如果該sleep時間在maxSleepMs的範圍之內，那麼就使用該sleep時間，否則使用maxSleepMs。另外，
		   maxRetries引數控制了最大重試次數，以避免無限制的重試。
		 */
		RetryPolicy retryPolicy = new ExponentialBackoffRetry(1000, 5);
		
		/**
		 * curator連結zookeeper的策略:
		 * 2>RetryNTimes【推薦】
			 * n：重試的次數
			 * sleepMsBetweenRetries：每次重試間隔的時間(ms)
		 */
//		RetryPolicy retryPolicy = new RetryNTimes(3, 5000);
		
		/**
		 * curator連結zookeeper的策略:
		 * 3>RetryOneTime
		 * sleepMsBetweenRetry:只重試一次，重試間隔的時間
		 */
//		RetryPolicy retryPolicy2 = new RetryOneTime(3000);
		
		/**
		 * 4>
		 * 永遠重試，不推薦使用
		 */
//		RetryPolicy retryPolicy3 = new RetryForever(retryIntervalMs)
		
		/**
		 * curator連結zookeeper的策略:
		 * 5>RetryUntilElapsed
		 * maxElapsedTimeMs:最大重試時間
		 * sleepMsBetweenRetries:每次重試間隔
		 * 重試時間超過maxElapsedTimeMs後，就不再重試
		 */
//		RetryPolicy retryPolicy4 = new RetryUntilElapsed(2000, 3000);

		//建立客戶端
		client = CuratorFrameworkFactory.builder()  //builder
				.connectString(zkServerPath)
				.sessionTimeoutMs(10000)  //session超時時間
				.retryPolicy(retryPolicy)  //重試策略
				//namespace：
				.namespace("testCRUD")
				.build();
		/**
		 * CuratorFrameworkFactory工廠在創建出一個客戶端CuratorFramework例項之後，實質上並沒有完成會話的建立，而是需要呼叫
		   CuratorFramework的sta rt)方法來完成會話的建立。
		 */
		client.start();
	}
	
	/**
	 * 
	 * @Description: 關閉zk客戶端連線
	 */
	public void closeZKClient() {
		if (client != null) {
			this.client.close();
		}
	}
	
	public static void main(String[] args) throws Exception {
		// 例項化
		CuratorOperator cto = new CuratorOperator();
		boolean isZkCuratorStarted = cto.client.isStarted();
		System.out.println("當前客戶的狀態：" + (isZkCuratorStarted ? "連線中" : "已關閉"));

        String nodePath = "/dongguabai/a";
        //建立節點
       /* byte[] data = "abcd".getBytes();
        cto.client.create()
                .creatingParentContainersIfNeeded()   //遞迴建立節點
                .withMode(CreateMode.PERSISTENT)      //節點模式
                .withACL(ZooDefs.Ids.OPEN_ACL_UNSAFE) //ACL
                .forPath(nodePath,data); //不指定內容，則內容為空*/

        //獲取節點
       /* byte[] bytes = cto.client.getData().forPath(nodePath);
        System.out.println("第一次獲取節點資料為："+new String(bytes));

        Stat stat = new Stat();
        byte[] bytes1 = cto.client.getData().storingStatIn(stat).forPath(nodePath);
        System.out.println("第二次獲取節點資料為："+new String(bytes1));
        System.out.println("獲取的Stat為："+ JsonUtil.toJSON(stat));
*/
        //獲取子節點
        List<String> list = cto.client.getChildren().forPath(nodePath);
        System.out.println("開始列印子節點：");
        list.forEach(result-> System.out.println(result));
        System.out.println("列印結束！");

        //修改節點
      /*  Stat stat = cto.client.setData().forPath(nodePath,"new1".getBytes());
        System.out.println("第一次獲取節點資料為："+new String(cto.client.getData().forPath(nodePath)));

        Stat stat1 = cto.client.setData().withVersion(stat.getVersion()).forPath(nodePath, "new2".getBytes());
        System.out.println("第二次獲取節點資料為："+new String(cto.client.getData().forPath(nodePath)));*/

        //刪除節點
       /* Stat stat = new Stat();
        byte[] bytes1 = cto.client.getData().storingStatIn(stat).forPath(nodePath);
        System.out.println("獲取節點資料為："+new String(bytes1));
        cto.client.delete()
                .guaranteed()  //防止網路抖動，只要客戶端會話有效，那麼Curator 會在後臺持續進行刪除操作，直到節點刪除成功
                .deletingChildrenIfNeeded()  //如果有子節點會刪除，注意除非人為刪除namespace，否則namespace不會刪除
                .withVersion(stat.getVersion())
                .forPath(nodePath);*/

        Thread.sleep(3000);
		
		cto.closeZKClient();
		boolean isZkCuratorStarted2 = cto.client.isStarted();
		System.out.println("當前客戶的狀態：" + (isZkCuratorStarted2 ? "連線中" : "已關閉"));
	}
	
}

修改節點：

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.data.Stat;

public class CuratorOperator {

	public CuratorFramework client = null;
	public static final String zkServerPath = "192.168.220.135:2181,192.168.220.136:2181,192.168.220.137:2181";

	/**
	 * 例項化zk客戶端
	 */
	public CuratorOperator() {
		/**
		 * 同步建立zk示例，原生api是非同步的
		 * 
		 * curator連結zookeeper的重試策略:
		 *
		 * 1>ExponentialBackoffRetry【推薦】
			 * baseSleepTimeMs：初始sleep時間(ms)
			 * maxRetries：最大重試次數，超過時間就不連結了
			 * maxSleepMs：最大重試時間(ms)
		 *
		 * 給定一個初始sleep時間base5leep丁imeMs，在這個基礎上結合重試次數，通過以下公式計算出當前需要sleep的時間:
		   當前sleep時間=baseSleepTimeMs*Math.max(1, random.nextInt(1<<(retryCount+1)))
		   可以看出，隨著重試次數的增加，計算出的sleep時間會越來越大。如果該sleep時間在maxSleepMs的範圍之內，那麼就使用該sleep時間，否則使用maxSleepMs。另外，
		   maxRetries引數控制了最大重試次數，以避免無限制的重試。
		 */
		RetryPolicy retryPolicy = new ExponentialBackoffRetry(1000, 5);
		
		/**
		 * curator連結zookeeper的策略:
		 * 2>RetryNTimes【推薦】
			 * n：重試的次數
			 * sleepMsBetweenRetries：每次重試間隔的時間(ms)
		 */
//		RetryPolicy retryPolicy = new RetryNTimes(3, 5000);
		
		/**
		 * curator連結zookeeper的策略:
		 * 3>RetryOneTime
		 * sleepMsBetweenRetry:只重試一次，重試間隔的時間
		 */
//		RetryPolicy retryPolicy2 = new RetryOneTime(3000);
		
		/**
		 * 4>
		 * 永遠重試，不推薦使用
		 */
//		RetryPolicy retryPolicy3 = new RetryForever(retryIntervalMs)
		
		/**
		 * curator連結zookeeper的策略:
		 * 5>RetryUntilElapsed
		 * maxElapsedTimeMs:最大重試時間
		 * sleepMsBetweenRetries:每次重試間隔
		 * 重試時間超過maxElapsedTimeMs後，就不再重試
		 */
//		RetryPolicy retryPolicy4 = new RetryUntilElapsed(2000, 3000);

		//建立客戶端
		client = CuratorFrameworkFactory.builder()  //builder
				.connectString(zkServerPath)
				.sessionTimeoutMs(10000)  //session超時時間
				.retryPolicy(retryPolicy)  //重試策略
				//namespace：
				.namespace("testCRUD")
				.build();
		/**
		 * CuratorFrameworkFactory工廠在創建出一個客戶端CuratorFramework例項之後，實質上並沒有完成會話的建立，而是需要呼叫
		   CuratorFramework的sta rt)方法來完成會話的建立。
		 */
		client.start();
	}
	
	/**
	 * 
	 * @Description: 關閉zk客戶端連線
	 */
	public void closeZKClient() {
		if (client != null) {
			this.client.close();
		}
	}
	
	public static void main(String[] args) throws Exception {
		// 例項化
		CuratorOperator cto = new CuratorOperator();
		boolean isZkCuratorStarted = cto.client.isStarted();
		System.out.println("當前客戶的狀態：" + (isZkCuratorStarted ? "連線中" : "已關閉"));

        String nodePath = "/dongguabai/test";
        //建立節點
       /* byte[] data = "abcd".getBytes();
        cto.client.create()
                .creatingParentContainersIfNeeded()   //遞迴建立節點
                .withMode(CreateMode.PERSISTENT)      //節點模式
                .withACL(ZooDefs.Ids.OPEN_ACL_UNSAFE) //ACL
                .forPath(nodePath,data); //不指定內容，則內容為空*/

        //獲取節點
       /* byte[] bytes = cto.client.getData().forPath(nodePath);
        System.out.println("第一次獲取節點資料為："+new String(bytes));

        Stat stat = new Stat();
        byte[] bytes1 = cto.client.getData().storingStatIn(stat).forPath(nodePath);
        System.out.println("第二次獲取節點資料為："+new String(bytes1));
        System.out.println("獲取的Stat為："+ JsonUtil.toJSON(stat));*/

        //修改節點
        Stat stat = cto.client.setData().forPath(nodePath,"new1".getBytes());
        System.out.println("第一次獲取節點資料為："+new String(cto.client.getData().forPath(nodePath)));

        Stat stat1 = cto.client.setData().withVersion(stat.getVersion()).forPath(nodePath, "new2".getBytes());
        System.out.println("第二次獲取節點資料為："+new String(cto.client.getData().forPath(nodePath)));



        Thread.sleep(3000);
		
		cto.closeZKClient();
		boolean isZkCuratorStarted2 = cto.client.isStarted();
		System.out.println("當前客戶的狀態：" + (isZkCuratorStarted2 ? "連線中" : "已關閉"));
	}
	
}

輸出結果：

刪除節點：

執行程式之前：

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.data.Stat;

public class CuratorOperator {

	public CuratorFramework client = null;
	public static final String zkServerPath = "192.168.220.135:2181,192.168.220.136:2181,192.168.220.137:2181";

	/**
	 * 例項化zk客戶端
	 */
	public CuratorOperator() {
		/**
		 * 同步建立zk示例，原生api是非同步的
		 * 
		 * curator連結zookeeper的重試策略:
		 *
		 * 1>ExponentialBackoffRetry【推薦】
			 * baseSleepTimeMs：初始sleep時間(ms)
			 * maxRetries：最大重試次數，超過時間就不連結了
			 * maxSleepMs：最大重試時間(ms)
		 *
		 * 給定一個初始sleep時間base5leep丁imeMs，在這個基礎上結合重試次數，通過以下公式計算出當前需要sleep的時間:
		   當前sleep時間=baseSleepTimeMs*Math.max(1, random.nextInt(1<<(retryCount+1)))
		   可以看出，隨著重試次數的增加，計算出的sleep時間會越來越大。如果該sleep時間在maxSleepMs的範圍之內，那麼就使用該sleep時間，否則使用maxSleepMs。另外，
		   maxRetries引數控制了最大重試次數，以避免無限制的重試。
		 */
		RetryPolicy retryPolicy = new ExponentialBackoffRetry(1000, 5);
		
		/**
		 * curator連結zookeeper的策略:
		 * 2>RetryNTimes【推薦】
			 * n：重試的次數
			 * sleepMsBetweenRetries：每次重試間隔的時間(ms)
		 */
//		RetryPolicy retryPolicy = new RetryNTimes(3, 5000);
		
		/**
		 * curator連結zookeeper的策略:
		 * 3>RetryOneTime
		 * sleepMsBetweenRetry:只重試一次，重試間隔的時間
		 */
//		RetryPolicy retryPolicy2 = new RetryOneTime(3000);
		
		/**
		 * 4>
		 * 永遠重試，不推薦使用
		 */
//		RetryPolicy retryPolicy3 = new RetryForever(retryIntervalMs)
		
		/**
		 * curator連結zookeeper的策略:
		 * 5>RetryUntilElapsed
		 * maxElapsedTimeMs:最大重試時間
		 * sleepMsBetweenRetries:每次重試間隔
		 * 重試時間超過maxElapsedTimeMs後，就不再重試
		 */
//		RetryPolicy retryPolicy4 = new RetryUntilElapsed(2000, 3000);

		//建立客戶端
		client = CuratorFrameworkFactory.builder()  //builder
				.connectString(zkServerPath)
				.sessionTimeoutMs(10000)  //session超時時間
				.retryPolicy(retryPolicy)  //重試策略
				//namespace：
				.namespace("testCRUD")
				.build();
		/**
		 * CuratorFrameworkFactory工廠在創建出一個客戶端CuratorFramework例項之後，實質上並沒有完成會話的建立，而是需要呼叫
		   CuratorFramework的sta rt)方法來完成會話的建立。
		 */
		client.start();
	}
	
	/**
	 * 
	 * @Description: 關閉zk客戶端連線
	 */
	public void closeZKClient() {
		if (client != null) {
			this.client.close();
		}
	}
	
	public static void main(String[] args) throws Exception {
		// 例項化
		CuratorOperator cto = new CuratorOperator();
		boolean isZkCuratorStarted = cto.client.isStarted();
		System.out.println("當前客戶的狀態：" + (isZkCuratorStarted ? "連線中" : "已關閉"));

        String nodePath = "/dongguabai/test";
        //建立節點
       /* byte[] data = "abcd".getBytes();
        cto.client.create()
                .creatingParentContainersIfNeeded()   //遞迴建立節點
                .withMode(CreateMode.PERSISTENT)      //節點模式
                .withACL(ZooDefs.Ids.OPEN_ACL_UNSAFE) //ACL
                .forPath(nodePath,data); //不指定內容，則內容為空*/

        //獲取節點
       /* byte[] bytes = cto.client.getData().forPath(nodePath);
        System.out.println("第一次獲取節點資料為："+new String(bytes));

        Stat stat = new Stat();
        byte[] bytes1 = cto.client.getData().storingStatIn(stat).forPath(nodePath);
        System.out.println("第二次獲取節點資料為："+new String(bytes1));
        System.out.println("獲取的Stat為："+ JsonUtil.toJSON(stat));*/

        //修改節點
      /*  Stat stat = cto.client.setData().forPath(nodePath,"new1".getBytes());
        System.out.println("第一次獲取節點資料為："+new String(cto.client.getData().forPath(nodePath)));

        Stat stat1 = cto.client.setData().withVersion(stat.getVersion()).forPath(nodePath, "new2".getBytes());
        System.out.println("第二次獲取節點資料為："+new String(cto.client.getData().forPath(nodePath)));*/

        //刪除節點
        Stat stat = new Stat();
        byte[] bytes1 = cto.client.getData().storingStatIn(stat).forPath(nodePath);
        System.out.println("獲取節點資料為："+new String(bytes1));
        cto.client.delete()
                .guaranteed()  //防止網路抖動，只要客戶端會話有效，那麼Curator 會在後臺持續進行刪除操作，直到節點刪除成功
                .deletingChildrenIfNeeded()  //如果有子節點會刪除，注意除非人為刪除namespace，否則namespace不會刪除
                .withVersion(stat.getVersion())
                .forPath(nodePath);

        Thread.sleep(3000);
		
		cto.closeZKClient();
		boolean isZkCuratorStarted2 = cto.client.isStarted();
		System.out.println("當前客戶的狀態：" + (isZkCuratorStarted2 ? "連線中" : "已關閉"));
	}
	
}

執行結果：

判斷節點是否存在：

其他相關資料：

https://blog.csdn.net/en_joker/article/details/78778917

https://www.cnblogs.com/LiZhiW/p/4926385.html?utm_source=tuicool&utm_medium=referral

相關推薦

基於Curator操作ZooKeeper（一）-基本操作

Java原生API操作ZooKeeper可參看： Java原生API操作Zookeeper（一） Java原生API操作Zookeeper（二） 相關內容： 基於Curator操作ZooKeeper（二）-Watcher操作 基於Curator操作ZooKeeper（二）-W

基於Curator操作ZooKeeper（二）-Watcher操作-補充TreeCache

轉自：https://blog.csdn.net/Leafage_M/article/details/78735485#treecache Java原生API操作ZooKeeper可參看： Java原生API操作Zookeeper（一） Java原生API操作Zookeeper（二）

基於Curator操作ZooKeeper（二）-Watcher操作

Java原生API操作ZooKeeper可參看： Java原生API操作Zookeeper（一） Java原生API操作Zookeeper（二） 相關內容： 基於Curator操作ZooKeeper（一）-基本操作 基於Curator操作ZooKeeper（二）-Watche

TensorFlow入門筆記（一）基本操作

result 官方教程 with orf print blog res ont constant 0. 環境配置 安裝Anaconda，python3環境，然後利用conda命令配置的tensorflow環境。 參考極客學院翻譯TensorFlow官方教程：http://w

R語言速成_尹鴻（一）基本操作

賦值 > x <- 5 #賦值 > ls() #檢視已經建立的變數 [1] "x" > age <- c(1,3,5,2,11,9,3,9,12,3) > weight <- c(4.4,5.3,7.2,5.2,8.5,7.3,6.

原子操作類（一）原子操作類詳細介紹

expected 文章 span del 也有 pair 上一個 ride 操作類 引言 ??Java從JDK1.5開始提供了java.util.concurrent.atomic包，方便程序員在多線程環境下，無鎖的進行原子操作。原子變量的底層使用了處理器提供的原子指令，但

VS2010 操作Word（二）基本操作

建立基本的工程之後，下面就是具體的操作和應用了！ 本節主要介紹如何建立，寫入，儲存一個Word。 我們可以建立一個Word的操作類，我這裡建立的是一個DLL程式，這樣可以將一個Word操作封裝起來，便於其他程式呼叫。 按照第一節的類似介紹，我一次添加了需要用到了類： 同

基於Curator操作ZooKeeper（三）-Curator整合Spring

Java原生API操作ZooKeeper可參看： Java原生API操作Zookeeper（一） Java原生API操作Zookeeper（二） 相關內容： 基於Curator操作ZooKeeper（一）-基本操作 基於Curator操作ZooKeeper（二）-Watche

Python學習記錄——Ubuntu（一）基本配置、快捷鍵和文件操作命令行

默認 spa 地址 重新 當前時間 search 一個空格 類型 soc 1.常用的獲取幫助方法： （1）-h （2）--help （3）man 　　man 章節 查找的信息 #用於查詢某指令在某章節中的幫助信息 　　man -f #精確查找 　　man -k #模糊查

基於Java語言構建區塊鏈（一）—— 基本原型

java 分布式 程序員 後端引言 區塊鏈技術是一項比人工智能更具革命性的技術，人工智能只是提高了人類的生產力，而區塊鏈則將改變人類社會的生產關系，它將會顛覆我們人類社會現有的協作方式。了解和掌握區塊鏈相關知識和技術，是我們每位開發人員必須要去做的事情，這樣我們才能把握住這波時代趨勢的紅利。 本文將基於Jav

【Python-GPU加速】基於Numba的GPU計算加速（一）基本

Numba是一個可以利用GPU/CPU和CUDA 對python函式進行動態編譯，大幅提高執行速度的加速工具包。 利用修飾器@jit,@cuda.jit,@vectorize等對函式進行編譯 JIT：即時編譯，提高執行速度 基於特定資料型別

zookeeper詳解（一） -- 基本結構

1、zookeeper是什麼 ZooKeeper是一個分散式的，開放原始碼的分散式應用程式協調服務，是Google的Chubby一個開源的實現，是Hadoop的重要元件，CDH版本中更是使用它進行Namenode的協調控制。它是一個為分散式應用提供一致性服務的軟體，提

ZooKeeper系列（一）基本概念

Zookeeper產生的背景 ZooKeeper---譯名為“動物園管理員”。動物園裡當然有好多的動物，遊客可以根據動物園提供的嚮導圖到不同的場館觀賞各種型別的動物，而不是像走在原始叢林裡，心驚膽顫

Redis的基本資料操作命令（一）

一 String型別 1 set 設定key對應的值。 set name Diamond 2 setnx 設定key的值，如果key已存在，返回0。nx為not exist的意思。 127.0.0.1:6379> setnx n

EOS的基礎知識（一）基本的命令操作

EOS環境的搭建和節點啟動分為以下兩步： 第一步：下載EOS的原始碼 使用命令：git clonehttps://github.com/EOSIO/eos –recursive 下載原始碼，時間大概1-3小時。編譯要求：計算機記憶體要求要有8GB以上。 下載編譯之後，

CQL（Cypher）基本操作（一）

Neo4j 標籤屬性圖模型 • Nodes – 節點。在其他圖模型中稱作“點”、“頂點”、“物件”。 • Relationships – 關係。在其他圖模型中也稱作“邊”、“弧”、“線”。關係擁有型別。 • Properties – 屬性，

分布式利器Zookeeper（一）

zookeeperZookeeper不論是在實際項目中，還是在各種分布式開源項目中都得到了廣泛應用，從本篇博客開始，將為大家帶來我對Zookeeper的認識。這個系列將會涵蓋Zookeeper的介紹、環境搭建、配置說明、Java操作Zookeeper（原生API方式）、zkclient操作Zookeeper方

OpenGL在MFC中的使用總結（一）——基本框架

palette 接受 white 要求 無效 結構 del 一次 是你 項目中要畫3D顯示的模型，於是要用到OpenGL,加上是在MFC中，並且是在MFC中的ActiveX中使用。再並且鑒於他們程序主框架的設定。常規的方法還不一定能實現。所以還是查過不少資料，在此一一總

HTML5入門（一）—— 基本標簽&表格

詳細信息 樣式設置 定位 content 瀏覽器中 解釋 加載 郵箱 常用 一、HTML簡介 超文本標簽語言，即網頁的源碼。而瀏覽器就是翻譯解釋HTML源碼的工具。 二、HTML Head部分 <1>Head的作用

Django學習（一）---基本配置及創建項目、應用

cut 維護 onf response settings 通過 學習 clu render 安裝：在Django官網下載最新版Django然後通過pip安裝即可 一、創建項目 進入文件夾，打開cmd窗口，輸入django-admin startproject myblog(