Java API:介绍&创建节点|学习笔记

本文涉及的产品
云原生网关 MSE Higress,422元/月
注册配置 MSE Nacos/ZooKeeper,118元/月
任务调度 XXL-JOB 版免费试用,400 元额度,开发版规格
简介: 快速学习 Java API:介绍&创建节点

开发者学堂课程【大数据 ZooKeeper 快速入门 Java API:介绍&创建节点】学习笔记,与课程紧密联系,让用户快速学习知识。

课程地址:https://developer.aliyun.com/learning/course/549/detail/7570


Java API:介绍&创建节点


目录:

一、zookeeper 的 JavaAPI 介绍

二、JavaAPI 基本使用

 

课程概要:下面学习在 JavaAPI 中操作 zookeeper 集群

 

一.Zookeeper Java API

org.apache.zookeeper.Zookeeper

Zookeeper是在Java中客户端主类,负责建立与zookeeper集群的会话,并提供方法进行操作。在zookeeper类上提供了相应的方法,例如节点的创建、修改和删除等

org. apache.z.ookeeper.Watcher

Watcher 接口表示一个标准的事件处理器,其定义了事件通知相关的逻辑,包含KeeperState 和 EventType 两个枚举类,分别代表了通知状态和事件类型,同时定义了事件的回调方法: process (WatchedEvent event)。

process 方法是 Watcher 接口中的一个回调方法,当 ZooKeeper 向客户端发送一个 Watcher 事件通知时,客户端就会对相应的 process 方法进行回调,从而实现对事件的处理。

此逻辑即为 javaAPI 操作 zookeeper 类

 

二、基本使用

1. 建立 java maven 项目

引入 maven pom 坐标。

只需要把 zookeeper 引入,版本号与服务器保持一致

<dependency>

<groupId>org.apache.zookeeper</groupld>

<artifactId>zookeeper</artifactld>

<version>3.4.9K/version>

</ dependency>

2. 在 IDEA 中创建一个工程

(1)创建 maven 项目

(2)选择 maven 工程点击下一步,填写组织名和框架名称

(3)项目工程名称和存储路径

最终创建结果图:

image.png

在 pom.xml 中,把 zookeeper 依赖复制进入刷新即可

(4)Java 代码开发

在 main 方法中创建一个包,创建 TestZKClient.java

//创建 main 方法

