Zookeeper .Net客戶端代碼
本來此客戶端可以通過NuGet獲取,如果會使用NuGet, 則可以使用命令Install-Package ZooKeeperNet(需要最新版本的NuGet)
如果不會,就去 NuGet官網了解http://docs.nuget.org/docs/start-here/using-the-package-manager-console
如果你想自己編譯 你可以去GitHub下載源碼https://github.com/ewhauser/zookeeper
donet編譯時會報出Genrated裏的文件無法打開,實際上剛開始是沒有的;
最後在網上查了很多資料和源碼裏的說明文檔
ewhauser-zookeeper-a52ff80\src\java\main\org\apache\jute\package.html
ewhauser-zookeeper-a52ff80\src\java\main\org\apache\jute\compiler\package.html,
原來是hadoop的Rcc(是用JAVA編寫的 源文件中可以找到),這個東西作用是src下的zookeeper.jute文件轉換為C C++ java的數據結構 好像原來是沒有C#的,是後來作者加上的,這裏就先不管了,可以用就行,接下來說說怎麽生成 ewhauser-zookeeper-a52ff80\src\dotnet\ZooKeeperNet\Generated的文件
我們需要運行ant命令
如果不知道ant,那google把
配置好ant 後 運行
ant -file build.xml
這樣運行後等待build successfully 你的ewhauser-zookeeper-a52ff80\src\dotnet\ZooKeeperNet\Generated就有文件了
現在就能將zookeeperNet編譯為Dll了
我編譯的時候發現有MiscUtil.dll不存在的警告 ,所以我還是去把這個dll下載了下來
註意這個客戶端必須要用.NET4.0編譯
以下整理過的donet的源文件包,大家參考使用
通過C#代碼使用zookeeper
Zookeeper的使用主要是通過創建其Nuget ZooKeeperNet包下的Zookeeper實例,並且調用其接口方法進行
的,主要的操作就是對znode的增刪改操作,監聽znode的變化以及處理。
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 TimeSpan(0, 0, 0, 50000), new Watcher())) { 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); } } } }
本來此客戶端可以通過NuGet獲取,如果會使用NuGet, 則可以使用命令Install-Package ZooKeeperNet(需要最新版本的NuGet)
如果不會,就去 NuGet官網了解http://docs.nuget.org/docs/start-here/using-the-package-manager-console
如果你想自己編譯 你可以去GitHub下載源碼https://github.com/ewhauser/zookeeper
donet編譯時會報出Genrated裏的文件無法打開,實際上剛開始是沒有的;
最後在網上查了很多資料和源碼裏的說明文檔
ewhauser-zookeeper-a52ff80\src\java\main\org\apache\jute\package.html
ewhauser-zookeeper-a52ff80\src\java\main\org\apache\jute\compiler\package.html,
原來是hadoop的Rcc(是用JAVA編寫的 源文件中可以找到),這個東西作用是src下的zookeeper.jute文件轉換為C C++ java的數據結構 好像原來是沒有C#的,是後來作者加上的,這裏就先不管了,可以用就行,接下來說說怎麽生成 ewhauser-zookeeper-a52ff80\src\dotnet\ZooKeeperNet\Generated的文件
我們需要運行ant命令
如果不知道ant,那google把
配置好ant 後 運行
ant -file build.xml
這樣運行後等待build successfully 你的ewhauser-zookeeper-a52ff80\src\dotnet\ZooKeeperNet\Generated就有文件了
現在就能將zookeeperNet編譯為Dll了
我編譯的時候發現有MiscUtil.dll不存在的警告 ,所以我還是去把這個dll下載了下來
註意這個客戶端必須要用.NET4.0編譯
以下整理過的donet的源文件包,大家參考使用
通過C#代碼使用zookeeper
Zookeeper的使用主要是通過創建其Nuget ZooKeeperNet包下的Zookeeper實例,並且調用其接口方法進行
的,主要的操作就是對znode的增刪改操作,監聽znode的變化以及處理。
- 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 TimeSpan(0, 0, 0, 50000), new Watcher()))
- {
- 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);
- }
- }
- }
- }
Zookeeper .Net客戶端代碼