SpringBoot集成Curator实现Watch事件监听-编程知识

SpringBoot集成Curator实现Watch事件监听

系列文章目录

文章目录

系列文章目录
前言

前言

前些天发现了一个巨牛的人工智能学习网站，通俗易懂，风趣幽默，忍不住分享一下给大家。点击跳转到网站，这篇文章男女通用，看懂了就去分享给你的码吧。
在这里插入图片描述

Zookeeper是一个Apache开源的分布式的应用，为系统架构提供协调服务。从设计模式角度来审视：该组件是一个基于观察者模式设计的框架，负责存储和管理数据，接受观察者的注册，一旦数据的状态发生变化，Zookeeper就将负责通知已经在Zookeeper上注册的观察者做出相应的反应，从而实现集群中类似Master/Slave管理模式。ZooKeeper的目标就是封装好复杂易出错的关键服务，将简单易用的接口和性能高效、功能稳定的系统提供给用户。
在这里插入图片描述
zookeeper安装单机模式

http://www.javacui.com/opensource/445.html

SpringBoot集成Curator实现Zookeeper基本操作

http://www.javacui.com/tool/615.html

看到别人写时，都是使用NodeCache和PathChildrenCache和TreeCache，实际使用时发现这三个类都是已经不再推荐使用，而是推荐CuratorCache

package com.example.springboot;import com.alibaba.fastjson.JSON;
import com.example.springboot.tool.ZkConfiguration;
import org.apache.curator.framework.CuratorFramework;
import org.apache.curator.framework.recipes.cache.*;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;/*** @Auther: Java小强* @Date: 2022/2/4 - 19:33* @Decsription: com.example.springboot* @Version: 1.0*/
@SpringBootTest(classes = Application.class)
public class CuratorTest {@Autowiredprivate ZkConfiguration zk;// 单节点监听@Testvoid nodeCache() throws Exception {CuratorFramework client = zk.curatorFramework();// 老版本是NodeCache和PathChildrenCache和TreeCache，新版CuratorCache是本节点和所有子节点CuratorCache nodecache = CuratorCache.build(client, "/javacui");// 启动时会把节点变化历史都传递过来nodecache.listenable().addListener(new CuratorCacheListener() {@Overridepublic void event(Type type, ChildData oldData, ChildData data) {System.out.println("节点发生变化");System.out.println(JSON.toJSONString(type));System.out.println(JSON.toJSONString(oldData));System.out.println(JSON.toJSONString(data));// "NODE_CHANGED"//{"data":"SmF2YeWwj+W8uuWNmuWuog==","path":"/javacui/p1","stat":{"aversion":0,"ctime":1643987130120,// "cversion":0,"czxid":63,"dataLength":16,"ephemeralOwner":0,"mtime":1643987143427,"mzxid":64,// "numChildren":0,"pzxid":63,"version":1}}//{"data":"SmF2YeW0lOeahOWNmuWuog==","path":"/javacui/p1","stat":{"aversion":0,"ctime":1643987130120,// "cversion":0,"czxid":63,"dataLength":16,"ephemeralOwner":0,"mtime":1643987265528,"mzxid":66,// "numChildren":0,"pzxid":63,"version":2}}}});nodecache.start();while (true) {// 模拟服务不关闭}}
}