Zookeeper学习笔记2-------group创建、查询、删除

下面一段代码涉及到了 ZooKeeper 创建group、为group添加member、列出group下面的 member、递归删除group。

这里我引用的是 ZooKeeper 3.4.10 提供的jar包。

GroupHelper.java

import java.io.IOException;
import java.util.List;
import java.util.concurrent.CountDownLatch;import org.apache.zookeeper.CreateMode;
import org.apache.zookeeper.KeeperException;
import org.apache.zookeeper.WatchedEvent;
import org.apache.zookeeper.Watcher;
import org.apache.zookeeper.Watcher.Event.KeeperState;
import org.apache.zookeeper.ZooDefs.Ids;
import org.apache.zookeeper.ZooKeeper;public class GroupHelper implements Watcher {private static final int SESSION_TIMEOUT = 5000;private ZooKeeper zk;private CountDownLatch connectSignal = new CountDownLatch(1);private String groupName=null;/*** connect to zookeeper* @param host* @throws IOException* @throws InterruptedException*/public void connect(String host) throws IOException, InterruptedException {this.zk = new ZooKeeper(host, SESSION_TIMEOUT, this);connectSignal.await();}@Overridepublic void process(WatchedEvent event) {// TODO Auto-generated method stubif (event.getState() == KeeperState.SyncConnected) {connectSignal.countDown();}}/*** * @param groupName* @throws KeeperException* @throws InterruptedException*/public void create(String groupName) throws KeeperException, InterruptedException {this.groupName=groupName;String path="/".concat(groupName) ;String createPath=zk.create(path, null, Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);System.out.println("Create Path:"+createPath);}/*** @param memberName* @throws KeeperException* @throws InterruptedException*/public void joinMember(String memberName) throws KeeperException, InterruptedException {String path=String.format("/%s/%s", this.groupName,memberName);  path=zk.create(path, null, Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);  System.out.println("Path:"+path);} /*** * @param groupName* @throws InterruptedException * @throws KeeperException */public void listMember(String groupName) throws  InterruptedException {List<String> children;try {children = zk.getChildren(groupName, false);if(children.isEmpty()) {System.out.println("No Member in List......");System.exit(-1);}for(String child :children) {System.out.println(child);}} catch (KeeperException e) {// TODO Auto-generated catch blocke.printStackTrace();System.exit(-1);}}/*** * @param path* @throws KeeperException* @throws InterruptedException*/public void deleteMember(String path) throws KeeperException, InterruptedException {List<String> children = zk.getChildren(path, false);if(children.isEmpty()) {return ;}for(String child:children) {String tmpPath=path+"/"+child;List<String> tmpList=zk.getChildren(tmpPath, false);if(tmpList.isEmpty()) {zk.delete(tmpPath, -1);    }else {this.deleteMember(tmpPath);}}zk.delete(path, -1);}}

GroupTest.java

我们创建一个组a ,然后又在组a下面创建c、ds、b成员,然后又在/a/ds下创建ss成员 ,最后递归删除他。

import java.io.IOException;import org.apache.log4j.BasicConfigurator;
import org.apache.zookeeper.KeeperException;public class ZookeeperTest {static {BasicConfigurator.configure();}public static void main(String []argv) throws IOException, InterruptedException, KeeperException {GroupHelper cg=new GroupHelper();  cg.connect("127.0.0.1:2181");   cg.create("a");  cg.joinMember("b");cg.joinMember("c");cg.joinMember("ds");cg.joinMember("ds/ss");cg.listMember("/a");//递归删除cg.deleteMember("/a");}}

运行结果:

对 Zookeeper的组操作是非常简单的。

Zookeeper学习笔记2-------group创建、查询、删除相关推荐

JavaWeb-综合案例(用户信息)-学习笔记01【列表查询】
Java后端学习路线笔记汇总表[黑马程序员] JavaWeb-综合案例(用户信息)-学习笔记01[列表查询] JavaWeb-综合案例(用户信息)-学习笔记02[登录功能] JavaWeb-综合案 ...
Zookeeper学习笔记
Zookeeper学习笔记概念 Zookeeper工作机制特点数据结构应用场景统一命名服务统一配置管理统一集群管理软负载均衡 Zookeeper本地安装本地模式安装安装前准备配置 ...
学习笔记--存储过程的创建和调用
学习笔记–存储过程的创建和调用定义存储过程是一个预编译的SQL语句,优点是允许模块化的设计,就是说只需创建一次,以后在程序中就可以调用多次.如果某次操作需要执行多次SQL,使用存储过程比单纯SQL ...
JavaWeb-综合案例(用户信息)-学习笔记05【分页查询功能】
Java后端学习路线笔记汇总表[黑马程序员] JavaWeb-综合案例(用户信息)-学习笔记01[列表查询] JavaWeb-综合案例(用户信息)-学习笔记02[登录功能] JavaWeb-综合案 ...
三、MySQL子查询学习笔记（标量子查询、列子查询、行子查询、表子查询详解）
三.MySQL子查询学习笔记 7:子查询含义: 一条查询语句中又嵌套了另一条完整的select语句,其中被嵌套的select语句,称为子查询或内查询:在外面的查询语句,称为主查询或外查询分类: 一 ...
oracle 最大值及其_学习笔记:Oracle优化 SQL查询最大值最小值时的优化方法案例...
天萃荷净 select max(id),min(id) from table优化,分享开发DBA需求,在SQL语句查询最大值.最小值数据时的优化方式案例 1.查看数据库版本 SQL> selec ...
Linux学习笔记---使用BusyBox创建根文件系统(二)
目录向 rootfs 的"/lib "目录添加库文件向 rootfs 的usr/lib 目录添加库文件创建其他文件夹根文件系统初步测试向 rootfs 的"/l ...
mybatis学习笔记(12)-多对多查询
mybatis学习笔记12-多对多查询示例多对多查询总结 resultMap总结本文实现多对多查询,查询用户及用户购买商品信息. 示例查询主表是:用户表关联表:由于用户和商品没有直接关联,通 ...
IBatis.Net学习笔记六--再谈查询
在IBatis.Net学习笔记五--常用的查询方式中我提到了一些IBatis.Net中的查询,特别是配置文件的写法. 后来通过大家的讨论,特别是Anders Cui 的提醒,又发现了其他的多表查询的 ...
【opencv学习笔记八】创建TrackBar轨迹条
createTrackbar这个函数我们以后会经常用到,它创建一个可以调整数值的轨迹条,并将轨迹条附加到指定的窗口上,使用起来很方便.首先大家要记住,它往往会和一个回调函数配合起来使用.先看下他的函数 ...

Zookeeper学习笔记2-------group创建、查询、删除

Zookeeper学习笔记2-------group创建、查询、删除相关推荐

最新文章

热门文章