開源地址：https://github.com/stulzq/NZookeeper

從 NUGET 安裝：

dotnet add package NZookeeper 

NZookeeper 是 Zookeeper 客戶端庫 ZookeeperEx 的封裝，旨在簡化 ZookeeperEx 的使用。

目前還不支援事務操作，下個版本支援

快速入門

1.連線 Zookeeper

using var loggerFactory = LoggerFactory.Create(builder =>
            {
                builder
                    .AddFilter("Microsoft", LogLevel.Debug)
                    .AddFilter("System", LogLevel.Information)
                    .AddConsole();
            });
var logger = loggerFactory.CreateLogger<ZkConnection>();
//多個Zookeeper地址使用英文逗號分隔
var zk = new ZkConnection(new ZkConnectionOptions() { ConnectionString = "localhost:2181", SessionTimeout = 5000 }, logger);
await zk.ConnectAsync();
 

2.設定 Watch 事件

用於監聽節點變化和資料變化，節點變化包括：節點建立，節點刪除

zk.OnWatch += Zk_OnWatch;

private Task Zk_OnWatch(ZkWatchEventArgs args)
{
    Console.WriteLine($"OnWatch: Path {args.Path}, Type {args.EventType}, State {args.EventType}");
    return Task.CompletedTask;
}

3.節點操作

//建立節點
await zk.CreateNodeAsync("/mynode", "節點資料",
                    new List<Acl>() { new Acl(AclPerm.All, AclScheme.World, AclId.World()) }, NodeType.Ephemeral);
//獲取子節點
await zk.GetChildrenAsync("/mynode");
//刪除節點
await zk.DeleteNodeAsync("/mynode");
//檢查節點是否存在
await zk.NodeExistsAsync("/mynode")
 

4.資料

//更新節點資料
await zk.SetDataAsync("/mynode", "111");
//獲取節點資料
await zk.GetDataAsync("/mynode")

5.ACL

//獲取ACL
await zk.GetAclAsync("/mynode");
//設定ACL
await zk.SetAclAsync("/mynode",new List<Acl>() { new Acl(AclPerm.All, AclScheme.World, AclId.World()) })