2021-03-26 03:41:58
Zookeeper入门教程(二):Zookeeper API 编程操作教程
教程索引目录请访问:《大数据技术入门级系列教程》
上一篇文章我们已经成功安装了 Zookeeper,虽然可以使用命令行操作 Zookeeper,但大部分时间还是通过编程调用操作 Zookeeper 的,所以本文就简单介绍一下入门级的基础操作。
本文全部代码公开在:https://github.com/renfei/demo/tree/master/zookeeper/zookeeper-zpi
基础条件
因为演示多个操作,Zookeeper 的客户端需要创建很多次,那为了偷懒,我们使用单元测试的 @Before 来为我们每次新建一个客户端:
public class ZookeeperApiDemo {
private static final String CONNECT_STRING = "localhost:2181";
private static final int SESSION_TIMEOUT = 2000;
private ZooKeeper zkClient = null;
@Before
public void init() throws Exception {
zkClient = new ZooKeeper(CONNECT_STRING, SESSION_TIMEOUT, event -> {
// 收到事件通知后的回调函数(用户的业务逻辑)
System.out.println(event.getType() + "--" + event.getPath());
// 再次启动监听
try {
zkClient.getChildren("/", true);
} catch (Exception e) {
e.printStackTrace();
}
});
}
}
基础增删查改
/**
* 创建子节点
*
* @throws Exception
*/
@Test
public void create() throws Exception {
// 参数:要创建的节点的路径; 参数2:节点数据 ; 参数3:节点权限 ;参数4:节点的类型
String nodeCreated = zkClient.create("/renfei", "demo".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
System.out.println(nodeCreated);
}
/**
* 放置数据
*
* @throws KeeperException
* @throws InterruptedException
*/
@Test
public void set() throws KeeperException, InterruptedException {
Stat stat = zkClient.setData("/renfei", "多大的".getBytes(), 0);
System.out.println(stat.toString());
}
/**
* 获取数据
*
* @throws KeeperException
* @throws InterruptedException
*/
@Test
public void get() throws KeeperException, InterruptedException {
Stat stat = new Stat();
byte[] dataBytes = zkClient.getData("/renfei", true, stat);
// 注意这个 Version 版本号,版本不对写入不进去
System.out.println(stat.getVersion());
System.out.println(new String(dataBytes));
}
/**
* 存在检测
*
* @throws KeeperException
* @throws InterruptedException
*/
@Test
public void exists() throws KeeperException, InterruptedException {
Stat stat = zkClient.exists("/renfei", false);
if (stat == null) {
System.out.println("节点不存在");
} else {
System.out.println(stat.getDataLength());
}
}
/**
* 删除数据
*
* @throws KeeperException
* @throws InterruptedException
*/
@Test
public void delete() throws KeeperException, InterruptedException {
Stat stat = zkClient.exists("/renfei", false);
if (stat != null) {
zkClient.delete("/renfei", stat.getVersion());
}
}
注册监听
Zookeeper 为我们提供了节点变化通知的机制,所以我们可以监听某个节点的变化,当数据发生改变时,Zookeeper 会通知我们最新的数据和状态。
因为监听是异步操作,这里需要两个线程,所以主线程需要让你睡眠等待,要不主线程退出子线程也就死了。
public void register() throws KeeperException, InterruptedException {
byte[] data = zkClient.getData("/renfei", watchedEvent -> {
try {
// 此处递归循环调用,一直监听变化
register();
} catch (KeeperException e) {
e.printStackTrace();
} catch (InterruptedException e) {
e.printStackTrace();
}
}, new Stat());
System.out.println(new String(data));
}
@Test
public void registerTest() throws InterruptedException {
try {
register();
} catch (KeeperException e) {
e.printStackTrace();
} catch (InterruptedException e) {
e.printStackTrace();
}
// 让主线程延时阻塞,为了可以查看register()的循环递归执行
Thread.sleep(Long.MAX_VALUE);
}
商业用途请联系作者获得授权。
版权声明:本文为博主「任霏」原创文章,遵循 CC BY-NC-SA 4.0 版权协议,转载请附上原文出处链接及本声明。
相关推荐
猜你还喜欢这些内容,不妨试试阅读一下评论与留言
以下内容均由网友提交发布,版权与真实性无法查证,请自行辨别。微信订阅号
扫码关注「任霏博客」微信订阅号内容标签
最新留言
- 你写得非常清晰明了,让我很容易理解你的观点。
- 感谢分享!拿走了~
- 您是说 UCClient 类接收来自Discuz的UCenter的消息吧,请求是来自 Discuz 的 UCenter吗?code 为 null 说明请求URL地址中没有 code 参数 (?code=xxx) ,确定是 UCenter 发起的请求吗?
- String code = request.getParameter("code"); code一直是null 这是为什么啊
- 你好,我想问一下如果是分析型的数据库要怎么制作docker镜像呢 是修改V008R003C002B0320版本号吗
- 可以的,我也正在开发分享的程序,可以邮件或群联系我都可以,关于页面里有联系方式:https://www.renfei.net/page/about 。
- 有破解软件的需要可以私下联系您吗?
- 您好,手机APP只是个客户端,用于数据呈现展示,数据均保存在服务器上,只留个APP没有任何用处,无能为力哦。
- 老哥 看你弄了这么多软件好厉害啊。 我有个软件 我买过几个小会员 没用几天 然后商家跑路了,软件服务器关闭了,连不上去 用不了。 你能做成一个打补丁版本可以本地用的么? 方便看下么?https://haodezhe.lanzouw.com/iD0f30h9joza 谢谢老哥!
- 您好,由于版权投诉和我国知识产权法的完善,我已经下架所有破解软件的下载链接了。
热文排行
- 生花妙笔信手来 – 基于 Amazon SageMaker 使用 Grounded-SAM 加速电商广告素材生成 [1]
- github.renfei.net 不再完整代理 Github 页面改为代理指定文件
- 优雅的源代码管理(三):本地优雅的使用 Git Rebase 变基
- 优雅的源代码管理(二):Git 的工作原理
- 优雅的源代码管理(一):版本控制系统 VCS(Version Control System)与软件配置管理 SCM(Software Configuration Management)
- ChatGPT 开发商 OpenAI 买下极品域名 AI.com
- 火爆的 AI 人工智能 ChatGPT 国内注册教程、使用方式和收费标准
- 解决 SpringCloud 中 bootstrap.yml 不识别 @activatedProperties@ 参数
- Cron表达式书写教程搞定Linux、Spring、Quartz的定时任务
- 阿里云香港可用区C发生史诗级故障