Apache ZooKeeper provides a hierarchical namespace for coordinating distributed systems. When using Java, the ZkClient wrapper simplifies session management, recursive path operations, and cnotinuous watcher registration compared to the native low-level API.

Maven Dependencies

Include the core ZooKeeper library alongside the ZkClient abstraction in your project configuration:

<dependency>
    <groupId>org.apache.zookeeper</groupId>
    <artifactId>zookeeper</artifactId>
    <version>3.8.4</version>
</dependency>
<dependency>
    <groupId>com.101tec</groupId>
    <artifactId>zkclient</artifactId>
    <version>0.11</version>
</dependency>

Etsablishing a Connection

Initialize a client instance by providing the ensemble connection string. The wrapper automatically handles session timeouts and reconnection logic.

import org.I0Itec.zkclient.ZkClient;

public class ZooKeeperConnector {
    public static void main(String[] args) {
        String ensembleUrl = "zk-node-01.example.com:2181";
        ZkClient session = new ZkClient(ensembleUrl);
        System.out.println("Session initialized successfully.");
        session.close();
    }
}

Recursive Node Creation and Deletion

Standard ZooKeeper operations require parent paths to exist before creating children. The ZkClient library bypasses this limitation by supporting recursive creation. Similarly, entire branches can be removed in a single call.

import org.I0Itec.zkclient.ZkClient;

public class PathOperations {
    public static void main(String[] args) {
        ZkClient session = new ZkClient("zk-node-01.example.com:2181");
        String targetNode = "/system-config/modules/auth";

        // Recursively generate persistent directories
        session.createPersistent(targetNode, true);
        System.out.println("Hierarchy created: " + targetNode);

        // Cascade deletion through all child nodes
        session.deleteRecursive(targetNode);
        System.out.println("Branch removed completely.");

        session.close();
    }
}

Monitoring Child Node Changes

Native ZooKeeper watchers trigger only once. The ZkClient implementation automatically re-registers callbacks, enabling continuous observation of child additions or removals under a specified parent path. The listener focuses exclusively on immediate children, not the parent directory itself.

import org.I0Itec.zkclient.IZkChildListener;
import org.I0Itec.zkclient.ZkClient;
import java.util.List;
import java.util.concurrent.TimeUnit;

public class ChildNodeObserver {
    public static void main(String[] args) throws InterruptedException {
        ZkClient session = new ZkClient("zk-node-01.example.com:2181");
        String parentDir = "/system-config/modules";

        session.createPersistent(parentDir, true);

        session.subscribeChildChanges(parentDir, new IZkChildListener() {
            @Override
            public void handleChildChange(String watchedPath, List<String> activeChildren) {
                System.out.printf("Directory modified: %s | Current children: %s%n", watchedPath, activeChildren);
            }
        });

        // Trigger addition callback
        session.createPersistent(parentDir + "/service-alpha", true);
        TimeUnit.SECONDS.sleep(1);

        // Trigger removal callback
        session.deleteRecursive(parentDir + "/service-alpha");
        TimeUnit.SECONDS.sleep(1);

        session.close();
    }
}

Tracking Data Payload Modifications

To detect content updates or node deletion, attach a data listener. When storing complex Java objects, configure a serializer. String or byte array payloads function without explicit serialization configuration.

import org.I0Itec.zkclient.IZkDataListener;
import org.I0Itec.zkclient.ZkClient;
import org.I0Itec.zkclient.serialize.SerializableSerializer;
import java.util.concurrent.TimeUnit;

public class DataPayloadMonitor {
    public static void main(String[] args) throws InterruptedException {
        ZkClient session = new ZkClient("zk-node-01.example.com:2181");
        session.setZkSerializer(new SerializableSerializer());

        String nodePath = "/system-config/modules/service-alpha";
        if (!session.exists(nodePath)) {
            session.createPersistent(nodePath, true);
        }

        session.subscribeDataChanges(nodePath, new IZkDataListener() {
            @Override
            public void handleDataChange(String path, Object updatedPayload) {
                System.out.println("Content modified at " + path + " -> " + updatedPayload);
            }

            @Override
            public void handleDataDeleted(String path) {
                System.out.println("Node erased: " + path);
            }
        });

        // Fire update event
        session.writeData(nodePath, "status: initializing");
        TimeUnit.MILLISECONDS.sleep(800);
        session.writeData(nodePath, "status: active");
        TimeUnit.MILLISECONDS.sleep(800);

        // Fire deletion event
        session.deleteRecursive(nodePath);
        TimeUnit.MILLISECONDS.sleep(800);

        session.close();
    }
}