pom.xml
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd" > <modelVersion>4.0.0</modelVersion> <groupId>com.kovansys.test</groupId> <version>1.1.0</version> <artifactId>zookeeper_test</artifactId> <packaging>jar</packaging> <properties> <maven.compiler.source>11</maven.compiler.source> <maven.compiler.target>11</maven.compiler.target> <spring.version>5.1.6.RELEASE</spring.version> <logback.version>1.2.3</logback.version> <slf4j.version>1.7.26</slf4j.version> <junit.version>5.4.1</junit.version> <java.encoding>UTF-8</java.encoding> <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> <zookeeper.version>3.4.14</zookeeper.version> </properties> <build> <directory>target</directory> <plugins> <plugin> <groupId>org.apache.maven.plugins</groupId> <artifactId>maven-compiler-plugin</artifactId> <version>3.8.0</version> </plugin> </plugins> </build> <dependencies> <dependency> <groupId>org.apache.zookeeper</groupId> <artifactId>zookeeper</artifactId> <version>${zookeeper.version}</version> <exclusions> <exclusion> <groupId>org.slf4j</groupId> <artifactId>slf4j-log4j12</artifactId> </exclusion> <exclusion> <groupId>log4j</groupId> <artifactId>log4j</artifactId> </exclusion> </exclusions> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-core</artifactId> <version>${spring.version}</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-context</artifactId> <version>${spring.version}</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-tx</artifactId> <version>${spring.version}</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-jdbc</artifactId> <version>${spring.version}</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-test</artifactId> <version>${spring.version}</version> </dependency> <dependency> <groupId>org.junit.jupiter</groupId> <artifactId>junit-jupiter-api</artifactId> <version>${junit.version}</version> <scope>test</scope> </dependency> <dependency> <groupId>org.junit.jupiter</groupId> <artifactId>junit-jupiter-engine</artifactId> <version>${junit.version}</version> <scope>test</scope> </dependency> <dependency> <groupId>org.slf4j</groupId> <artifactId>slf4j-api</artifactId> <version>${slf4j.version}</version> </dependency> <dependency> <groupId>ch.qos.logback</groupId> <artifactId>logback-core</artifactId> <version>${logback.version}</version> </dependency> <dependency> <groupId>ch.qos.logback</groupId> <artifactId>logback-classic</artifactId> <version>${logback.version}</version> </dependency> <dependency> <groupId>org.slf4j</groupId> <artifactId>jcl-over-slf4j</artifactId> <version>${slf4j.version}</version> </dependency> <dependency> <groupId>org.slf4j</groupId> <artifactId>log4j-over-slf4j</artifactId> <version>${slf4j.version}</version> </dependency> </dependencies> </project>
测试类
package zookeeper_test; import org.apache.zookeeper.CreateMode; import org.apache.zookeeper.WatchedEvent; import org.apache.zookeeper.Watcher; import org.apache.zookeeper.ZooDefs.Ids; import org.apache.zookeeper.ZooKeeper; import org.junit.jupiter.api.Test; public class ZookeeperTest { @Test public void testZookeeper() { int SESSION_TIMEOUT = 30 * 1000; Watcher wh = new Watcher() { public void process(WatchedEvent event) { System.out.println("WatchedEvent >>> " + event.toString()); } }; ZooKeeper zk = null; try { zk = new ZooKeeper("192.168.0.180:2181,192.168.0.180:2182,192.168.0.180:2183", SESSION_TIMEOUT, wh); // create node zk.create("/test", "My Data".getBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT); // get node data System.out.println("data of /test is:" + String.valueOf(new String(zk.getData("/test", false, null)))); // add watcher zk.exists("/test", wh); // update node zk.setData("/test", "Data updated".getBytes(), -1); // get node data System.out.println("data of /test is:" + String.valueOf(new String(zk.getData("/test", false, null)))); // add watcher zk.exists("/test", wh); // delete zk.delete("/test", -1); // if node exist System.out.println(" node /test exists: [" + (zk.exists("/test", false) != null) + "]"); } catch (Exception e) { e.printStackTrace(); } finally { if (zk != null) { try { zk.close(); } catch (Exception e) { e.printStackTrace(); } } } } }
相关推荐
zookeeper集群配置详解 详细描述在linux集群环境中搭建zookeeper的步骤
里面介绍了zookeeper的集群搭建和leader算法,是开课吧的资料,大家可以看下。
ZooKeeper集群的安装、配置 ZooKeeper集群的安装、配置
zookeeper linux 搭建流程,zookeeper linux 搭建流程zookeeper linux 搭建流程zookeeper linux 搭建流程。
zookeeper作为如今分布式应用下常用的开发技术,已经广泛应用于各种...该项目介绍了zookeeper的服务注册功能,使用了zookeeper集群环境搭建,可参考博客:https://blog.csdn.net/LiaoHongHB/article/details/84950486
java代码-使用java解决JEESZ-Zookeeper集群安装的源代码 ——学习参考资料:仅用于个人学习使用!
这个是我自己使用centerOS真实搭建的实践积累,文档包含了zookeeper伪集群和集群的搭建操作方法,还有截图和linux命令。这是实践积累,平常实操点内容并使用文档记录这些点滴,以免以后会忘记。
可以通过JPS指令,这个指令是查看当前活动的java进程。 对于zookeeper来说,如果有Quoroum……,就证明Zk服务是开启的 但该命令只能查看本机机器状态。
该项目通过zookeeper三个节点Node服务客户端代码,实现zookeeper集群管理与Master选举功能示例,项目结构如下图所示,其中依赖包包含:log4j-1.2.14.jar、slf4j-api-1.7.2.jar、slf4j-log4j12-1.7.2.jar、zookeeper-...
由于项目需要,编写基于zookeeper集群监测服务器宕机情况,并发邮件通知代码;实现很简单,编写了客户端和服务端,基于maven实现,代码方面修改zookeeper ip地址,需要部署的服务器名和邮件信息即可实现。直接打包...
windows环境下zookeeper集群搭建,分别点击zookeeper目录下的bin\zkServer.cmd;java测试节点,删除和查询节点;
内含dubbo+zookeeper的集群搭建的dome,以两个提供者一个使用者为例,zookeeper的版本为3.4.12,dubbo的版本为2.5.3,使用者请自行下载jar包
该代码是基于zookeeper应用场景:master选举下的代码;使用了zookeeper的集群模式,可参考博客:https://blog.csdn.net/LiaoHongHB/article/details/84951540
ZooKeeper安装配置 集群ZooKeeper安装配置 集群ZooKeeper安装配置 集群ZooKeeper安装配置 集群ZooKeeper安装配置 集群ZooKeeper安装配置 集群ZooKeeper安装配置 集群ZooKeeper安装配置 集群ZooKeeper安装配置 集群...
zookeeper 单机集群配置,下载后,只需配置zookeeper环境变量,即可使用
zookeeper 集群配置的相关配置信息,不同的文件夹相当于一台机器的配置,现在是伪集群,都在一台机器上的配置信息。
ZooKeeper服务器是用Java创建的,它运行在JVM之上。需要安装JDK 7或更高版本。zookeeper是一个分布式协调服务,接下来我会详细介绍大数据中一个重要集群zookeeper的详细安装步骤。
ZooKeeper集群。Zookeeper有三种运行模式:单机模式、伪集群模式和集群模式。单机模式这种模式一般适用于开发测试环境,一方面我们没有那么多机器资源,另外就是平时的开发调试并不需要极好的稳定性。在Linux环境下...
zookeeper集群需要奇数台机器,本示例使用3台机器,机器名称分别为server1、server2、server3。 本集群是centos6版本。 本示例是在已经安装完jdk8的环境中进行操作的,如果没有安装jdk,则需要提前安装jdk