Springboot整合zookeeper实现对节点的创建、监听与判断的案例详解

目录
  • Springboot整合zookeeper教程
  • 1.环境准备
  • 2.代码编写
    • 2.1.在pom.xml文件中增加zookeeper依赖(记得跟自己的zookeeper版本对应)
    • 2.2.API测试
  • 3.全部代码

Springboot整合zookeeper教程

1.环境准备

  • zookeeper集群环境
  • 一个简单的springboot项目环境

不懂如何搭建zookeeper集群的小伙伴可以移步到我的另一篇文章喔,里面有详细的zookeeper集群搭建教程~

zookeeper集群搭建步骤(超详细)

https://blog.csdn.net/weixin_47025166/article/details/125415538?spm=1001.2014.3001.5502

2.代码编写

2.1.在pom.xml文件中增加zookeeper依赖(记得跟自己的zookeeper版本对应)

除此之外,我们也引入junitlog4j方便我们后面的测试

   <!--引入对应的zookeeper -->
        <dependency>
            <groupId>org.apache.zookeeper</groupId>
            <artifactId>zookeeper</artifactId>
            <version>3.7.1</version>
        </dependency>

   <!--引入日志-->
        <dependency>
            <groupId>org.apache.logging.log4j</groupId>
            <artifactId>log4j-to-slf4j</artifactId>
            <version>2.17.2</version>
        </dependency>

   <!--引入junit测试-->
        <dependency>
            <groupId>junit</groupId>
            <artifactId>junit</artifactId>
            <version>RELEASE</version>
        </dependency>

2.2.API测试

我们创建zkClient类用于实现对zookeeper中节点的操作:

 1.客户端初始化

package com.canrioyuan.zookeepertest;

import org.apache.zookeeper.*;
import org.apache.zookeeper.data.Stat;
import org.junit.Before;
import org.junit.Test;

import java.io.IOException;
import java.util.List;

//创建对应的zookeeper客户端
public class ZkClient {

    //对应的zookeeper客户端连接,连接之间不能存在空格
    private String connectString = "192.168.154.133:2181,192.168.154.134:2181,192.168.154.135:2181";
    //即超时时间,我们设置成2s
    private int sessionTimeout = 2000;
    //声明zookeeper客户端
    private ZooKeeper zkClient;

    //初始化
    @Test
    public void init() throws IOException {
        zkClient = new ZooKeeper(connectString, sessionTimeout, new Watcher() {
            @Override
            public void process(WatchedEvent watchedEvent) {

            }
        });
    }

}

运行测试,成功后如会出现下图所示结果:

