1. 程式人生 > >Zookeeper .Net客戶端程式碼

Zookeeper .Net客戶端程式碼

通過C#程式碼使用zookeeper

Zookeeper的使用主要是通過建立其Nuget ZooKeeperNet包下的Zookeeper例項,並且呼叫其介面方法進行

的,主要的操作就是對znode的增刪改操作,監聽znode的變化以及處理。

Java程式碼  收藏程式碼
  1. using System;  
  2. using System.Collections.Generic;  
  3. using System.Linq;  
  4. using System.Text;  
  5. using ZooKeeperNet;  
  6. namespace ZookeeperDemo  
  7. {  
  8.     class Watcher : IWatcher  
  9.     {  
  10.         public void Process(WatchedEvent @event)  
  11.         {  
  12.             if (@event.Type == EventType.NodeDataChanged)  
  13.             {  
  14.                 Console.WriteLine(@event.Path);  
  15.             }  
  16.         }  
  17.     }  
  18. }  
  19. using System;  
  20. using System.Collections.Generic;  
  21. using System.Linq;  
  22. using System.Text;  
  23. using ZooKeeperNet;  
  24. namespace ZookeeperDemo  
  25. {  
  26.     class Program  
  27.     {  
  28.         static void Main(string[] args)  
  29.         {  
  30.             //建立一個Zookeeper例項,第一個引數為目標伺服器地址和埠,第二個引數為Session超時時間,第三個為節點變化時的回撥方法   
  31.             using (ZooKeeper zk = new ZooKeeper("127.0.0.1:2181"new
     TimeSpan(00050000), new Watcher()))  
  32.             {  
  33.                 var stat = zk.Exists("/root",true);  
  34.                 ////建立一個節點root,資料是mydata,不進行ACL許可權控制,節點為永久性的(即客戶端shutdown了也不會消失)   
  35.                 //zk.Create("/root", "mydata".GetBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.Persistent);  
  36.                 //在root下面建立一個childone znode,資料為childone,不進行ACL許可權控制,節點為永久性的   
  37.                 zk.Create("/root/childone""childone".GetBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.Persistent);  
  38.                 //取得/root節點下的子節點名稱,返回List<String>   
  39.                 zk.GetChildren("/root"true);  
  40.                 //取得/root/childone節點下的資料,返回byte[]   
  41.                 zk.GetData("/root/childone"truenull);  
  42.                 //修改節點/root/childone下的資料,第三個引數為版本,如果是-1,那會無視被修改的資料版本,直接改掉  
  43.                 zk.SetData("/root/childone""childonemodify".GetBytes(), -1);  
  44.                 //刪除/root/childone這個節點,第二個引數為版本,-1的話直接刪除,無視版本   
  45.                 zk.Delete("/root/childone", -1);  
  46.             }  
  47.         }  
  48.     }  
  49. }