SpringBoot集成Curator实现Zookeeper基本操作

本文主要是介绍SpringBoot集成Curator实现Zookeeper基本操作，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

系列文章目录

文章目录

系列文章目录
前言

前言

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

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

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

官网

https://curator.apache.org/releases.html#Current_Release

POM引入

<!--                      curator                      -->
<dependency><groupId>org.apache.curator</groupId><artifactId>curator-recipes</artifactId><version>5.2.0</version>
</dependency>
<!--                      fastjson                      -->
<dependency><groupId>com.alibaba</groupId><artifactId>fastjson</artifactId><version>1.2.79</version>
</dependency>

application.yml定义连接属性

server:port: 80
curator:connectString: 192.168.3.22:2181 # zookeeper 地址retryCount: 1 # 重试次数elapsedTimeMs: 2000 # 重试间隔时间sessionTimeoutMs: 60000 # session超时时间connectionTimeoutMs: 10000 # 连接超时时间

使用Springboot配置读取

package com.example.springboot.config;import lombok.Data;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.stereotype.Component;/*** @Auther: Java小强* @Date: 2022/2/4 - 19:37* @Decsription: com.example.springboot.config* @Version: 1.0*/
@Data
@Component
@ConfigurationProperties(prefix = "curator")
public class CuratorConf {private int retryCount;private int elapsedTimeMs;private String connectString;private int sessionTimeoutMs;private int connectionTimeoutMs;
}

公用连接创建对象

package com.example.springboot.tool;import com.example.springboot.config.CuratorConf;
import org.apache.curator.framework.CuratorFramework;
import org.apache.curator.framework.CuratorFrameworkFactory;
import org.apache.curator.retry.RetryNTimes;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;/*** @Auther: Java小强* @Date: 2022/2/4 - 19:37* @Decsription: com.example.springboot.tool* @Version: 1.0*/
@Configuration
public class ZkConfiguration {@Autowiredprivate CuratorConf curatorConf;/*** 这里会自动调用一次start，请勿重复调用*/@Bean(initMethod = "start")public CuratorFramework curatorFramework() {return CuratorFrameworkFactory.newClient(curatorConf.getConnectString(),curatorConf.getSessionTimeoutMs(),curatorConf.getConnectionTimeoutMs(),new RetryNTimes(curatorConf.getRetryCount(), curatorConf.getElapsedTimeMs()));}}

编写测试类，实现各种基础操作，并挨个测试

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.api.BackgroundCallback;
import org.apache.curator.framework.api.CuratorEvent;
import org.apache.zookeeper.data.Stat;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;import java.nio.charset.StandardCharsets;
import java.util.List;/*** @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 contextLoads() {CuratorFramework client= zk.curatorFramework();System.out.println(client.toString());}// 创建节点@Testvoid createPath() throws Exception{CuratorFramework client= zk.curatorFramework();// 父节点不存在则创建String path = client.create().creatingParentsIfNeeded().forPath("/javacui/p1" ,"Java小强博客".getBytes(StandardCharsets.UTF_8));System.out.println(path);byte[] data = client.getData().forPath("/javacui/p1");System.out.println(new String(data));}// 赋值，修改数据@Testvoid setData() throws Exception{CuratorFramework client = zk.curatorFramework();int version = 0; // 当前节点的版本信息Stat stat = new Stat();client.getData().storingStatIn(stat).forPath("/javacui/p1");version = stat.getVersion();// 如果版本信息不一致，说明当前数据被修改过，则修改失败程序报错client.setData().withVersion(version).forPath("/javacui/p1","Java崔的博客".getBytes(StandardCharsets.UTF_8));byte[] data = client.getData().forPath("/javacui/p1");System.out.println(new String(data));}// 查询节点@Testvoid getPath() throws Exception{CuratorFramework client= zk.curatorFramework();// 查内容byte[] data = client.getData().forPath("/javacui/p1");System.out.println(new String(data));// 查状态Stat stat = new Stat();client.getData().storingStatIn(stat).forPath("/javacui/p1");System.out.println(JSON.toJSONString(stat, true));}// 删除节点@Testvoid deletePath() throws Exception{CuratorFramework client= zk.curatorFramework();// deletingChildrenIfNeeded如果有子节点一并删除// guaranteed必须成功比如网络抖动时造成命令失败client.delete().guaranteed().deletingChildrenIfNeeded().inBackground(new BackgroundCallback() {@Overridepublic void processResult(CuratorFramework curatorFramework, CuratorEvent curatorEvent) throws Exception {System.out.println("删除成功");// { "path":"/javacui/p1","resultCode":0,"type":"DELETE"}System.out.println(JSON.toJSONString(curatorEvent, true));}}).forPath("/javacui/p1");}// 查询子节点@Testvoid getPaths() throws Exception{CuratorFramework client= zk.curatorFramework();List<String> paths = client.getChildren().forPath("/javacui");for(String p : paths){System.out.println(p);}}
}