2.创建节点

    //创建节点
    @Test
    public void create() throws InterruptedException, KeeperException {
        //public String create(String path, byte[] data, List<ACL> acl, CreateMode createMode)
        //上图中从左到右的参数分别对应着:你所要创建的节点的名字,节点的值,节点的权限,节点的类型(持久有序,持久无序,临时有序,临时无序)
        zkClient.create("/class", "LiHua".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
    }

运行测试,你会发现,程序报了这样的错误;

 这是因为我们测试方法是互相独立的,此时运行测试,客户端处于未初始化的状态。因此,我们在客户端类的init方法中将@Test注解改成@Before注解,表示在每个测试执行之前都必须执行初始化方法。

  //初始化
    @Before
//    @Test
    public void init() throws IOException {
        zkClient = new ZooKeeper(connectString, sessionTimeout, new Watcher() {
            @Override
            public void process(WatchedEvent watchedEvent) {

            }
        });
    }

这时候我们再运行,会提示运行成功

 我们来到任意一台zookeeper客户端中查看节点,会发现已经创建成功

3.监听节点的状态

一次监听只能生效一次,而为了能够持续监听,我们对初始化方法再做出调整,保证每次初始化都有一次监听生效。

 @Before
    public void init() throws IOException {
        zkClient = new ZooKeeper(connectString, sessionTimeout, new Watcher() {
            @Override   //process中即为监听后做出的处理
            public void process(WatchedEvent watchedEvent) {
                List<String> children = null;
                try {
                    children = zkClient.getChildren("/", true);
                } catch (KeeperException e) {
                    e.printStackTrace();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                System.out.println("-------------------------");
                for (String child : children) {
                    System.out.println(child);
                }
                System.out.println("-------------------------");

            }
        });
    }

然后在监听节点代码中进行延时操作

 //监听节点
    @Test
    public void getChildren() throws InterruptedException, KeeperException {

        //正常一次监听只会生效一次,因此我们设置延时监听,确保能够持续监听节点的变化。
        Thread.sleep(Long.MAX_VALUE);
    }

此时我们可以看到控制台输出了zookeeper中的节点:

 我们进入zookeeper客户端对节点进行操作

增加一个节点school

 返回控制台,此时已经监听到了节点的变化: 

 我们再对school这个节点进行删除操作

此时控制台同样监听到了节点的变化:

 4.判断节点是否存在

 //判断节点是否存在
    @Test
    public void status() throws InterruptedException, KeeperException {
        Stat status = zkClient.exists("/class", false);
        System.out.println(status == null ? "no exist" : "exist");
    }

此时zookeeper中的节点;

测试结果:

3.全部代码

package com.canrioyuan.zookeepertest;

import org.apache.zookeeper.*;
import org.apache.zookeeper.data.Stat;
import org.junit.Before;
import org.junit.Test;

import java.io.IOException;
import java.util.List;

//创建对应的zookeeper客户端
public class ZkClient {

    //对应的zookeeper客户端连接,连接之间不能存在空格
    private String connectString = "192.168.154.133:2181,192.168.154.134:2181,192.168.154.135:2181";
    //即超时时间,我们设置成2s
    private int sessionTimeout = 2000;
    //声明zookeeper客户端
    private ZooKeeper zkClient;

    //初始化
//    @Test
    @Before
    public void init() throws IOException {
        zkClient = new ZooKeeper(connectString, sessionTimeout, new Watcher() {
            @Override   //process中即为监听后做出的处理
            public void process(WatchedEvent watchedEvent) {
                List<String> children = null;
                try {
                    children = zkClient.getChildren("/", true);
                } catch (KeeperException e) {
                    e.printStackTrace();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                System.out.println("-------------------------");
                for (String child : children) {
                    System.out.println(child);
                }
                System.out.println("-------------------------");

            }
        });
    }

    //创建节点
    @Test
    public void create() throws InterruptedException, KeeperException {
        //public String create(String path, byte[] data, List<ACL> acl, CreateMode createMode)
        //上图中从左到右的参数分别对应着:你所要创建的节点的名字,节点的值,节点的权限,节点的类型(持久有序,持久无序,临时有序,临时无序)
        zkClient.create("/class", "LiHua".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
    }

    //监听节点
    @Test
    public void getChildren() throws InterruptedException, KeeperException {

        //正常一次监听只会生效一次,因此我们设置延时监听,确保能够持续监听节点的变化。
        Thread.sleep(Long.MAX_VALUE);
    }

    //判断节点是否存在
    @Test
    public void status() throws InterruptedException, KeeperException {
        Stat status = zkClient.exists("/class", false);
        System.out.println(status == null ? "no exist" : "exist");
    }
}

至此,我们基于Springboot整合zookeeper实现对节点的创建、监听与判断教程就结束啦~

到此这篇关于基于Springboot整合zookeeper实现对节点的创建、监听与判断的文章就介绍到这了,更多相关Springboot整合zookeeper实现节点监听内容请搜索我们以前的文章或继续浏览下面的相关文章希望大家以后多多支持我们!

时间: 2022-06-23

2020最新IDEA SpringBoot整合Dubbo的实现(zookeeper版)

首先,要在电脑上安装配置好zookeeper哦~ 这是我云服务器上的zookeeper状态 接下来,开始整合 1. 准备一个dubbo-api的SpringBoot项目 用来存储Entity类和Server接口的项目,配置文件无须改动. entity – User // Lombok注解 相当于Setter Getter toString() @Data public class User implements Serializable { // 序列化很重要!!! private static

Springboot 整合 Dubbo/ZooKeeper 实现 SOA 案例解析

一.为啥整合 Dubbo 实现 SOA Dubbo 不单单只是高性能的 RPC 调用框架,更是 SOA 服务治理的一种方案. 核心: 远程通信,向本地调用一样调用远程方法. 集群容错 服务自动发现和注册,可平滑添加或者删除服务提供者. 我们常常使用 Springboot 暴露 HTTP 服务,并走 JSON 模式.但慢慢量大了,一种 SOA 的治理方案.这样可以暴露出 Dubbo 服务接口,提供给 Dubbo 消费者进行 RPC 调用.下面我们详解下如何集成 Dubbo. 二.运行 spring

SpringBoot整合Dubbo zookeeper过程解析

这篇文章主要介绍了SpringBoot整合Dubbo zookeeper过程解析,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下 docker pull zookeeper docker run --name zk01 -p 2181:2181 --restart always -d 2e30cac00aca 表明zookeeper已成功启动 Zookeeper和Dubbo• ZooKeeperZooKeeper 是一个分布式的,开放源码的分布式

IDEA整合Dubbo+Zookeeper+SpringBoot实现

本文主要介绍了IDEA整合Dubbo+Zookeeper+SpringBoot实现,分享给大家,具体如下: 放上一张Dubbo的架构图 刚刚学过SpringCloud,Dubbo虽然没有Spring家族那么强悍,但始终不能违背Dubbo是一款高性能优秀的RPC框架. click官网地址了解更多 自己也是初学者,想自己动手做一个简单的demo,于是上网查资料,发现针对那种入门的案例,网上主要有两个比较经典的,一个是尚硅谷雷神版,还有一个是官网推荐的入门 案例. 雷神的Dubbo视频教程大神讲解 视

zookeeper+Springboot实现服务器动态上下线监听教程详解

目录 zookeeper+Springboot实现服务器动态上下线监听教程 一.什么是服务器动态上下线监听 二.为什么要实现对服务器上下线的监听 三.编码实现 四.测试 1.启动客户端,开启监听 2.按照下面的流程启动服务器端 zookeeper+Springboot实现服务器动态上下线监听教程 一.什么是服务器动态上下线监听 客户端能够实时洞察到服务器上下线的变化,现在我们看看下面三个变化给集群.服务器.客户端三者的变化 初始情况 服务器3启动 服务器2下线 从上面的图我们可以知道,在集群中,

云服务器宝塔面板的安装图文教程详解

0x01.安装宝塔面板 宝塔面板是一个非常简单易用的服务器运维面板,可视化面板,减弱了新手在应对命令式操作Linux服务器时的恐惧感.在安装该面板后,不需要再在服务器上用命令行手动安装.配置Nginx 服务器这些必须的环境配置软件,只需要一键即可完成环境配置.软件安装,对新手以及想快速开发的人员特别友好! 系统要求(来自官方) 内存:512M以上,推荐768M以上(纯面板约占系统的60M内存) 硬盘:100M以上可用的硬盘空间(纯面板占约20M的磁盘空间) 系统:CentOS 7.1+(Ubun

vue watch普通监听和深度监听实例详解(数组和对象)

下面通过一段代码给大家介绍vue watch的普通监听和深度监听,具体代码如下所示: var vm=new Vue({ data:{ num:1, obj:{ name:'三儿', age:'21', sex:'女' } }, watch:{ num(val, oldVal){ //普通的watch监听 console.log("num: "+val, oldVal); }, obj:{ //深度监听,可监听到对象.数组的变化 handler(val, oldVal){ console

JS奇技之利用scroll来监听resize详解

前言 大家都知道知道原生的 resize 事件只能作用于 defaultView 即 window 上,那么我们应该通过什么样的方式来监听其他元素的大小改变呢?笔者最近学习发现了一种神奇的方法,通过 scroll 事件来间接实现 resize 事件的监听,本文将对这种方式进行原理的剖析与代码实现. 原理 首先,我们先来看一下 scroll 事件是干嘛的. The scroll event is fired when the document view or an element has been

微信小程序 实现拖拽事件监听实例详解

微信小程序 拖拽监听功能: 在软件开发或者 APP应用开发的时候,经常会遇到拖拽监听,最近自己学习微信小程序的知识,就想实现这样的拖拽效果,这里就记录下. 需要做个浮在scroll-view之上的button.尝试了一下. 上GIF: Android中也会有类似移动控件的操作.思路差不多.获取到位移的X Y 的变量,给控件设置坐标. 1.index.wxml ../images/gundong.png" bindtap="ballClickEvent" style="

Javascript添加监听与删除监听用法详解

本文实例讲述了Javascript添加监听与删除监听的用法.分享给大家供大家参考.具体分析如下: js中事件监听就是利用addEventListener来绑定一个事件,这个用法在jquery中非常常用并且简单,但在原生js中比较复杂,这里整理了addEventListener事件各方法的测试与例子供大家参考学习. 在前两天做播放器的时候添加监听后删除监听遇到了一点麻烦,删不掉,后来看了一下才发现,参数需要完全对应,什么叫完全对应呢,换句话说: 复制代码 代码如下: $('.video')[0].

vue v-on监听事件详解

在html或jsp页面中我们总能碰到监听DOM事件来触发javaScript代码,下面我们就简单聊聊Vue.js中的监听事件是怎么处理的. 在vue.js中监听事件是通过v-on指令来实现的,先看一下简单的监听事件代码. <!DOCTYPE html> <html> <head lang="en"> <meta charset="UTF-8"> <title></title> <scrip

微信小程序page的生命周期和音频播放及监听实例详解

一.界面的生命周期 /** * 监听页面加载, * 页面加载中 */ onLoad:function(){ var _this = this console.log('index---------onload()') /** * 监听音乐播放 */ wx.onBackgroundAudioPlay(function() { console.log('onBackgroundAudioPlay') }), /** * 监听音乐暂停 */ wx.onBackgroundAudioPause(func

Spring Boot应用事件监听示例详解

前言 本文主要给大家介绍了关于Spring Boot应用事件监听的相关内容,分享出来供大家参考学习,下面话不多说了,来一起看看详细的介绍吧 1. Spring Boot特有的应用事件 除了Spring框架的事件,Spring Boot的SpringApplication也发送了一些自己的事件: ApplicationStartingEvent:在任何处理(除了注册listener和initializer)开始之前发送. ApplicationEnvironmentPreparedEvent: 在

python hook监听事件详解

本文实例为大家分享了python hook监听事件的具体代码,供大家参考,具体内容如下 # -*- coding: utf-8 -*- # # by oldj http://oldj.net/ # import pythoncom import pyHook def onMouseEvent(event): # 监听鼠标事件 print "MessageName:",event.MessageName print "Message:", event.Message

在Debian(Raspberry Pi)树莓派上安装NodeJS的教程详解

在树莓派上运行NodeJS并不需要特别的配置,你只需要确保可以用openssh远程连接到你的树莓派. 安装并配置Open SSH服务器 它可以确保你能远程连接到树莓派,它应该已经被安装了,但是这个过程可以确保安装最新版和生成加密密钥. 如果Raspberry Pi运行在'headerlesss'模式.没有显示器,键盘或鼠标的情况下,就需要通过网线连接到树莓派. sudo apt-get install openssh-server sudo rm -rf /etc/ssh/ssh_host_*