Zookeeper .Net客戶端程式碼
阿新 • • 發佈:2019-02-14
通過C#程式碼使用zookeeper
Zookeeper的使用主要是通過建立其Nuget ZooKeeperNet包下的Zookeeper例項,並且呼叫其介面方法進行
的,主要的操作就是對znode的增刪改操作,監聽znode的變化以及處理。
Java程式碼- using System;
- using System.Collections.Generic;
- using System.Linq;
- using System.Text;
- using ZooKeeperNet;
- namespace ZookeeperDemo
- {
-
class Watcher : IWatcher
- {
- public void Process(WatchedEvent @event)
- {
- if (@event.Type == EventType.NodeDataChanged)
- {
- Console.WriteLine(@event.Path);
- }
- }
- }
- }
- using System;
- using System.Collections.Generic;
-
using System.Linq;
- using System.Text;
- using ZooKeeperNet;
- namespace ZookeeperDemo
- {
- class Program
- {
- static void Main(string[] args)
- {
- //建立一個Zookeeper例項,第一個引數為目標伺服器地址和埠,第二個引數為Session超時時間,第三個為節點變化時的回撥方法
-
using (ZooKeeper zk = new ZooKeeper("127.0.0.1:2181", new
- {
- var stat = zk.Exists("/root",true);
- ////建立一個節點root,資料是mydata,不進行ACL許可權控制,節點為永久性的(即客戶端shutdown了也不會消失)
- //zk.Create("/root", "mydata".GetBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.Persistent);
- //在root下面建立一個childone znode,資料為childone,不進行ACL許可權控制,節點為永久性的
- zk.Create("/root/childone", "childone".GetBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.Persistent);
- //取得/root節點下的子節點名稱,返回List<String>
- zk.GetChildren("/root", true);
- //取得/root/childone節點下的資料,返回byte[]
- zk.GetData("/root/childone", true, null);
- //修改節點/root/childone下的資料,第三個引數為版本,如果是-1,那會無視被修改的資料版本,直接改掉
- zk.SetData("/root/childone", "childonemodify".GetBytes(), -1);
- //刪除/root/childone這個節點,第二個引數為版本,-1的話直接刪除,無視版本
- zk.Delete("/root/childone", -1);
- }
- }
- }
- }