Zookeeper入门

概念

ZK命令操作

数据模型

服务端命令

./zkServer.sh start ./zkServer.sh stop ./zkServer.sh status ./zkServer.sh restart

客户端命令

./zkCli.sh-server127.0.0.1:2181#登录命令quit#退出命令ls/#查看根目录下子节点ls/dir1/dir2#查看指定目录下子节点create /test#创建test节点get /test#读取节点数据set/test hehe#设置节点数据delete /test#删除节点，若包含子节点则无法删除deleteall /test#删除子树create-e/test#创建临时节点，当前会话关闭时节点删除create-s/test#创建顺序节点create-es/test#创建临时顺序节点ls-s/test# 可以查看test节点的详细信息

Java API操作

Curator

//创建基本节点，带有数据，没有数据时则默认客户端ip为数据client.create().forPath("/app1","hello");//设置节点类型为临时节点，默认是持久化节点client.create().withMode(CreateMode.EPHEMEAL).forPath("/path");//创建多级节点client.create().creatingParentsIfNeed().forPath("/path");//查询节点，获取节点数据client.getData().forPath("/app1");//查询子节点，获取当前节点的子节点client.getChildren().forPath("/app1");//查询节点状态信息Statstat=newStat();client.getData().storingStatIn(stat).forPath("/app1");//修改节点数据client.setData().forPath("/app1","world");//根据版本信息修改数据法，防止多个客户端同时对数据进行操作，出现并发问题client.setData().withVersion(stat.getVersion()).forPath("/app2","hahha".getBytes());//删除带有子节点的节点client.delete().deletingChildrenIfNeed().forPath("/app3");//删除必须成功client.delete().guaranteed().forPath("/app4");//回调client.delete().inBackground(()->{}).forPath("/app5");

事件监听

监听特定节点

//注册NodeCache对象，监听单个节点finalNodeCachenodeCache=newNodeCache(client,"/app1");//注册监听nodeCache.getListenable().addListener(()->{//获取修改后节点的数据byte[]data=nodeCache.getCurrentData().getData();});//开启监听nodeCache.start(true);

监听子节点

//创建监听对象PathChildrenCachepathChildrenCache=newPathChildrenCache(client,"/app2",true);nodeCache.getListenable().addListener(()->{//监听子节点的变化，并且拿到变更后的数据PathChildrenCacheEvent.Typetype=event.getType();if(type.equals(PathChildrenCacheEvent.Type.CHILD_UPDATED)){byte[]data=event.getData().getData();}});pathChildrenCache.start();

监听子树

TreeCachetreeCache=newTreeCache(client,"/app3");treeCache.getListenable().addListener(()->{});treeCache.start();

分布式锁

ZK集群

Leader选举

这里先比较Zxid，再比较Serverid，并且在开始选举时，都会先投票给自己，然后广播投票内容，其他节点收到广播后再根据上述规则确定是否改变投票。

搭建集群

1.下载安装包，然后解压，创建data文件夹2.data文件夹下创建myid文件，并写入id(1,2,3,...)3.配置zoo.cfg文件，写入集群所有服务器ip:port，格式如下： server.1=127.0.0.1:2181#这里的1是写入myid里的id...4.配置zoo.cfg文件，配置dataDir为刚创建的data文件夹5.启动zk

ZK核心理论