ZooKeeper 是一个分布式的、开源的协调服务,用于管理和协调大型分布式系统中的进程。它提供了以下主要功能和特性:
以下是一个简单的 Java 代码示例,展示了如何使用 ZooKeeper 客户端 API 连接到 ZooKeeper 服务器并创建一个节点:
import org.apache.zookeeper.CreateMode;
import org.apache.zookeeper.ZooDefs;
import org.apache.zookeeper.ZooKeeper;
import org.apache.zookeeper.data.ACL;
import org.apache.zookeeper.data.Id;
import org.apache.zookeeper.data.Stat;
import java.util.Collections;
import java.util.List;
public class ZooKeeperExample {
public static void main(String[] args) throws Exception {
// 连接到 ZooKeeper 服务器
String connectString = "localhost:2181";
int sessionTimeout = 3000;
ZooKeeper zk = new ZooKeeper(connectString, sessionTimeout, event -> {
System.out.println("ZooKeeper event: " + event);
});
// 创建一个节点
String path = "/example";
byte[] data = "Hello, ZooKeeper!".getBytes();
List<ACL> acls = Collections.singletonList(new ACL(ZooDefs.Perms.ALL, new Id("world", "anyone")));
String createdPath = zk.create(path, data, acls, CreateMode.PERSISTENT);
System.out.println("Created node: " + createdPath);
// 获取节点数据
Stat stat = new Stat();
byte[] retrievedData = zk.getData(path, false, stat);
System.out.println("Node data: " + new String(retrievedData));
// 关闭连接
zk.close();
}
}
原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。
如有侵权,请联系 cloudcommunity@tencent.com 删除。
原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。
如有侵权,请联系 cloudcommunity@tencent.com 删除。