Java小强个人技术博客站点    手机版
当前位置： 首页 >> 软件 >> SpringBoot集成Curator实现Watch事件监听

SpringBoot集成Curator实现Watch事件监听

32670 软件 | 2022-2-5

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 {
    @Autowired
    private ZkConfiguration zk;

    // 单节点监听
    @Test
    void nodeCache() throws Exception {
        CuratorFramework client = zk.curatorFramework();
        // 老版本是NodeCache和PathChildrenCache和TreeCache，新版CuratorCache是本节点和所有子节点
        CuratorCache nodecache = CuratorCache.build(client, "/javacui");
        // 启动时会把节点变化历史都传递过来
        nodecache.listenable().addListener(new CuratorCacheListener() {
            @Override
            public 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) {
            // 模拟服务不关闭
        }
    }
}


这样，本节点，子节点，所有节点的监听，都集成到了一个里面进行实现。

推荐您阅读更多有关于“ apache zookeeper springboot Curator watch ”的文章

上一篇：Curator分布式锁 下一篇：SpringBoot集成Curator实现Zookeeper基本操作

猜你喜欢

发表评论：