public static void main(String[] args) throws Exception{

//注意导包:引入 org下的 zookeeper

//构造 JAVA 的 zookeeper 客户端

ZooKeeper zk = new ZooKeeper(

//连接信息:IP 和端口,毫秒超时事件,监听

//本地未配置 host 映射,此处应写 ip

"node-1:2181, node-2:2181, node-3:2181",30000,new Watcher()

) {

@Override

//此处为事件通知的回调方法,客户端在此处进行逻辑

public void process (WatchedEvent event){

System. out. println(”事件类型为:” + event.getState( ) ;

System. out. println(”事件类型为:” + event.getType( ) ;

System. out. println("事件发生的路径: “+ event. getPath);

}) ;

//创建一个节点

//在根目录下创建 myGirls,数据为性感的

zk.create("/myGirls,”性感的".getBytes("UTF-8"),ZooDefs.Ids.OPEN_ACL_UNSAFE,CreateMode.PERSISTENT)

Zk.close()

代码运行:没有zk方法创建节点的运行

image.png

此处打印三句话,第一个表示客户端与集群连接,客户端连接为 None

代码运行:

image.png

#在服务器上查看是否创建成功

[zk:localhost:2181(CONNECTED) 15] ls /

运行结果:

[myGrills00000000011,hellozk,watchtest]

#查看数据

[zk:localhost:2181(CONNECTED) 15] get /myGrills00000000011

运行结果:

性感的

czxid =0x200000051

ctime = Thu an o416:04:25 cST 2018

mzxid = 0x200000051

mtime = Thu an0416:04:25 cST 2018

pzxid = 0x200000051

cversion = 0

dataversion = 0

ac1version = 0

ephemera1owner = 0x0

dataLength = 9

numchi1dren = 0

相关实践学习
基于MSE实现微服务的全链路灰度
通过本场景的实验操作,您将了解并实现在线业务的微服务全链路灰度能力。
相关文章
|
12天前
|
数据采集 JSON Java
Java爬虫获取微店快递费用item_fee API接口数据实现
本文介绍如何使用Java开发爬虫程序,通过微店API接口获取商品快递费用(item_fee)数据。主要内容包括:微店API接口的使用方法、Java爬虫技术背景、需求分析和技术选型。具体实现步骤为:发送HTTP请求获取数据、解析JSON格式的响应并提取快递费用信息,最后将结果存储到本地文件中。文中还提供了完整的代码示例,并提醒开发者注意授权令牌、接口频率限制及数据合法性等问题。
|
12天前
|
数据采集 存储 Java
Java爬虫获取微店店铺所有商品API接口设计与实现
本文介绍如何使用Java设计并实现一个爬虫程序,以获取微店店铺的所有商品信息。通过HttpClient发送HTTP请求,Jsoup解析HTML页面,提取商品名称、价格、图片链接等数据,并将其存储到本地文件或数据库中。文中详细描述了爬虫的设计思路、代码实现及注意事项,包括反爬虫机制、数据合法性和性能优化。此方法可帮助商家了解竞争对手,为消费者提供更全面的商品比较。
|
7天前
|
数据采集 算法 Java
如何在Java爬虫中设置动态延迟以避免API限制
如何在Java爬虫中设置动态延迟以避免API限制
|
1月前
|
算法 Java 程序员
菜鸟之路Day06一一Java常用API
《菜鸟之路Day06——Java常用API》由blue编写,发布于2025年1月24日。本文详细介绍了Java中常用的API,包括JDK7的时间类(Date、SimpleDateFormat、Calendar)和JDK8新增的时间API(ZoneId、Instant、DateTimeFormatter等),以及包装类的使用。通过多个实例练习,如时间计算、字符串转整数、十进制转二进制等,帮助读者巩固所学内容,提升编程技能。文章强调了理论与实践结合的重要性,鼓励读者多做练习以提高学习效率。
80 28
|
16天前
|
缓存 Java 应用服务中间件
java语言后台管理若依框架-登录提示404-接口异常-系统接口404异常如何处理-登录验证码不显示prod-api/captchaImage 404 (Not Found) 如何处理-解决方案优雅草卓伊凡
java语言后台管理若依框架-登录提示404-接口异常-系统接口404异常如何处理-登录验证码不显示prod-api/captchaImage 404 (Not Found) 如何处理-解决方案优雅草卓伊凡
51 5
|
1月前
|
JSON Java 数据挖掘
利用 Java 代码获取淘宝关键字 API 接口
在数字化商业时代,精准把握市场动态与消费者需求是企业成功的关键。淘宝作为中国最大的电商平台之一,其海量数据中蕴含丰富的商业洞察。本文介绍如何通过Java代码高效、合规地获取淘宝关键字API接口数据,帮助商家优化产品布局、制定营销策略。主要内容包括: 1. **淘宝关键字API的价值**:洞察用户需求、优化产品标题与详情、制定营销策略。 2. **获取API接口的步骤**:注册账号、申请权限、搭建Java开发环境、编写调用代码、解析响应数据。 3. **注意事项**:遵守法律法规与平台规则,处理API调用限制。 通过这些步骤,商家可以在激烈的市场竞争中脱颖而出。
|
2月前
|
JSON Java Apache
Java基础-常用API-Object类
继承是面向对象编程的重要特性,允许从已有类派生新类。Java采用单继承机制,默认所有类继承自Object类。Object类提供了多个常用方法,如`clone()`用于复制对象,`equals()`判断对象是否相等,`hashCode()`计算哈希码,`toString()`返回对象的字符串表示,`wait()`、`notify()`和`notifyAll()`用于线程同步,`finalize()`在对象被垃圾回收时调用。掌握这些方法有助于更好地理解和使用Java中的对象行为。
|
2月前
|
算法 Java API
如何使用Java开发获得淘宝商品描述API接口?
本文详细介绍如何使用Java开发调用淘宝商品描述API接口,涵盖从注册淘宝开放平台账号、阅读平台规则、创建应用并申请接口权限,到安装开发工具、配置开发环境、获取访问令牌,以及具体的Java代码实现和注意事项。通过遵循这些步骤,开发者可以高效地获取商品详情、描述及图片等信息,为项目和业务增添价值。
124 10
|
2月前
|
存储 Java 数据挖掘
Java 8 新特性之 Stream API:函数式编程风格的数据处理范式
Java 8 引入的 Stream API 提供了一种新的数据处理方式,支持函数式编程风格,能够高效、简洁地处理集合数据,实现过滤、映射、聚合等操作。
110 6
|
2月前
|
Java API 开发者
Java中的Lambda表达式与Stream API的协同作用
在本文中,我们将探讨Java 8引入的Lambda表达式和Stream API如何改变我们处理集合和数组的方式。Lambda表达式提供了一种简洁的方法来表达代码块,而Stream API则允许我们对数据流进行高级操作,如过滤、映射和归约。通过结合使用这两种技术,我们可以以声明式的方式编写更简洁、更易于理解和维护的代码。本文将介绍Lambda表达式和Stream API的基本概念,并通过示例展示它们在实际项目中的应用。

热门文章

最新文章