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的源文件包，你們參考使用

html

經過C#代碼使用zookeeperjava

Zookeeper的使用主要是經過建立其Nuget ZooKeeperNet包下的Zookeeper實例，而且調用其接口方法進行node

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

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);
            }

        }
    }
}

經過C#代碼使用zookeeperapache

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 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);
}
}
}
}