Zookeeper：Java API - 版本历史

Eijux：/* Curator */

2021-09-30T10:44:31Z

Curator

@@ 第486行： / 第486行： @@
 <syntaxhighlight lang="Java" highlight="">
 /**
 * 创建节点
@@ 第538行： / 第551行： @@
 <syntaxhighlight lang="Java" highlight="">
 /**
 * 读取节点
@@ 第578行： / 第604行： @@
 调用'''setData()'''方法进行同步更新：
 <syntaxhighlight lang="Java" highlight="">
 /**
 * 更新节点
@@ 第657行： / 第696行： @@
 调用'''delete()'''方法进行同步删除：
 <syntaxhighlight lang="Java" highlight="">
 /**
 * 删除节点

Eijux：/* 创建Curator客户端 */

2021-09-30T10:38:04Z

创建Curator客户端

←上一版本		2021年9月30日 (四) 18:38的版本
第451行：		第451行：
	* @return CuratorFramework实例		* @return CuratorFramework实例
	*/		*/
	public static ~~CuratorFrameworkcreateSimple~~(String connectionString) {		public static CuratorFramework createSimple(String connectionString) {
	return CuratorFrameworkFactory.newClient(connectionString, retryPolicy);		return CuratorFrameworkFactory.newClient(connectionString, retryPolicy);
	}		}
第463行：		第463行：
	* @return CuratorFramework实例		* @return CuratorFramework实例
	*/		*/
	public static ~~CuratorFrameworkcreateWithOptions~~(		public static CuratorFramework createWithOptions(
	String connectionString, RetryPolicyretryPolicy,		String connectionString, RetryPolicyretryPolicy,
	int connectionTimeoutMs,int sessionTimeoutMs)		int connectionTimeoutMs,int sessionTimeoutMs)

Eijux：/* 环境准备 */

2021-09-30T10:36:46Z

环境准备

←上一版本		2021年9月30日 (四) 18:36的版本
第384行：		第384行：
	=== 环境准备 ===		=== 环境准备 ===
	Curator 包含了以下几个包：		Curator 包含了以下几个包：
	# '''curator-framework'''~~：是对ZooKeeper的底层API的一些封装。~~		# '''curator-framework'''：是对ZooKeeper的'''底层API'''的一些封装。
	# '''curator-client'''~~：提供了一些客户端的操作，例如重试策略等。~~		# '''curator-client'''：提供了一些客户端的操作，例如'''重试策略'''等。
	# '''curator-recipes'''~~：封装了一些高级特性，如：Cache事件监听、选举、分布式锁、分布式计数器、分布式Barrier等。~~		# '''curator-recipes'''：封装了一些高级特性，如：'''Cache事件监听'''、选举、'''分布式锁'''、分布式计数器、分布式Barrier等。

Eijux：/* 异步删除 */

2021-09-29T07:04:43Z

异步删除

←上一版本		2021年9月29日 (三) 15:04的版本
第688行：		第688行：

	==== 异步删除 ====		==== 异步删除 ====
	~~异步删除思路同“异步更新”是一样的：异步删除同样需要用到~~ DeleteBuilder ~~构造者实例的“~~'''inBackground(AsyncCallback asyncCallback)'''”方法去设置回调。		异步删除思路同“异步更新”是一样的：异步删除同样需要用到“'''DeleteBuilder'''”构造者实例的“'''inBackground(AsyncCallback asyncCallback)'''”方法去设置回调。

	=== 总结 ===		=== 总结 ===

Eijux：/* 异步更新 */

2021-09-29T07:04:17Z

异步更新

←上一版本		2021年9月29日 (三) 15:04的版本
第604行：		第604行：

	==== 异步更新 ====		==== 异步更新 ====
	通过 SetDataBuilder ~~构造者实例的~~'''inBackground(AsyncCallback callback)'''~~方法，设置一个~~ AsyncCallback 回调实例：		通过“'''SetDataBuilder'''”构造者实例的“'''inBackground(AsyncCallback callback)'''”方法，设置一个 '''AsyncCallback''' 回调实例：
	* 异步执行完成之后，SetDataBuilder 构造者实例会再执行 AsyncCallback 实例的“processResult(...)”方法中的回调逻辑，即可完成更新后的其他操作。		* 异步执行完成之后，SetDataBuilder 构造者实例会再执行 AsyncCallback 实例的“processResult(...)”方法中的回调逻辑，即可完成更新后的其他操作。
	<syntaxhighlight lang="Java" highlight="11,33">		<syntaxhighlight lang="Java" highlight="11,33">

Eijux：/* 删除ZNode */

2021-09-29T07:03:14Z

删除ZNode

←上一版本		2021年9月29日 (三) 15:03的版本
第652行：		第652行：

	=== 删除ZNode ===		=== 删除ZNode ===
			节点的删除同更新一样，分为'''同步删除'''与'''异步删除'''。

			==== 同步删除 ====
			调用'''delete()'''方法进行同步删除：
			<syntaxhighlight lang="Java" highlight="">
			/**
			* 删除节点
			*/
			@Test
			public void deleteNode() {
			//创建客户端
			CuratorFramework client = ClientFactory.createSimple(ZK_ADDRESS);

			try {
			//启动客户端实例,连接服务器
			client.start();

			//删除节点
			String zkPath = "/test/CRUD/remoteNode-1";
			client.delete().forPath(zkPath);

			//删除后查看结果
			String parentPath = "/test";
			List<String> children = client.getChildren().forPath(parentPath);
			for (String child : children) {
			log.info("child:", child);
			}
			} catch (Exception e) {
			e.printStackTrace();
			} finally {
			CloseableUtils.closeQuietly(client);
			}
			}
			</syntaxhighlight>

			==== 异步删除 ====
			异步删除思路同“异步更新”是一样的：异步删除同样需要用到 DeleteBuilder 构造者实例的“'''inBackground(AsyncCallback asyncCallback)'''”方法去设置回调。

	=== 总结 ===		=== 总结 ===

