JAVA-1848: Moved apache-zookeeper to apache-libraries
This commit is contained in:
parent
d490b91c92
commit
689482831a
|
@ -1,7 +0,0 @@
|
||||||
## Apache Zookeeper
|
|
||||||
|
|
||||||
This module contains articles about Apache Zookeeper
|
|
||||||
|
|
||||||
### Relevant articles:
|
|
||||||
|
|
||||||
- [Getting Started with Java and Zookeeper](https://www.baeldung.com/java-zookeeper)
|
|
|
@ -1,31 +0,0 @@
|
||||||
<?xml version="1.0" encoding="UTF-8"?>
|
|
||||||
<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>
|
|
||||||
<artifactId>apache-zookeeper</artifactId>
|
|
||||||
<version>0.0.1-SNAPSHOT</version>
|
|
||||||
<name>apache-zookeeper</name>
|
|
||||||
<packaging>jar</packaging>
|
|
||||||
|
|
||||||
<parent>
|
|
||||||
<groupId>com.baeldung</groupId>
|
|
||||||
<artifactId>parent-modules</artifactId>
|
|
||||||
<version>1.0.0-SNAPSHOT</version>
|
|
||||||
</parent>
|
|
||||||
|
|
||||||
<dependencies>
|
|
||||||
<dependency>
|
|
||||||
<groupId>org.apache.zookeeper</groupId>
|
|
||||||
<artifactId>zookeeper</artifactId>
|
|
||||||
<version>${org.apache.zookeeper.version}</version>
|
|
||||||
</dependency>
|
|
||||||
</dependencies>
|
|
||||||
|
|
||||||
<properties>
|
|
||||||
<org.apache.zookeeper.version>3.4.11</org.apache.zookeeper.version>
|
|
||||||
</properties>
|
|
||||||
|
|
||||||
</project>
|
|
||||||
|
|
|
@ -1,33 +0,0 @@
|
||||||
package com.baeldung.zookeeper.connection;
|
|
||||||
|
|
||||||
import java.io.IOException;
|
|
||||||
import java.util.concurrent.CountDownLatch;
|
|
||||||
|
|
||||||
import org.apache.zookeeper.WatchedEvent;
|
|
||||||
import org.apache.zookeeper.Watcher;
|
|
||||||
import org.apache.zookeeper.Watcher.Event.KeeperState;
|
|
||||||
import org.apache.zookeeper.ZooKeeper;
|
|
||||||
|
|
||||||
public class ZKConnection {
|
|
||||||
private ZooKeeper zoo;
|
|
||||||
final CountDownLatch connectionLatch = new CountDownLatch(1);
|
|
||||||
|
|
||||||
public ZKConnection() {
|
|
||||||
}
|
|
||||||
|
|
||||||
public ZooKeeper connect(String host) throws IOException, InterruptedException {
|
|
||||||
zoo = new ZooKeeper(host, 2000, new Watcher() {
|
|
||||||
public void process(WatchedEvent we) {
|
|
||||||
if (we.getState() == KeeperState.SyncConnected) {
|
|
||||||
connectionLatch.countDown();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
});
|
|
||||||
connectionLatch.await();
|
|
||||||
return zoo;
|
|
||||||
}
|
|
||||||
|
|
||||||
public void close() throws InterruptedException {
|
|
||||||
zoo.close();
|
|
||||||
}
|
|
||||||
}
|
|
|
@ -1,35 +0,0 @@
|
||||||
package com.baeldung.zookeeper.manager;
|
|
||||||
|
|
||||||
import org.apache.zookeeper.KeeperException;
|
|
||||||
|
|
||||||
public interface ZKManager {
|
|
||||||
/**
|
|
||||||
* Create a Znode and save some data
|
|
||||||
*
|
|
||||||
* @param path
|
|
||||||
* @param data
|
|
||||||
* @throws KeeperException
|
|
||||||
* @throws InterruptedException
|
|
||||||
*/
|
|
||||||
public void create(String path, byte[] data) throws KeeperException, InterruptedException;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Get ZNode Data
|
|
||||||
*
|
|
||||||
* @param path
|
|
||||||
* @param boolean watchFlag
|
|
||||||
* @throws KeeperException
|
|
||||||
* @throws InterruptedException
|
|
||||||
*/
|
|
||||||
public Object getZNodeData(String path, boolean watchFlag);
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Update the ZNode Data
|
|
||||||
*
|
|
||||||
* @param path
|
|
||||||
* @param data
|
|
||||||
* @throws KeeperException
|
|
||||||
* @throws InterruptedException
|
|
||||||
*/
|
|
||||||
public void update(String path, byte[] data) throws KeeperException, InterruptedException, KeeperException;
|
|
||||||
}
|
|
|
@ -1,58 +0,0 @@
|
||||||
package com.baeldung.zookeeper.manager;
|
|
||||||
|
|
||||||
import org.apache.zookeeper.CreateMode;
|
|
||||||
import org.apache.zookeeper.KeeperException;
|
|
||||||
import org.apache.zookeeper.ZooDefs;
|
|
||||||
import org.apache.zookeeper.ZooKeeper;
|
|
||||||
|
|
||||||
import com.baeldung.zookeeper.connection.ZKConnection;
|
|
||||||
|
|
||||||
public class ZKManagerImpl implements ZKManager {
|
|
||||||
private static ZooKeeper zkeeper;
|
|
||||||
private static ZKConnection zkConnection;
|
|
||||||
|
|
||||||
public ZKManagerImpl() {
|
|
||||||
initialize();
|
|
||||||
}
|
|
||||||
|
|
||||||
/** * Initialize connection */
|
|
||||||
private void initialize() {
|
|
||||||
try {
|
|
||||||
zkConnection = new ZKConnection();
|
|
||||||
zkeeper = zkConnection.connect("localhost");
|
|
||||||
} catch (Exception e) {
|
|
||||||
System.out.println(e.getMessage());
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
public void closeConnection() {
|
|
||||||
try {
|
|
||||||
zkConnection.close();
|
|
||||||
} catch (InterruptedException e) {
|
|
||||||
System.out.println(e.getMessage());
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
public void create(String path, byte[] data) throws KeeperException, InterruptedException {
|
|
||||||
zkeeper.create(path, data, ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
|
|
||||||
}
|
|
||||||
|
|
||||||
public Object getZNodeData(String path, boolean watchFlag) {
|
|
||||||
try {
|
|
||||||
byte[] b = null;
|
|
||||||
b = zkeeper.getData(path, null, null);
|
|
||||||
String data = new String(b, "UTF-8");
|
|
||||||
System.out.println(data);
|
|
||||||
return data;
|
|
||||||
} catch (Exception e) {
|
|
||||||
System.out.println(e.getMessage());
|
|
||||||
}
|
|
||||||
return null;
|
|
||||||
}
|
|
||||||
|
|
||||||
public void update(String path, byte[] data) throws KeeperException, InterruptedException {
|
|
||||||
int version = zkeeper.exists(path, true)
|
|
||||||
.getVersion();
|
|
||||||
zkeeper.setData(path, data, version);
|
|
||||||
}
|
|
||||||
}
|
|
|
@ -1,13 +0,0 @@
|
||||||
<?xml version="1.0" encoding="UTF-8"?>
|
|
||||||
<configuration>
|
|
||||||
<appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender">
|
|
||||||
<encoder>
|
|
||||||
<pattern>%d{HH:mm:ss.SSS} [%thread] %-5level %logger{36} - %msg%n
|
|
||||||
</pattern>
|
|
||||||
</encoder>
|
|
||||||
</appender>
|
|
||||||
|
|
||||||
<root level="INFO">
|
|
||||||
<appender-ref ref="STDOUT" />
|
|
||||||
</root>
|
|
||||||
</configuration>
|
|
Loading…
Reference in New Issue