环保局网站如何做备案证明,安康网站开发,俄罗斯乌克兰战争最新情况,凡科网站怎么设计2.15日学习打卡 目录: 2.15日学习打卡一. Zookeeper部署运行伪集群安装集群安装服务管理 二. Zookeeper系统模型数据模型节点特性客户端命令行节点数据信息Watcher监听机制权限控制 ACL 三. 原生api操作Zookeeper四. zkclient库操作Zookeeper五. Apache Curator操作Zookeeper六…2.15日学习打卡 目录: 2.15日学习打卡一. Zookeeper部署运行伪集群安装集群安装服务管理 二. Zookeeper系统模型数据模型节点特性客户端命令行节点数据信息Watcher监听机制权限控制 ACL 三. 原生api操作Zookeeper四. zkclient库操作Zookeeper五. Apache Curator操作Zookeeper六. Zookeeper高级四字命令选举机制 一. Zookeeper部署运行
伪集群安装 下载Zookeeper 选择第二个点击Download 下载最新版本即可 下载后将文件上传值虚拟机 可以使用xftp或者rz命令 将上传后的Zookeeper 解压后移动到 usr/local目录下 tar -zxvf apache-zookeeper-3.9.1-bin.tar.gz -C /usr/local 重命名文件夹 mv apache-zookeeper-3.9.1-bin zookeeper-3.9.1 修改配置文件 cd /usr/local/zookeeper/config mv zoo_sample.cfg zoo.cfg 修改zoo.cfg #The number of milliseconds of each tick tickTime2000initLimit10 syncLimit5 dataDir/usr/local/zookeeper/zkdata dataLogDir/usr/local/zookeeper/zklogs clientPort2181 创建数据持久化目录 mkdir /usr/local/zookeeper/zkdata mkdir /usr/local/zookeeper/zklogs 启动zookeeper服务(进入bin目录) ./zkServer.sh start 查看Zookeeper运行状态 zkServer.sh status jps 查看进程 可以通过./zkCli.sh来判断是否搭建成功 ./zkCli.sh 集群安装 环境准备(3个虚拟机) 192.168.66.100 192.168.66.110 192.168.66.120 解压zookeeper tar -zxvf apache-zookeeper-3.6.3.tar.gz -C /usr/local 修改配置文件 cd /usr/local/zookeeper/config mv zoo_sample.cfg zoo.cfg 修改zoo.cfg 添加 server.1192.168.66.101:2888:3888 server.2192.168.66.102:2888:3888 server.3192.168.66.103:2888:3888 创建数据持久化目录和日志目录
对3台节点都创建zkdata目录 。 mkdir /usr/local/zookeeper/zkdata mkdir /usr/local/zookeeper/zklogs 在工作目录中生成myid文件 第一台机器上 echo 1 /usr/local/zookeeper/zkdata/myid 第二台机器上 echo 2 /usr/local/zookeeper/zkdata/myid 第三台机器上 echo 3 /usr/local/zookeeper/zkdata/myid 启动zookeeper集群 zookeeper没有提供自动批量启动脚本需要手动一台一台地起zookeeper进程 在每一台节点上运行命令: bin/zkServer.sh start 注意 启动后用jps应该能看到一个进程QuorumPeerMain。光有进程不代表zk已经正常服务需要用命令检查状态bin/zkServer.sh status 能看到角色模式为leader或follower即正常了。 服务管理 脚本说明zkCleanup清理Zookeeper历史数据包括事务日志文件和快照数据文件zkCliZookeeper的简易客户端zkEnv设置Zookeeper的环境变量zkServer Zookeeper服务器的启动、停止和重启脚本
配置环境变量
修改文件 vim /etc/profile
export ZOOKEEPER_HOME/usr/local/zookeeper
export PATH$PATH:$JAVA_HOME/bin:$ZOOKEEPER_HOME/bin生效环境变量 source /etc/profile 启动服务 如何启动zookeeper服务。
语法结构 sh zkServer.sh start 停止服务 语法结构 sh zkServer.sh stop 查看zookeeper状态 语法结构 sh zkServer.sh status 设置一键启动/一键停止脚本 编写一键启停脚本 vim zkStart-all.sh
#验证传入的参数
if [ $# -ne 1 ];thenecho 无效参数用法为: $1
{start|stop|restart|status}exit
fi
#遍历所有节点
for host in 192.168.66.100 192.168.66.110
192.168.66.120
doecho $host 正在 $1 #发送命令给目标机器ssh $host source /etc/profile;
/usr/local/zookeeper/bin/zkServer.sh $1
done二. Zookeeper系统模型
数据模型 在Zookeeper中可以说 Zookeeper中的所有存储的数据是由znode组成的节点也称为 znode并以 key/value 形式存储数据
树 介绍 整体结构类似于 linux 文件系统的模式以树形结构存储。其中根路径以 / 开头 保存数据 注意 以 key/value 形式存储数据。key就是znode的节点路径比如 /java , /server。 节点特性 znode节点类型
ZooKeeper 节点是有生命周期的这取决于节点的类型。节点类型可以分为持久节点、临时节点以及时序节点具体在节点创建过程中一般是组合使用可以生成以下 4 种节点类型。 持久节点
持久节点是zookeeper中最常见的一种节点类型。所谓持久节点是指改数据节点被创建后就会一直存在与zookeeper服务器上直到有删除操作来主动清除这个节点。 示例
/java spring
/jjy zbjjy持久顺序节点
这类节点的基本特性和上面的节点类型是一致的。额外的特性是在ZK中每个父节点会为他的第一级子节点维护一份时序会记录每个子节点创建的先后顺序。 示例
/java00000000000001 spring
/jjy00000000000001 zbjjy临时节点 区别 和持久节点不同的是临时节点的生命周期和客户端会话绑定。也就是说如果客户端会话失效那么这个节点就会自动被清除掉。注意这里提到的是会话失效而非连接断开。另外在临时节点下面不能创建子节点。 临时顺序节点
临时顺序节点的基本特性和临时节点是一致的同样是在临时节点的基础上添加了顺序的特性。
示例:
/jjy0000000000000001 zbjjy
/jjy0000000000000002 zbjjy
/jjy0000000000000003 zbjjy客户端命令行 创建
创建ZK节点
语法结构
create [-s] [-e] path data acl参数 -s顺序节点 -e临时节点 默认情况下不添加-s或者-e参数的创建的是持久节点。 实例
[zk: localhost:2181(CONNECTED) 0]create /zk-book jjy读取
读取节点信息ls命令和set命令。
ls命令 语法结构
ls path [watch]实例
ls /注意 第一次部署的ZooKeeper集群默认在根节点“1”下面有一个叫作/zookeeper的保留节点。 get命令 使用get命令可以获取zookeeper指定节点的数据内容和属性信息。
语法格式
get path [watch]示例
get /zk-book更新
使用set命令可以更新指定节点的数据内容。
语法结构
set path data [version]示例
set /java springmvc参数 data就是要更新的新内容。注意set命令后面还有一个version参数在ZooKeeper 中节点的数据是有版本概念的这个参数用于指定本次更新操作是基于ZNode的哪一个数据版本进行的。 删除
删除zookeeper上的指定节点。
语法结构
delete path [version]示例
create /zk-book 123
create /zk-book/child 12345
delete /zk-book参数 如果节点包含子节点就报错。 节点数据信息 节点的状态结构
每个节点都有属于自己的状态信息这就很像每个人的身份信息一样。
语法结构
[zk: localhost:2181(CONNECTED) 15] stat /a
cZxid 0x300000014
ctime Thu Dec 30 15:05:07 CST 2021
mZxid 0x300000014
mtime Thu Dec 30 15:05:07 CST 2021
pZxid 0x300000015
cversion 1
dataVersion 0
aclVersion 0
ephemeralOwner 0x0
dataLength 1
numChildren 1查看节点类型
语法结构
create 参数 /java spring参数 -e临时节点 -s顺序节点 默认不写就是持久型节点 Watcher监听机制 ZooKeeper 提供了分布式数据的发布/订阅功能。一个典型的发布/订阅模型系统定义了一种一对多的订阅关系,能够让多个订阅者同时监听某一个主题对象当这个主题对象自身状态变化时会通知所有订阅者使它们能够做出相应的处理。 注意 在ZooKeeper中引入了Watcher机制来实现这种分布式的通知功能。ZooKeeper 允许客户端向服务端注册一个 Watcher 监听当服务端的一些指定事件触发了这个Watcher那么就会向指定客户端发送一个事件通知来实现分布式的通知功能。 监听机制
监听节点变化 语法结构:
ls -w path参数 命令如果使用watch,那么监听的是节点的变化而不是值的变化。 监听节点的值的变化 语法结构:
get -w path 参数 watch监听机制只能够使用一次如果下次想要使用必须重新监听就比如ls path watch命令只能监听节点路径的改变一次如果还想监听那么需要再执行一次ls path watch命令。 权限控制 ACL 在ZooKeeper的实际使用中我们的做法往往是搭建一个共用的ZooKeeper集群统一为若干个应用提供服务。在这种情况下不同的应用之间往往是不会存在共享数据的使用场景的因此需要解决不同应用之间的权限问题。
ACL 权限控制
权限模式Schema授权对象ID权限Permission) 参数 ZooKeeper的权限控制是基于每个znode节点的需要对每个节点设置权限每个znode支持设置多种权限控制方案和多个权限子节点不会继承父节点的权限客户端无权访问某节点但可能可以访问它的子节点 例子
setAcl /test2 ip:128.0.0.1:crwdaschema
ZooKeeper内置了一些权限控制方案可以用以下方案为每个节点设置权限
方案描述world只有一个用户anyone代表所有人默认ip使用IP地址认证auth使用已添加认证的用户认证digest使用“用户名:密码”方式认证 id
授权对象ID是指权限赋予的用户或者一个实体例如IP 地址或 者机器。授权模式 schema 与 授权对象 ID 之间关系
权限模式授权对象IP通常是一个IP地址或是IP段例如“192.168.66.101”Digest自定义通常是“username:BASE64(SHA-1(username:password))”World只有一个ID:“anyone”Super与Digest模式一致 权限permission
权限ACL简写描述CREATEc可以创建子节点DELETEd可以删除子节点仅下一级节点READr可以读取节点数据及显示子节点列表WRITEw可以设置节点数据ADMINa可以设置节点访问控制列表权限 权限相关命令
命令使用方式描述getAclgetAcl读取ACL权限setAclsetAcl设置ACL权限addauthaddauth添加认证用户
实战 World方案 语法格式
setAcl path world:anyone:acl客户端实例
[zk: localhost:2181(CONNECTED) 0] create /node1 1
Created /node1
[zk: localhost:2181(CONNECTED) 1] getAcl /node1 world,anyone #默认为world方案
: cdrwa #任何人都拥有所有权限IP方案
语法格式
setAcl path ip:ip:acl参数 可以是具体IP也可以是IP/bit格式即IP转换为二进制匹配前bit位如192.168.0.0/16匹配192.168… 客户端实例
#创建节点
[zk: localhost:2181(CONNECTED) 0] create /node2 1
Created /node2
#设置权限
[zk: localhost:2181(CONNECTED) 1] setAcl /node2 ip:192.168.66.110:cdrwa #设置IP192.168.66.110
拥有所有权限
cZxid 0x1900000239
#使用IP非 192.168.66.101 的机器
[zk: localhost:2181(CONNECTED) 0] get /node2
Authentication is not valid : /node2 #没有权限Auth方案 语法格式
setAcl path auth:user:acl添加认证用户
addauth digest user:password客户端实例
#创建节点
[zk: localhost:2181(CONNECTED) 0] create /node3
1
Created /node3
#添加认证用户
[zk: localhost:2181(CONNECTED) 1] addauth digest jjy:123456
#设置权限
[zk: localhost:2181(CONNECTED) 2] setAcl /node3 auth:yoonper:cdrwa
#获取权限
[zk: localhost:2181(CONNECTED) 3] getAcl /node3 digest,jjy:UvJWhBril5yzpEiA2eV7bwwhfLs: cdrwa刚才已经添加认证用户可以直接读取数据断开会话重连需要重新addauth添加认证用户
[zk: localhost:2181(CONNECTED) 3] get /node3Digest方案
语法格式
setAcl path digest:user:password:acl这里的密码是经过SHA1及BASE64处理的密文在SHELL中可以通 过以下命令计算
echo -n user:password | openssl dgst -binary -sha1 | openssl base64先来计算一个密文
echo -n baizhan:123456 | openssl dgst -binary -sha1 | openssl base64
UvJWhBril5yzpEiA2eV7bwwhfLs客户端实例
#创建节点
[zk: localhost:2181(CONNECTED) 0] create /node4 1
Created /node4
#使用是上面算好的密文密码添加权限
[zk: localhost:2181(CONNECTED) 1] setAcl /node4 digest:jjy:UvJWhBril5yzpEiA2eV7bwwhfLs:cdr
wa#获取节点数据没有权限
[zk: localhost:2181(CONNECTED) 3] get /node4
Authentication is not valid : /node4
#添加认证用户
[zk: localhost:2181(CONNECTED) 4] addauth digest jjy:123456
#成功读取数据
[zk: localhost:2181(CONNECTED) 5] get /node4
1三. 原生api操作Zookeeper 利用Zookeeper官方的原生java api进行连接然后演示一些创建、删除、修改、查询节点的操作。
引入依赖
dependenciesdependencygroupIdorg.apache.zookeeper/groupIdartifactIdzookeeper/artifactIdversion3.4.8/version/dependency
/dependencies
创建会话
package com.jjy;import org.apache.zookeeper.ZooKeeper;import java.io.IOException;public class ZkMain {public static void main(String[] args) throws IOException {/*** 创建一个 Zookeeper 的实例* 此处为一个集群Zookeeper 的 ip 之间用逗号隔开** 参数解释* param 1 - Zookeeper 的实例 ip 此处是一个集群所以配置了多个 ip用逗号隔开* param 2 - session 过期时间单位秒 (1000)* param 3 - 监视者用于获取监听事件 (MyWatch)*///创建一个会话ZooKeeper zooKeeper new ZooKeeper(192.168.66.100:2181,192.168.66.110:2181,192.168.66.120:2181, 4000, null);System.out.println(zooKeeper.getState());}
}
创建节点
private void createNodeSync() throws KeeperException, InterruptedException {String path /poype_node;/**znode名称*节点数据*设置权限*znode类型**/String nodePath zooKeeper.create(path, 123.getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);System.out.println(nodePath);
} znode 类型有四种 PERSISTENT - 持久化目录节点客户端与zookeeper断开连接后该节点依旧存在PERSISTENT_SEQUENTIAL - 持久化并带有序列号EPHEMERAL - 临时目录节点客户端与zookeeper断开连接后该节点被删除EPHEMERAL_SEQUENTIAL - 临时并带有序列号 删除节点 同步方式删除一个节点
private void deleteSync() throws KeeperException, InterruptedException {zooKeeper.delete(/node_1, 12);
}
读取数据
private void getDataSync() throws KeeperException, InterruptedException {Stat stat new Stat();// getData的返回值是该节点的数据值节点的状态信息会赋值给stat对象byte[] data zooKeeper.getData(/node_1,true, stat);System.out.println(new String(data));System.out.println(stat);
} 参数 znode 名称 (/zoo) 监视者用于获取监控事件 (MyWatch) Zookeeper 实例信息和数据信息 (stat) 更新数据
Stat stat zooKeeper.setData(/poype_node2, poype5211314.getBytes(), 1); 参数: param1znode名称 param2节点数据 param3该节点的版本 检测节点是否存在
private void existSync() throws KeeperException, InterruptedException {Stat stat zooKeeper.exists(/poype_node2, true);System.out.println(stat);
}参数 param1znode 名称 (/zoo) param2监视者用于获取监控事件 (MyWatch) 注册监听getChilren
通过zkCli.getchildren(“/”,new watch()){}来注册监听监听的是整个根节点,但是这个监听只能监听一次。线程休眠是为了让监听等待事件发生不然会随着程序直接运行完。
public class WatchDemo1 {static ListString children null;public static void main(String[] args) throws IOException, KeeperException, InterruptedException {ZooKeeper zkCli new ZooKeeper(192.168.50.183:2181,192.168.50.184:2181,192.168.50.185:2181, 3000, new Watcher() {//监听回调Overridepublic void process(WatchedEvent event) {System.out.println(正在监听中.....);}});//监听目录children zkCli.getChildren(/, new Watcher() {Overridepublic void process(WatchedEvent event) {System.out.println(监听路径为 event.getPath());System.out.println(监听的类型为 event.getType());System.out.println(数据被2货修改了);for(String c:children) {System.out.println(c);}}}); Thread.sleep(Long.MAX_VALUE);}
}注册监听getData
getData监听的为一个节点,同样只监听一次返回的是该节点的内容。
public class WatchDemo {public static void main(String[] args) throws IOException, KeeperException, InterruptedException {ZooKeeper zkCli new ZooKeeper(192.168.50.183:2181,192.168.50.184:2181,192.168.50.185:2181, 3000, new Watcher() {//监听回调Overridepublic void process(WatchedEvent event) {}});byte[] data zkCli.getData(/hunter, new Watcher() {//监听的具体内容Overridepublic void process(WatchedEvent event) {System.out.println(监听路径为 event.getPath());System.out.println(监听的类型为 event.getType());System.out.println(数据被2货修改了);}}, null);System.out.println(new String(data));Thread.sleep(Long.MAX_VALUE);}
}
测试
package com.jjy;import org.apache.zookeeper.CreateMode;
import org.apache.zookeeper.KeeperException;
import org.apache.zookeeper.ZooDefs;
import org.apache.zookeeper.ZooKeeper;
import org.apache.zookeeper.data.Stat;import java.io.IOException;
import java.util.List;public class ZkMain {public static void main(String[] args) throws IOException, InterruptedException, KeeperException {/*** 创建一个 Zookeeper 的实例* 此处为一个集群Zookeeper 的 ip 之间用逗号隔开** 参数解释* param 1 - Zookeeper 的实例 ip 此处是一个集群所以配置了多个 ip用逗号隔开* param 2 - session 过期时间单位秒 (1000)* param 3 - 监视者用于获取监听事件 (MyWatch)*///创建一个会话ZooKeeper zooKeeper new ZooKeeper(192.168.66.100:2181,192.168.66.110:2181,192.168.66.120:2181, 4000, null);System.out.println(zooKeeper.getState());/**znode名称*节点数据*设置权限*znode类型**/
// //创建结点
// String s zooKeeper.create(/node1, 1.getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
// System.out.println(s创建成功);//判断结点是否存在Stat exists zooKeeper.exists(/node1, null);System.out.println(exists);//删除结点//zooKeeper.delete(/node1, -1);//修改结点//zooKeeper.setData(/node1,jjy.getBytes(),-1);//获取结点的数据byte[] data zooKeeper.getData(/node1, null, null);System.out.println(new String(data));//获取节点ListString children zooKeeper.getChildren(/node1, null);for(String child : children){System.out.println(child);}}
}package com.jjy;import org.apache.zookeeper.KeeperException;
import org.apache.zookeeper.WatchedEvent;
import org.apache.zookeeper.Watcher;
import org.apache.zookeeper.ZooKeeper;import java.io.IOException;public class ZkWacher {public static void main(String[] args) throws IOException, InterruptedException, KeeperException {/*** 创建一个 Zookeeper 的实例* 此处为一个集群Zookeeper 的 ip 之间用逗号隔开** 参数解释* param 1 - Zookeeper 的实例 ip 此处是一个集群所以配置了多个 ip用逗号隔开* param 2 - session 过期时间单位秒 (1000)* param 3 - 监视者用于获取监听事件 (MyWatch)*///创建一个会话ZooKeeper zooKeeper new ZooKeeper(192.168.66.100:2181,192.168.66.110:2181,192.168.66.120:2181, 4000, new Watcher() {Overridepublic void process(WatchedEvent watchedEvent) {System.out.println(正在监听);}});
// //注册监听机制 监听节点
// zooKeeper.getChildren(/node1,new Watcher() {
//
// Override
// public void process(WatchedEvent watchedEvent) {
// //监听的路径
// System.out.println(watchedEvent.getPath());
// //监听类型
// System.out.println(watchedEvent.getType());
// System.out.println(节点被修改了);
// }
// });//监听数据zooKeeper.getData(/root,new Watcher() {Overridepublic void process(WatchedEvent event) {//监听的具体内容System.out.println(监听路径为 event.getPath());System.out.println(监听的类型为 event.getType());System.out.println(数据被2货修改了);}},null);Thread.sleep(Long.MAX_VALUE);}}
四. zkclient库操作Zookeeper 使用zookeeper遇到问题: 重复注册watcher session失效重连 异常处理删除节点不能有子节点新增节点必须有父节点等 zkclient是Github上一个开源的Zookeeper客户端在Zookeeper原生 API接口之上进行了包装是一个更加易用的Zookeeper客户端。同时Zkclient在内部实现了诸如Session超时重连Watcher反复注册等功能从而提高开发效率。
添加依赖
dependencygroupIdcom.101tec/groupIdartifactIdzkclient/artifactIdversion0.10/version
/dependency创建会话
String connStr 192.168.66.100:2181;
ZkClient zk new ZkClient(connStr);创建节点
String res zk.create(/root, jjy,
CreateMode.PERSISTENT);修改节点数据
zk.writeData(/root, zbjjy);获取节点数据
String res zk.readData(/root);删除节点
zk.delete(/root);注册数据监听 zk.subscribeDataChanges(/root/ghz, new IZkDataListener() {Overridepublic void handleDataDeleted(String arg0) throws Exception {System.err.println(数据删除: arg0);}Overridepublic void handleDataChange(String arg0, Object arg1) throws Exception {System.err.println(数据修改: arg0 ------ arg1);}});
注册节点监听
zk.subscribeChildChanges(/root, (arg0, arg1) - {System.err.println(子节点发生变化 arg0);arg1.forEach(f - {System.out.println(content f);});});测试
package com.jjy;import org.I0Itec.zkclient.IZkChildListener;
import org.I0Itec.zkclient.IZkDataListener;
import org.I0Itec.zkclient.ZkClient;
import org.apache.zookeeper.CreateMode;import java.util.List;public class ZkClientMain {public static void main(String[] args) throws InterruptedException {//创建会话ZkClient zk new ZkClient(192.168.66.100:2181,192.168.66.110:2181,192.168.66.120:2181);//获取子节点ListString children zk.getChildren(/node1);for (String child : children) {System.out.println(child);}//创建结点zk.create(/node2,2, CreateMode.PERSISTENT);System.out.println(创建节点成功);//修改结点数据zk.writeData(/node2,jjy);//获取数据String o zk.readData(/node2);System.out.println(o);//删除数据zk.delete(/node2);//注册节点监听事件zk.subscribeChildChanges(/node1, new IZkChildListener() {Overridepublic void handleChildChange(String s, ListString list) throws Exception {System.out.println(数据改变了);list.forEach(f-{System.out.println(f);});}});//注册结点数据zk.subscribeDataChanges(/node2, new IZkDataListener() {Overridepublic void handleDataChange(String s, Object o) throws Exception {System.out.println(数据改变了);}Overridepublic void handleDataDeleted(String s) throws Exception {System.out.println(数据删除了);}});Thread.sleep(Long.MAX_VALUE);}
}
五. Apache Curator操作Zookeeper Curator是 Netflix公司开源的一套ZooKeeper客户端框架。和ZkClient一样Curator解决了很多ZooKeeper客户端非常底层的细节开发工作包括连接重连、反复注册Watcher和NodeExistsException异常等目前已经成为了Apache的顶级项目,是全世界范围内使用最广泛的ZooKeeper客户端之一
Curator包
添加Maven依赖
dependencygroupIdorg.apache.curator/groupIdartifactIdcurator-recipes/artifactIdversion4.2.0/version
/dependency创建会话 String connStr 192.168.66.100:2181;CuratorFramework cur CuratorFrameworkFactory.builder().connectString(connStr).connectionTimeoutMs(5000).retryPolicy(new ExponentialBackoffRetry(1000,3)).build();cur.start();//连接
创建节点
cur.create().withMode(CreateMode.PERSISTENT).forPath(/root, jjy.getBytes());
删除数据节点
cur.delete().forPath(/root);注意 此方法只能删除叶子节点否则会抛出异常。 删除一个节点并且递归删除其所有的子节点
cur.delete().deletingChildrenIfNeeded().forPath(/root);删除一个节点强制指定版本进行删除
cur.delete().withVersion(10086).forPath(path);删除一个节点强制保证删除
cur.delete().guaranteed().forPath(path);注意: guaranteed()接口是一个保障措施只要客户端会话有效那么Curator会在后台持续进行删除操作直到删除节点成功。 注意上面的多个流式接口是可以自由组合的例如
cur.delete().guaranteed().deletingChildrenIfNeeded().withVersion(10086).forPath(/root);读取数据节点数据
读取一个节点的数据内容
cur.getData().forPath(/root);注意: 此方法返的返回值是byte[ ]; 读取一个节点的数据内容同时获取到该节点的stat
Stat stat new Stat();
client.getData().storingStatIn(stat).forPath(path);更新数据节点数据 更新一个节点的数据内容
client.setData().forPath(path,data.getBytes());注意 该接口会返回一个Stat实例; 更新一个节点的数据内容强制指定版本进行更新
client.setData().withVersion(10086).forPath(path,data.getBytes());检查节点是否存在
client.checkExists().forPath(path);注意 该方法返回一个Stat实例用于检查ZNode是否存在的操作. 可以调用额外的方法(监控或者后台处理)并在最后调用forPath()指定要操作的ZNode 获取某个节点的所有子节点路径
client.getChildren().forPath(path);测试
package com.jjy;import org.apache.curator.framework.CuratorFramework;
import org.apache.curator.framework.CuratorFrameworkFactory;
import org.apache.curator.framework.recipes.cache.NodeCache;
import org.apache.curator.retry.ExponentialBackoffRetry;
import org.apache.zookeeper.CreateMode;import java.util.List;public class CuratorMain {public static void main(String[] args) throws Exception {//创建会话String connStr 192.168.66.100:2181,192.168.66.110:2181,192.168.66.120:2181;CuratorFramework cur CuratorFrameworkFactory.builder().connectString(connStr).connectionTimeoutMs(5000).retryPolicy(new ExponentialBackoffRetry(1000,3)).build();//连接cur.start();//连接//创建节点cur.create().withMode(CreateMode.PERSISTENT).forPath(/node3,3.getBytes());//获取数据byte[] bytes cur.getData().forPath(/node3);System.out.println(new String(bytes));//删除结点cur.delete().forPath(/node3);//删除的结点有子节点cur.delete().deletingChildrenIfNeeded().forPath(/root);//修改结点cur.setData().forPath(/node3,jjy.getBytes());//获取某个结点的所有子节点ListString strings cur.getChildren().forPath(/node3);strings.forEach(f-{System.out.println(f);});//监听机制NodeCache nodeCache new NodeCache(cur, /node3);nodeCache.getListenable().addListener(()-{System.out.println(被修改了);});nodeCache.start();Thread.sleep(Long.MAX_VALUE);}
}
六. Zookeeper高级
四字命令 之前使用stat命令来验证ZooKeeper服务器是否启动成功这里的stat命令就是ZooKeeper 中最为典型的命令之一。ZooKeeper中有很多类似的命令它们的长度通常都是4个英文字母因此我们称之为“四字命令”。
添加配置 vim zoo.cfg
4lw.commands.whitelist*四字命令
conf
输出Zookeeper相关服务的详细配置信息如客户端端口数据存储路径、最大连接数、日志路径、数据同步端口、主节点推举端口、session超时时间等等。
语法结构
echo conf| nc localhost 2181注意: 注意conf命令输出的配置信息仅仅是输出一些最基本的配置参数。另外conf命令会根据当前的运行模式来决定输出的信息。如果是单机模式(standalone), 就不会输出诸如initLimit.syncLimit、electionAlg 和electionPort等集群相关的配置信息。 cons cons 命令用于输出当前这台服务器上所有客户端连接的详细信息包括每个客户端的客户端IP、会话ID和最后一次与服务器交互的操作类型等。
语法结构
echo cons | nc localhost 2181ruok
ruok命令用于输出当前ZooKeeper服务器是否正在运行。该命令的名字非常有趣其谐音正好是“Are you ok”。执行该命令后如果当前ZooKeeper服务器正在运行那么返回“imok” 否则没有任何响应输出。
语法结构
echo ruok | nc localhost 2181stat
stat命令用于获取ZooKeeper服务器的运行时状态信息,包括基本的ZooKeeper版本、打包信息、运行时角色、集群数据节点个数等信息另外还会将当前服务器的客户端连接信息打印出来。
语法结构
echo stat | nc localhost 2181注意 除了一些基本的状态信息外stat命令还会输出一些服务器的统计信息包括延迟情况、收到请求数和返回的响应数等。注意所有这些统计数据都可以通过srst命令进行重置。 mntr
列出集群的关键性能数据包括zk的版本、最大/平均/最小延迟数、数据包接收/发送量、连接数、zk角色Leader/Follower、node数量、watch数量、临时节点数。
语法结构
echo mntr | nc localhost 2181选举机制 核心选举原则 选举机制流程 选择机制中的概念
Serverid服务器ID
比如有三台服务器编号分别是1,2,3。 编号越大在选择算法中的权重越大。 Zxid数据ID 服务器中存放的最大数据ID. 值越大说明数据越新在选举算法中数据越新权重越大。 Epoch逻辑时钟
或者叫投票的次数同一轮投票过程中的逻辑时钟值是相同的。每 投完一次票这个数据就会增加然后与接收到的其它服务器返回的 投票信息中的数值相比根据不同的值做出不同的判断。
如果我的内容对你有帮助请点赞评论收藏。创作不易大家的支持就是我坚持下去的动力
