ZooKeeper入门（二）Java操作zookeeper

首先是pom依赖：

     <dependency><groupId>org.apache.zookeeper</groupId><artifactId>zookeeper</artifactId><version>3.4.6</version></dependency>

java操作zookeeper：

import java.io.IOException;
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.EventType;
import org.apache.zookeeper.Watcher.Event.KeeperState;
import org.apache.zookeeper.ZooDefs.Ids;
import org.apache.zookeeper.ZooKeeper;public class TestZookeeper {//连接地址private static final String ADDRES = "127.0.0.1:2181";//session 会话时间private static final int SESSION_OUTTIME = 2000;//信号量,阻塞程序执行,用户等待zookeeper连接成功,发送成功信号，private static final CountDownLatch countDownLatch = new CountDownLatch(1);public static void main(String[] args) throws IOException, InterruptedException, KeeperException {ZooKeeper zk = new ZooKeeper(ADDRES, SESSION_OUTTIME, new Watcher() {@Overridepublic void process(WatchedEvent event) {// 获取事件状态KeeperState keeperState = event.getState();// 获取事件类型EventType eventType = event.getType();if (KeeperState.SyncConnected == keeperState) {if (EventType.None == eventType) {//如果收到了服务端的响应事件，连接成功countDownLatch.countDown();System.out.println("keeperState:"+keeperState);System.out.println("eventType:"+eventType);System.out.println("zk 启动连接...");}};}});// 如果countDownLatch不为0，会一直进行阻塞countDownLatch.await();//参数一：节点名称；参数二：data数据.getBytes()意为将data变为字节数组；参数三：ids为节点权限；参数三：CreateMode为节点类型；String result = zk.create("/qushen001", "info".getBytes(), Ids.OPEN_ACL_UNSAFE,CreateMode.PERSISTENT);System.out.println(result);zk.close();}}

ZooKeeper入门（二）Java操作zookeeper相关推荐

kafka入门(4)-java操作kafka
kafka入门(4)-java操作kafka 准备工作创建maven工程导入Maven Kafka POM依赖 <repositories>< ...
ffmpeg入门及java操作ffmpeg对视频进行处理
一.ffmpeg 1.简介 FFmpeg是一个开源免费跨平台的视频和音频流方案,属于自由软件,采用LGPL或GPL许可证(依据你选择的组件).它提供了录制.转换以及流化音视频的完整解决方案.它包含了非 ...
2021年大数据ZooKeeper（二）：ZooKeeper集群搭建
目录 ZooKeeper集群搭建第一步:下载zookeeeper的压缩包,下载网址如下第二步:解压第三步:修改配置文件第四步:添加myid配置第五步:安装包分发并修改myid的 ...
ZooKeeper入门（三）zookeeper的Watcher机制
process方法是Watcher接口中的一个回调方法,当ZooKeeper向客户端发送一个Watcher事件通知时,客户端就会对相应的process方法进行回调,从而实现对事件的处理. import ...
redis入门及java操作
redis 命令可以去菜鸟教程http://www.runoob.com/redis/redis-tutorial.html 或者以下地址去学习http://www.cnblogs.com/huang ...
zookeeper和k8s_学习 ZooKeeper（二）： ZooKeeper on Kubernetes
更新至 ZooKeeper 3.5.6 版本资源定义配置日志文件 log4j.properties.ZooKeeper 配置文件模板 zoo.cfg.jinja2 和 ZooKeeper ID ...
ZooKeeper(二) idea中使用Java操作zookeeper
本章介绍使在idea环境中使用maven工程进行连接zookeeper,并进行简单的增删查改操作. 一.使用的pom依赖添加zookeeper依赖,以及进行测试的junit测试依赖. <?xm ...
elasticSearch入门到java操作api一套搞定
目录写在前面一.下载地址二.solr与es比较三.安装elasticsearch 四.安装可视化界面(hand插件) 使用五.安装kibana 六.学习es核心概念七.IK分词器插件八. ...
SQLite(二): Java操作SQLite
1.SQLiteJDBC SQLite JDBC Driver 可以在这个网站下载https://bitbucket.org/xerial/sqlite-jdbc/overview,当前稳定版本sql ...

ZooKeeper入门（二）Java操作zookeeper

ZooKeeper入门（二）Java操作zookeeper相关推荐

最新文章

热门文章