前 言
作者简介：半旧518，长跑型选手，立志坚持写10年博客，专注于java后端
☕专栏简介：深入、全面、系统的介绍微服务常用技术栈zookeeper知识
文章简介：本文将深入、全面介绍使用zookeeper的客户端API远程操作zookeeper服务器新建节点，建议收藏备用，创作不易，敬请三连哦
文章推荐：
zookeeper入门到精通01——zookeeper入门
zookeeper入门到精通02——zookeeper的本地安装操作
zookeeper入门到精通03——zookeeper集群搭建
zookeeper入门到精通04——zookeeper集群选举与集群操作
Zookeeper入门到精通05——Zookeeper客户端命令行操作

一、环境准备

先启动zookeeper服务集群。

[wangzhou@zookeeper01 logs]$ zk.sh start

查看状态

[wangzhou@zookeeper01 logs]$ zk.sh status

结果如下就说明启动成功哦(ps:集群操作这里不会的童鞋可以看看该专栏前几篇博客哟~)。

二、创建工程

然后idea新建maven工程。

pom添加依赖

<dependencies><dependency><groupId>junit</groupId><artifactId>junit</artifactId><version>RELEASE</version></dependency><dependency><groupId>org.apache.logging.log4j</groupId><artifactId>log4j-core</artifactId><version>2.8.2</version></dependency><dependency><groupId>org.apache.zookeeper</groupId><artifactId>zookeeper</artifactId><version>3.5.7</version></dependency></dependencies>

在项目的 src/main/resources 目录下，新建一个文件，命名为“log4j.properties”，在文件中填入。

log4j.rootLogger=INFO, stdoutlog4j.appender.stdout=org.apache.log4j.ConsoleAppenderlog4j.appender.stdout.layout=org.apache.log4j.PatternLayoutlog4j.appender.stdout.layout.ConversionPattern=%d %p [%c]- %m%nlog4j.appender.logfile=org.apache.log4j.FileAppenderlog4j.appender.logfile.File=target/spring.loglog4j.appender.logfile.layout=org.apache.log4j.PatternLayoutlog4j.appender.logfile.layout.ConversionPattern=%d %p [%c]- %m%n

按如下目录结构建立ZKClient实例。

三、功能实现

写下demo案例。

public class ZKClient {ZooKeeper client;@Beforepublic void init() throws IOException {// 注意逗号后不要加空格，严格按照格式，在下面写自己对应得zookeeper服务集群得ip//端口号如不指定，默认未2181String connectString="192.168.106.43:2182,192.168.106.44:2182,192.168.106.45:2182";int sessionTimeout = 2000;client = new ZooKeeper(connectString, sessionTimeout, new Watcher() {@Overridepublic void process(WatchedEvent watchedEvent) {}});}@Testpublic void create() throws InterruptedException, KeeperException {//参数解释：// path:新建节点路径, data:zookeeper.avi, 控制方式：OPEN_ACL_UNSAFE，节点类型：PERSISTENTString nodeCreated = client.create("/wangzhou", "zookeeper.avi".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);}}

测试结果如下。

启动zookeeper客户端，确定节点数据是否成功插入。

[zk: localhost:2181(CONNECTED) 5] get -s /sanguo2zookeeper.avicZxid = 0xa0000000actime = Tue Jun 21 06:24:15 PDT 2022mZxid = 0xa0000000amtime = Tue Jun 21 06:24:15 PDT 2022pZxid = 0xa0000000acversion = 0dataVersion = 0aclVersion = 0ephemeralOwner = 0x0dataLength = 13numChildren = 0