【自撰】zooKeeper 集成 Java代码

导入maven依赖

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

java代码

try {// 计数器对象CountDownLatch countDownLatch = new CountDownLatch(1);// ip地址, 超时时间ms ，监听器ZooKeeper zooKeeper = new ZooKeeper("192.168.17.113:2181", 5000, new Watcher() {@Overridepublic void process(WatchedEvent watchedEvent) {// 判断if (watchedEvent.getState() == Event.KeeperState.SyncConnected) {System.out.println("连接成功");// 计数器-1countDownLatch.countDown();}}});// 阻塞主进程countDownLatch.await();// 创建节点  /path ，数据的字节数组 ， ZooDefs.Ids.权限 , CreateMode.节点的类型// 持久化节点zooKeeper.create("/z1","zzz".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE,CreateMode.PERSISTENT);// 获取数据byte[] data = zooKeeper.getData("/z1", null, new Stat());System.out.println(new String(data));/*zooKeeper.create("/z2","zzz".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE,CreateMode.PERSISTENT_SEQUENTIAL);// 持有化有序节点zooKeeper.create("/z3","zzz".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE,CreateMode.EPHEMERAL);// 临时节点zooKeeper.create("/z4","zzz".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE,CreateMode.EPHEMERAL_SEQUENTIAL);// 有序临时节点*/// 关闭zookeeperzooKeeper.close();
} catch (IOException | InterruptedException | KeeperException e) {e.printStackTrace();
}

可以自行封装，提高性能

zooKeeper 集群

复制三份zookeeper的tar包解压，分别将文件夹重命名为

mv  apache -zookeeper-3.7.0-bin zookeeper2181
mv  apache -zookeeper-3.7.0-bin zookeeper2182
mv  apache -zookeeper-3.7.0-bin zookeeper2183

进入任意zookeeper文件夹
创建data文件夹进入data新建myid文件 sehll echo “1” > myid
进入conf文件夹复制

cp zoo_sample.cfg zoo.cfg

修改zoo.cfg文件

vi zoo.cfg

dataDir = (data文件夹的路径)
clientPort=(端口号)
最后在zoo.cfg末尾添加

其他文件重复以上操作即可

启动以上zookeeper ./zkServer.sh
查看启动的状态 ./zkServer.sh status

Mode: follower(从机)、leader(主机)
切换端口连接 ./zkCli.sh -server ip:端口

以上操作即可完成zookeeper集群

【自撰】zooKeeper 集成 Java代码相关推荐

局域网内共享文件可集成Java代码实现——FileZilla Server
局域网内共享文件可集成Java代码实现--FileZilla Server 1. 前言 Filezilla的主要优势在于:高安全.高性能.Filazilla的安全性是来自于其开放源代码的. Filez ...
java调用knime_Knime中集成Java代码
本文版权归作者所有,欢迎转载,但未经作者同意必须保留此段声明,且在文章页面明显位置给出原文连接,否则保留追究法律责任的权利. Knime是一个非常强大的数据分析平台,支持常用的各种数据清洗,分析等功能 ...
5.zookeeper集成Java项目curator客户端
创建了一个SpringBoot项目,引入pom依赖 <dependency><groupId>org.apache.curator& ...
jira集成开发代码_7种JIRA集成可优化您的Java开发流程
jira集成开发代码有哪些最佳集成可以用来优化JIRA工作流程? 我喜欢寻找在工作流程中提高效率的方法. 看着那些小小的自动化和流畅的流程,我的脸上露出了微笑. 我知道我并不孤单,有时花费更多的时间 ...
SonarQube 9.x集成阿里p3c代码规范检测java代码；
文章目录前言一.下载p3c-pmd插件二.sonarqube配置使用p3c规则检测 1.新建质量配置 2.将创建好的p3c检测规则设置为默认质量配置注1 注2 前言因为我们公司后端主用的是j ...
具有外部Zookeeper集成并使用SOLRJ API访问数据的SOLR cloud 7.4集群配置
SOLR是最流行且高度可扩展的搜索引擎之一,它基于分布式索引技术运行. Solr索引几乎可以基于任何类型的数据源(CSV数据或XML数据或从RDBMS数据库或标准文件系统中提取的数据)构建. 对于以R ...
Zookeeper的java实例
还是在之前的模块中写这个例子: 注意在pom.xml中加上Zookeeper的依赖, 现在开始写ZookeeperDemo.java import org.apache.log4j.Logger; i ...
spark streaming 接收 kafka 数据java代码WordCount示例
1. 首先启动zookeeper 2. 启动kafka 3. 核心代码生产者生产消息的java代码,生成要统计的单词 package streaming;import java.util.Prope ...
ZooKeeper Watch Java API浅析getChildren
2019独角兽企业重金招聘Python工程师标准>>> Watch是ZooKeeper中非常重要的一个机制,它可以监控ZooKeeper中节点的变化情况,告知客户端.下面,我们以代码 ...

【自撰】zooKeeper 集成 Java代码

zooKeeper 集群

【自撰】zooKeeper 集成 Java代码相关推荐

最新文章

热门文章