Zookeeper--客户端操作

客户端连接示例

Zookeeper类，是我们编程时最常用的类文件。这个类是Zookeeper客户端的主要类文件。如果要使用Zookeeper服务，应用程序首先必须创建一个Zookeeper实例，这时就需要使用此类。一旦客户端和Zookeeper服务建立起了连接，Zookeeper系统将会给次连接会话分配一个ID值，并且客户端将会周期性的向服务器端发送心跳来维持会话连接。只要连接有效，客户端就可以使用Zookeeper API来做相应处理了。
而客户端能进行的操作也就是服务中能进行的9中操作（参见Zookeeper–简介之Zookeeper节点的属性）
下面是一个简单的客户端连接，节点的创建等操作的示例：

public class ZooKeeperTest {public static final int SESSION_TIMEOUT = 30000;private ZooKeeper zk;private Watcher wh = new Watcher(){public void process(WatchedEvent event){System.out.println(event.toString());//如果连接诶成功，则输出其状态if(event.getState() == KeeperState.SyncConnected){System.out.println("客户端与zookeeper的连接会话创建成功"+event.getState());}}};//创建zookeeper客户端对象public void createZKInstance() throws IOException{zk = new ZooKeeper("192.168.57.130:2181,192.168.57.131:2181,192.168.57.132:2181",SESSION_TIMEOUT,wh);System.out.println("状态:"+zk.getState());}//使用客户端来对zookeeper操作public void zkOperations() throws KeeperException, InterruptedException{//创建一个节点System.out.println("创建javanode节点");zk.create("/javanode2", "sss".getBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);String data = new String(zk.getData("/javanode2", false, null));System.out.println(data);}public void list(String groupName) throws KeeperException, InterruptedException{try{List<String> children = zk.getChildren(groupName, false);if(children.isEmpty()){System.out.println("No members in group "+groupName);System.exit(1);}System.out.println("--------------");for(String child:children){System.out.println(child);}System.out.println("--------------");}catch(KeeperException.NoNodeException e){System.out.println("Group :"+groupName +" does not exist");System.exit(1);}}public void zkClose() throws InterruptedException{zk.close();System.out.println("客户端关闭");}public static void main(String[] args) throws IOException, KeeperException, InterruptedException{ZooKeeperTest zkt  = new ZooKeeperTest();zkt.createZKInstance();zkt.zkOperations();zkt.list("/");zkt.zkClose();}
}运行结果为：
状态:CONNECTING
创建javanode节点
WatchedEvent state:SyncConnected type:None path:null
客户端与zookeeper的连接会话创建成功SyncConnected
--
sss
--------------
javanode2
zookeeper
pomelo
hbase
--------------
客户端关闭

Watch触发器示例

对Watch触发器进行补充（关于watch详细，参见文章 Zookeeper–简介之Watch触发器）
下面是一个watch的简单示例：


public class SetDataSync implements Watcher{private static CountDownLatch connectedSemaphore = new CountDownLatch(1);private static ZooKeeper zk = null;private static Stat stat = new Stat();public void process(WatchedEvent event) {if(event.getState() == KeeperState.SyncConnected ){if(event.getType() == EventType.None && event.getPath() == null){connectedSemaphore.countDown();}else if(event.getType() == EventType.NodeDataChanged){try {System.out.println(new String(zk.getData(event.getPath(), true, stat)));System.out.println(stat.getCzxid()+","+stat.getMzxid()+","+stat.getVersion());} catch (KeeperException e) {e.printStackTrace();} catch (InterruptedException e) {e.printStackTrace();}}}}public static void main(String[] args) throws IOException, KeeperException, InterruptedException{String path = "/synctest";//创建zookeeper的客户端zk = new ZooKeeper("192.168.57.130:2181",30000,new SetDataSync());connectedSemaphore.await();System.out.println("----连接成功....");zk.create(path, "test".getBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL);System.out.println(new String(zk.getData(path, true, stat)));System.out.println(stat.getCzxid()+","+stat.getMzxid()+","+stat.getVersion());zk.setData(path, "up1".getBytes(), -1);Thread.sleep(Integer.MAX_VALUE);}}

Zookeeper--客户端操作相关推荐

【Java从0到架构师】Zookeeper 应用 - Java 客户端操作、服务器动态感知、分布式锁业务处理
分布式基石 Zookeeper 框架全面剖析 Java 客户端操作 Java 客户端 API 服务器的动态感知服务注册服务发现分布式锁业务处理单机环境(一个虚拟机中) 分布式环境_同名节点分 ...
zookeeper客户端库curator分析
zookeeper客户端库curator分析前言综述 zookeeper保证理解zookeeper的顺序一致性之前使用zookeeper客户端踩到的坑 curator 连接保证连接状态监控以 ...
Zookeeper客户端Curator使用详解
http://www.jianshu.com/p/70151fc0ef5d Zookeeper客户端Curator使用详解简介 Curator是Netflix公司开源的一套zookeeper客户端框 ...
zookeeper专题：使用zookeeper客户端实现动态监听节点并获取数据
文章目录 1. zookeeper原生客户端 2. Curator客户端 1. zookeeper原生客户端 zookeeper原生客户端就是zookeeper官方自带的客户端,作为代码与zk服务器交 ...
【转】ZooKeeper学习第二期--Zookeeper命令操作
一.Zookeeper的四字命令 Zookeeper支持某些特定的四字命令字母与其的交互.他们大多数是查询命令,用来获取Zookeeper服务的当前状态及相关信息.用户在客户端可以通过telnet或n ...
Zookeeper客户端Curator详解
一.Curator 客户端使用 Curator是 Netflix公司开源的一套ZooKeeper客户端框架,和 ZkClient一样它解决了非常底层的细节开发工作,包括连接.重连.反复注册Watche ...
Zookeeper 客户端之 Curator
之前写的一个在 Linux 上安装部署 Zookeeper 的笔记,其他操作系统请自行谷歌教程吧. 本文案例工程已经同步到了 github,传送门. PS : 目前还没有看过Curator的具体源码, ...
ZooKeeper客户端Curator的基本使用
前提:ZooKeeper版本:3.4.14 Curator版本:2.13.0 1.什么是Curator Curator是Netflix公司开源的一套zookeeper客户端框架,解决了很多Z ...
zookeeper客户端 curator的使用
curator简介 Curator是Netflix公司开源的一个Zookeeper客户端,与Zookeeper提供的原生客户端相比,Curator的抽象层次更高,提供了各种应用场景的实现封装,flue ...
【高级篇】详解Zookeeper客户端Curator
一.序言之前分享过一篇关于Curotor的基本应用[基础篇]详解Zookeeper客户端Curator,如果对Curator没有了解的可以看看,本文分享关于Curator的一些高级特性,在监听和le ...

Zookeeper--客户端操作

客户端连接示例

Watch触发器示例

Zookeeper--客户端操作相关推荐

最新文章

热门文章