Zookeeper：分布式事件监听 - 版本历史

Eijux：/* Watcher监听器 */

2021-09-30T11:02:57Z

Watcher监听器

←上一版本		2021年9月30日 (四) 19:02的版本
第150行：		第150行：
	WatcherEvent 传输实例和 Curator的 WatchedEvent 封装实例，在名称上基本上一样，只有一个字母之差，而且功能也是一样的，都表示的是同一个服务器端事件。		WatcherEvent 传输实例和 Curator的 WatchedEvent 封装实例，在名称上基本上一样，只有一个字母之差，而且功能也是一样的，都表示的是同一个服务器端事件。
	</pre>		</pre>

			=== watcher 原理 ===
			见：“'''[[Zookeeper：watcher 事件机制原理]]'''”

	== Cache机制监听 ==		== Cache机制监听 ==

Eijux：/* Watcher监听器 */

2021-09-30T10:58:20Z

Watcher监听器

←上一版本		2021年9月30日 (四) 18:58的版本
第23行：		第23行：
	== Watcher监听器 ==		== Watcher监听器 ==
	在 ZooKeeper 中，Watcher 监听器的使用过程：		在 ZooKeeper 中，Watcher 监听器的使用过程：
	# 定义一个 '''Watcher''' 接口的实例：使用 Watcher ~~接口的事件回调方法：“process（WatchedEvent event）”定义回调处理逻辑。如下：~~		# 定义一个 '''Watcher''' 接口的实例：使用 Watcher 接口的事件回调方法：“'''process(WatchedEvent event)'''”定义回调处理逻辑。如下：
	#: <syntaxhighlight lang="Java" highlight="">		#: <syntaxhighlight lang="Java" highlight="">
	//演示：定义一个监听器		//演示：定义一个监听器
第38行：		第38行：
	byte[] content = client.getData().usingWatcher(w).forPath(workerPath);		byte[] content = client.getData().usingWatcher(w).forPath(workerPath);
	</syntaxhighlight>		</syntaxhighlight>
	#* 可以分别通过 '''getData()'''、'''exists()'''、'''getChildren()''' ~~方法去设置监听器。~~		#* 可以分别通过 '''getData()'''、'''exists()'''、'''getChildren()''' 方法（对应的构造器“GetDataBuilder”、“GetChildrenBuilder”和“ExistsBuilder”实现了“Watchable<T>”接口）去设置监听器。
	# 一个 Watcher 监听器在向服务器端完成注册后，当服务器端的一些事件触发了这个 Watcher，就会向注册过的客户端会话发送一个事件通知来实现分布式的通知功能。		# 一个 Watcher 监听器在向服务器端完成注册后，当服务器端的一些事件触发了这个 Watcher，就会向注册过的客户端会话发送一个事件通知来实现分布式的通知功能。
	#* 在 Curator 客户端收到服务器端的通知后，会封装一个通知事件“'''WatchedEvent'''”的实例，再传递给监听器的“process(WatchedEvent e)”回调方法。		#* 在 Curator 客户端收到服务器端的通知后，会封装一个通知事件“'''WatchedEvent'''”的实例，再传递给监听器的“process(WatchedEvent e)”回调方法。
第123行：		第123行：


	'''Watchable<T>'''~~接口：定义了~~ usingWatcher(Watcher w) ~~用于为实现了此接口的构造者设置监视器。~~		'''Watchable<T>'''接口：定义了“'''usingWatcher(Watcher w)'''”用于为实现了此接口的构造者设置监视器。
	* 实现了 Watchable<T> 接口的构造者，如：'''GetDataBuilder'''、'''GetChildrenBuilder''' 和 '''ExistsBuilder'''。（分别对应了前一节所述三个方法）		* 实现了 Watchable<T> 接口的构造者，如：'''GetDataBuilder'''、'''GetChildrenBuilder''' 和 '''ExistsBuilder'''。（分别对应了前一节所述三个方法）
	* 在 Curator 中，Watchable<T> 接口的源代码如下：		* 在 Curator 中，Watchable<T> 接口的源代码如下：

