网站首页代码在哪里,wordpress 字段帅选,前端特效网站,找百度一、Zookeeper常用命令行 1.启动zookeeper客户端(在启动zookeeper集群后启动进行调试) zkCli.sh 2.查看帮助、操作历史 help、history 3.查看当前Znode的目录 ls / ls2 / (查看当前Znode的详细信息) 4.创建Znode (1)默认#xff1a;create 路径 内容 create /Wy…一、Zookeeper常用命令行 1.启动zookeeper客户端(在启动zookeeper集群后启动进行调试) zkCli.sh 2.查看帮助、操作历史 help、history 3.查看当前Znode的目录 ls / ls2 / (查看当前Znode的详细信息) 4.创建Znode (1)默认create 路径 内容 create /Wyh 18yearsold (2)创建短暂的Znode ephemeral create -e /dilireba beautiful (3)创建带序号的Znode sequential create -s /yangmi justsoso (4)创建短暂带序号的Znode create -e -s /wyh cool 5.查看Znode get /Wyh 6.修改Znode set /Wyh 7.删除Znode delete /Wyh rmr /Wyh 递归删除即删除该节点及该节点下所有子节点 8.监听节点 (1)监听节点的子节点即监听路径 ls / watch (2)监听节点的内容 get / watch 9.查看节点状态 stat /Wyh 二、Zookeeper常用API 1.准备工作zookeeper的依赖 可以解压其压缩包将lib目录下的依赖包导入到编译器 也可以使用mavenmaven配置 dependencygroupIdorg.apache.zookeeper/groupIdartifactIdzookeeper/artifactIdversion3.4.10/version/dependencydependencygroupIdjunit/groupIdartifactIdjunit/artifactIdversion4.12/versionscopecompile/scope/dependency2.常用方法讲解 1首先创建客户端类ZKClient 在类中定义全局变量连接字段connectString、连接超时sessionTimeout、客户端类比变量zkCli 2初始化客户端 定义初始化方法init,new一个zookeeper赋值给zkCli并设置它的变量connectString,sessionTimeout,new Watcher()置回调监听watcher 输出事件event的路径、状态、类型并用try/catch抛出异常 3创建节点方法 定义创建节点方法createZnode调用客户端create方法设置路径、编辑内容并转化为byte类型、应答类型、节点类型然后将路径赋值给字符串变量path 输出path 4获取子节点方法 定义方法getZnode调用客户端getChildren方法设置目标路径、是否监听把获取的子节点的名称赋值给字符串集合children使用 for循环遍历children集合 5删除节点方法 定义方法deleteZnode调用delete方法设置目标节点、版本值-1为删除然后可以遍历目标删除节点的父节点 6修改节点方法、并查看 定义方法setZnode调用setData方法设置目标节点并转化为byte类型、版本值-1调用getData方法设置查看节点、是否监听、状态new Stat()将得到的值赋值给字节集合data将data强转为string类型数据进行查看。 3.具体代码 /*** author: PrincessHug* date: 2019/2/25, 13:28* Blog: https://www.cnblogs.com/HelloBigTable/*/
public class ZKClient01 {private String connectString 192.168.126.128:2181,192.168.126.129:2181,192.168.126.130:2181;private int senssionTimeout 3000;private ZooKeeper zkCli null;/*** 初始化客户端* throws IOException*/Beforepublic void unit() throws IOException {zkCli new ZooKeeper(connectString, senssionTimeout, new Watcher() {public void process(WatchedEvent watchedEvent) {}});}/*** 创建节点* throws KeeperException* throws InterruptedException*/Testpublic void createZnode() throws KeeperException, InterruptedException {String path zkCli.create(/Wyh, cool.getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);System.out.println(path);}//获取节点Testpublic void getZone() throws KeeperException, InterruptedException {ListString children zkCli.getChildren(/, true);for (String c:children){System.out.println(c);}}//删除节点Testpublic void deleteZnode() throws KeeperException, InterruptedException {zkCli.delete(/baby,-1);getZone();}//修改节点Testpublic void setZnode() throws KeeperException, InterruptedException {zkCli.setData(/Wyh,reallycool.getBytes(),-1);byte[] data zkCli.getData(/Wyh, true, new Stat());System.out.println(new String(data));}} 转载于:https://www.cnblogs.com/HelloBigTable/p/10434153.html