Eijux：/* 更新ZNode */

2021-09-29T06:57:25Z

更新ZNode

←上一版本		2021年9月29日 (三) 14:57的版本
第573行：		第573行：

	=== 更新ZNode ===		=== 更新ZNode ===
			节点的更新分为'''同步更新'''与'''异步更新'''。

			==== 同步更新 ====
			调用'''setData()'''方法进行同步更新：
			<syntaxhighlight lang="Java" highlight="">
			/**
			* 更新节点
			*/
			@Test
			public void updateNode() {
			//创建客户端
			CuratorFramework client = ClientFactory.createSimple(ZK_ADDRESS);

			try {
			//启动客户端实例,连接服务器
			client.start();

			String data = "hello world";
			byte[] payload = data.getBytes("UTF-8");

			String zkPath = "/test/CRUD/node-1";
			client.setData().forPath(zkPath, payload);
			} catch (Exception e) {
			e.printStackTrace();
			} finally {
			CloseableUtils.closeQuietly(client);
			}
			}
			</syntaxhighlight>

			==== 异步更新 ====
			通过 SetDataBuilder 构造者实例的'''inBackground(AsyncCallback callback)'''方法，设置一个 AsyncCallback 回调实例：
			* 异步执行完成之后，SetDataBuilder 构造者实例会再执行 AsyncCallback 实例的“processResult(...)”方法中的回调逻辑，即可完成更新后的其他操作。
			<syntaxhighlight lang="Java" highlight="11,33">
			/**
			* 更新节点 - 异步模式
			*/
			@Test
			public void updateNodeAsync() {
			//创建客户端
			CuratorFramework client = ClientFactory.createSimple(ZK_ADDRESS);

			try {
			//异步更新完成，回调此实例
			AsyncCallback.StringCallback callback = new AsyncCallback.StringCallback() {
			//回调方法
			@Override
			public void processResult(int i, String s, Object o, String s1)
			{
			System.out.println(
			"i = " + i + " \| " +
			"s = " + s + " \| " +
			"o = " + o + " \| " +
			"s1 = " + s1
			);
			}
			};

			//启动客户端实例,连接服务器
			client.start();

			String data = "hello ,every body! ";
			byte[] payload = data.getBytes("UTF-8");
			String zkPath = "/test/CRUD/remoteNode-1";

			client.setData()
			.inBackground(callback) //设置回调实例
			.forPath(zkPath, payload);

			Thread.sleep(10000);
			} catch (Exception e) {
			e.printStackTrace();
			} finally {
			CloseableUtils.closeQuietly(client);
			}
			}
			</syntaxhighlight>

	=== 删除ZNode ===		=== 删除ZNode ===

Eijux：/* 读取ZNode */

2021-09-29T06:46:10Z

读取ZNode

@@ 第532行： / 第532行： @@
 === 读取ZNode ===
 === 更新ZNode ===
 === 删除ZNode ===

Eijux：/* 删除ZNode */

2021-09-28T16:57:44Z

删除ZNode

←上一版本		2021年9月29日 (三) 00:57的版本
第534行：		第534行：
	=== 更新ZNode ===		=== 更新ZNode ===
	=== 删除ZNode ===		=== 删除ZNode ===


			=== 总结 ===
			关于操作 ZNode 的方法一般通过'''链式调用'''完成：
			# 其方法返回“构造者实例”，操作不会立即执行；
			#*（如“CreateBuilder”、“ExistsBuilder”、“GetDataBuilder”、“GetChildrenBuilder”、“SetDataBuilder”、“DeleteBuilder”）
			# 在链式调用最末端调用“'''forPath（String znodePath）'''”方法执行实际的操作。


			“更新”和“删除”操作可以'''异步执行'''，通过对应“构造者示例”的“'''inBackground(AsyncCallback asyncCallback)'''”方法设置回调。

Eijux：/* 创建ZNode */

2021-09-28T16:48:44Z

创建ZNode

←上一版本		2021年9月29日 (三) 00:48的版本
第518行：		第518行：
	* 如上，CreateBuilder 构造者实例的“'''withMode()'''”方法，设置了节点的类型为“'''CreateMode.PERSISTENT'''”类型，表示节点的类型为持久化节点。		* 如上，CreateBuilder 构造者实例的“'''withMode()'''”方法，设置了节点的类型为“'''CreateMode.PERSISTENT'''”类型，表示节点的类型为持久化节点。

			==== 节点类型 ====
	ZooKeeper 节点有 4 种类型：		ZooKeeper 节点有 4 种类型：
	# '''PERSISTENT'''：持久化节点		# '''PERSISTENT'''：持久化节点

Zookeeper：Java API - 版本历史

Eijux：​/* Curator */

Eijux：​/* 创建Curator客户端 */

Eijux：​/* 环境准备 */

Eijux：​/* 异步删除 */

Eijux：​/* 异步更新 */

Eijux：​/* 删除ZNode */

Eijux：​/* 更新ZNode */

Eijux：​/* 读取ZNode */

Eijux：​/* 删除ZNode */

Eijux：​/* 创建ZNode */

Eijux：/* Curator */

Eijux：/* 创建Curator客户端 */

Eijux：/* 环境准备 */

Eijux：/* 异步删除 */

Eijux：/* 异步更新 */

Eijux：/* 删除ZNode */

Eijux：/* 更新ZNode */

Eijux：/* 读取ZNode */

Eijux：/* 删除ZNode */

Eijux：/* 创建ZNode */