Eijux：/* Cache机制监听 */

2021-09-30T10:36:57Z

Cache机制监听

←上一版本		2021年9月30日 (四) 18:36的版本
第152行：		第152行：

	== Cache机制监听 ==		== Cache机制监听 ==
	~~Watcher需要反复注册比较烦琐，所以，Curator~~ 引入了 Cache 来监听 ZooKeeper 服务器端的事件。Cache 机制对 ZooKeeper 事件监听进行了封装，能够自动处理反复注册监听。		Watcher需要反复注册比较烦琐，所以，'''Curator''' 引入了 Cache 来监听 ZooKeeper 服务器端的事件。Cache 机制对 ZooKeeper 事件监听进行了封装，能够自动处理反复注册监听。

Eijux：/* Tree Cache（TreeCache） */

2021-09-30T10:34:43Z

Tree Cache（TreeCache）

@@ 第551行： / 第551行： @@
 示例：
 <syntaxhighlight lang="Java" highlight="">
 /**
 * 客户端监听实践

Eijux：/* Path Cache（PathChildrenCache） */

2021-09-30T10:34:25Z

Path Cache（PathChildrenCache）

@@ 第387行： / 第387行： @@
 示例：
 <syntaxhighlight lang="Java" highlight="">
 /**
 * 客户端监听实践

Eijux：/* Node Cache（NodeCache） */

2021-09-30T10:34:06Z

Node Cache（NodeCache）

@@ 第232行： / 第232行： @@
 示例：
 <syntaxhighlight lang="Java" highlight="">
 /**
 * 客户端监听实践

Eijux：/* Node Cache（NodeCache） */

2021-09-30T10:15:57Z

Node Cache（NodeCache）

←上一版本		2021年9月30日 (四) 18:15的版本
第260行：		第260行：
	@Override		@Override
	public void nodeChanged() throws Exception {		public void nodeChanged() throws Exception {
	~~ChildDatachildData~~ = nodeCache.getCurrentData();		ChildData childData = nodeCache.getCurrentData();
	log.info("ZNode节点状态改变, path={}", childData.getPath());		log.info("ZNode节点状态改变, path={}", childData.getPath());
	log.info("ZNode节点状态改变, data={}", new String(childData.getData(), "Utf-8"));		log.info("ZNode节点状态改变, data={}", new String(childData.getData(), "Utf-8"));

Eijux：/* Cache机制监听 */

2021-09-30T10:14:32Z

Cache机制监听

←上一版本		2021年9月30日 (四) 18:14的版本
第160行：		第160行：
	# Tree Cache：'''树缓存'''是Path Cache的增强，不光能监听子节点，还能监听 ZNode 节点自身。		# Tree Cache：'''树缓存'''是Path Cache的增强，不光能监听子节点，还能监听 ZNode 节点自身。

	=== Node ~~Cache~~ ===
			<pre>
			TreeCacheEvent 的事件类型：
			“NODE_ADDED：对应于节点的增加。
			“NODE_UPDATED：对应于节点的修改。
			“NODE_REMOVED：对应于节点的删除。

			PathChildrenCacheEvent 的事件类型：
			“CHILD_ADDED”：对应于子节点的增加。
			“CHILD_UPDATED”：对应子于节点的修改。
			“CHILD_REMOVED”：对应子于节点的删除。
			</pre>


			=== Node Cache（NodeCache） ===
	----		----
	Node Cache，用于监控节点的增加，删除和更新。		Node Cache，用于监控节点的增加，删除和更新。
第184行：		第198行：
	@Override		@Override
	public void nodeChanged() throws Exception {		public void nodeChanged() throws Exception {
	~~ChildDatachildData~~ = nodeCache.getCurrentData();		ChildData childData = nodeCache.getCurrentData();

	log.info("ZNode节点状态改变, path={}", childData.getPath());		log.info("ZNode节点状态改变, path={}", childData.getPath());
第232行：		第246行：
	public void testNodeCache() {		public void testNodeCache() {
	//检查节点是否存在，没有则创建		//检查节点是否存在，没有则创建
	~~booleanisExist~~ = ZKclient.instance.isNodeExist(workerPath);		boolean isExist = ZKclient.instance.isNodeExist(workerPath);
	if (!isExist) {		if (!isExist) {
	ZKclient.instance.createNode(workerPath, null);		ZKclient.instance.createNode(workerPath, null);
第240行：		第254行：

	try {		try {
	//构造 NodeCache 缓存实例		// 构造 NodeCache 缓存实例
	NodeCache nodeCache = new NodeCache(client, workerPath, false);		NodeCache nodeCache = new NodeCache(client, workerPath, false);
	//构造 NodeCacheListener 监听实例		// 构造 NodeCacheListener 监听实例
	NodeCacheListener listener = new NodeCacheListener() {		NodeCacheListener listener = new NodeCacheListener() {
	@Override		@Override
第253行：		第267行：
	};		};

	//~~注册并启动节点的事件监听~~		// 注册节点的事件监听
	nodeCache.getListenable().addListener(listener);		nodeCache.getListenable().addListener(listener);
			// 启动节点监听
	nodeCache.start();		nodeCache.start();

第284行：		第299行：
	</syntaxhighlight>		</syntaxhighlight>

	=== ~~PathChildrenCache~~ ===		=== Path Cache（PathChildrenCache） ===
	----		----
	PathChildrenCache 子节点缓存用于子节点的监听，监控当前节点的子节点被创建、更新或者删除：		PathChildrenCache 子节点缓存用于子节点的监听，监控当前节点的子节点被创建、更新或者删除：
第346行：		第361行：
	}		}
	</syntaxhighlight>		</syntaxhighlight>
	# 将 PathChildrenCacheListener 实例注册到 PathChildrenCache ~~缓存实例，使用缓存实例的“addListener”方法：~~		# 将 PathChildrenCacheListener 实例注册到 PathChildrenCache 缓存实例，使用缓存实例的“addListener”方法；
	~~#: <syntaxhighlight lang="Java" highlight="">~~
	~~//启动节点的事件监听~~
	~~pathChildrenCacheListener.getListenable().addListener(listener);~~
	~~</syntaxhighlight>~~
	# 调用缓存实例 PathChildrenCache 的 “start” 方法，启动节点的事件监听；		# 调用缓存实例 PathChildrenCache 的 “start” 方法，启动节点的事件监听；
	#: <syntaxhighlight lang="Java" highlight="">		#: <syntaxhighlight lang="Java" highlight="">
第378行：		第389行：
	public void testPathChildrenCache() {		public void testPathChildrenCache() {
	//检查节点是否存在，没有则创建		//检查节点是否存在，没有则创建
	~~booleanisExist~~ = ZKclient.instance.isNodeExist(workerPath);		boolean isExist = ZKclient.instance.isNodeExist(workerPath);
	if (!isExist) {		if (!isExist) {
	ZKclient.instance.createNode(workerPath, null);		ZKclient.instance.createNode(workerPath, null);
第449行：		第460行：
	</syntaxhighlight>		</syntaxhighlight>

	=== Tree ~~Cache~~ ===		=== Tree Cache（TreeCache） ===
	----		----
	Tree Cache可以看作是 Node Cache 和 Path Cache 的合体。Tree Cache 不光能监听子节点，还能监听节点自身。		Tree Cache可以看作是 Node Cache 和 Path Cache 的合体。Tree Cache 不光能监听子节点，还能监听节点自身。

Eijux：/* Tree Cache */

2021-09-30T10:04:57Z

Tree Cache

显示更改

Eijux：/* PathChildrenCache */

2021-09-30T09:43:48Z

PathChildrenCache

←上一版本		2021年9月30日 (四) 17:43的版本
第321行：		第321行：
	switch (event.getType()) {		switch (event.getType()) {
	case CHILD_ADDED:		case CHILD_ADDED:
	log.info("子节点增加, path={}, data={}", data.getPath(),		log.info("子节点增加, path={}, data={}", data.getPath(), new String(data.getData(), "UTF-8"));
	new String(data.getData(), "UTF-8"));
	break;		break;
	case CHILD_UPDATED:		case CHILD_UPDATED:
	log.info("子节点更新, path={}, data={}", data.getPath(),		log.info("子节点更新, path={}, data={}", data.getPath(), new String(data.getData(), "UTF-8"));
	new String(data.getData(), "UTF-8"));
	break;		break;
	case CHILD_REMOVED:		case CHILD_REMOVED:
	log.info("子节点删除, path={}, data={}", data.getPath(),		log.info("子节点删除, path={}, data={}", data.getPath(), new String(data.getData(), "UTF-8"));
	new String(data.getData(), "UTF-8"));
	break;		break;
	default:		default:
第399行：		第396行：
	//子节点增加		//子节点增加
	case CHILD_ADDED:		case CHILD_ADDED:
	log.info("子节点增加, path={}, data={}",		log.info("子节点增加, path={}, data={}", data.getPath(), new String(data.getData(), "UTF-8"));
	data.getPath(),
	new String(data.getData(), "UTF-8"));
	break;		break;
	//子节点更新		//子节点更新
	case CHILD_UPDATED:		case CHILD_UPDATED:
	log.info("子节点更新, path={}, data={}",		log.info("子节点更新, path={}, data={}", data.getPath(), new String(data.getData(), "UTF-8"));
	data.getPath(),
	new String(data.getData(), "UTF-8"));
	break;		break;
	//子节点删除		//子节点删除
	case CHILD_REMOVED:		case CHILD_REMOVED:
	log.info("子节点删除, path={}, data={}",		log.info("子节点删除, path={}, data={}", data.getPath(), new String(data.getData(), "UTF-8"));
	data.getPath(),
	new String(data.getData(), "UTF-8"));
	break;		break;
	default:		default:
第446行：		第437行：
	}		}
	}		}
			</syntaxhighlight>
			结果：
			<syntaxhighlight lang="xml" highlight="">
			- 子节点增加, path=/test/listener/node/id-0, data=to set content
			- 子节点增加, path=/test/listener/node/id-2, data=to set content
			- 子节点增加, path=/test/listener/node/id-1, data=to set content
			......
			- 子节点删除, path=/test/listener/node/id-2, data=to set content
			- 子节点删除, path=/test/listener/node/id-0, data=to set content
			- 子节点删除, path=/test/listener/node/id-1, data=to set content
	</syntaxhighlight>		</syntaxhighlight>

	=== Tree Cache ===		=== Tree Cache ===

Zookeeper：分布式事件监听 - 版本历史

Eijux：​/* Watcher监听器 */

Eijux：​/* Watcher监听器 */

Eijux：​/* Cache机制监听 */

Eijux：​/* Tree Cache（TreeCache） */

Eijux：​/* Path Cache（PathChildrenCache） */

Eijux：​/* Node Cache（NodeCache） */

Eijux：​/* Node Cache（NodeCache） */

Eijux：​/* Cache机制监听 */

Eijux：​/* Tree Cache */

Eijux：​/* PathChildrenCache */

Eijux：/* Watcher监听器 */

Eijux：/* Watcher监听器 */

Eijux：/* Cache机制监听 */

Eijux：/* Tree Cache（TreeCache） */

Eijux：/* Path Cache（PathChildrenCache） */

Eijux：/* Node Cache（NodeCache） */

Eijux：/* Node Cache（NodeCache） */

Eijux：/* Cache机制监听 */

Eijux：/* Tree Cache */

Eijux：/* PathChildrenCache */