Zookeeper.NET Client(三)【Znode节点增删改查】
那些最能干的人,往往是那些即使在最绝望的环境里,仍不断传送成功意念的人。他们不但鼓舞自己,也振奋他人,不达成功,誓不休止。——安东尼·罗宾class Program{static void Main(string[] args){//创建一个Zookeeper实例,第一个参数为目标服务器地址和端口,第二个参数为Session超时时
·
那些最能干的人,往往是那些即使在最绝望的环境里,仍不断传送成功意念的人。他们不但鼓舞自己,也振奋他人,不达成功,誓不休止。——安东尼·罗宾
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);
if (stat == null)
{
//创建一个节点root,数据是mydata,不进行ACL权限控制,节点为永久性的(即客户端shutdown了也不会消失)
zk.Create("/root", "mydata灵风".GetBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.Persistent);
}
//在root下面创建一个childone znode,数据为childone,不进行ACL权限控制,节点为永久性的
Console.WriteLine(DateTime.Now+",(预估)开始创建毫秒数位置:"+DateTime.Now.Millisecond);
Console.WriteLine(zk.Create("/root/childone", "childone".GetBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.Persistent));
//取得/root节点下的子节点名称,返回List<String>
Console.WriteLine(zk.GetChildren("/root", true).Count());
//取得/root/childone节点下的数据,返回byte[]
Console.WriteLine(Encoding.UTF8.GetString(zk.GetData("/root/childone", true, null)));
//修改节点/root/childone下的数据,第三个参数为版本,如果是-1,那会无视被修改的数据版本,直接改掉
/*ZooKeeper中每个znode的Stat结构体由下述字段构成:
czxid:创建节点的事务的zxid
mzxid:对znode最近修改的zxid
ctime:以距离时间原点(epoch)的毫秒数表示的znode创建时间
mtime:以距离时间原点(epoch)的毫秒数表示的znode最近修改时间
version:znode数据的修改次数
cversion:znode子节点修改次数
aversion:znode的ACL修改次数
ephemeralOwner:如果znode是临时节点,则指示节点所有者的会话ID;如果不是临时节点,则为零。
dataLength:znode数据长度。
numChildren:znode子节点个数。
*/
long time = zk.SetData("/root/childone", "childonemodify".GetBytes(), -1).Ctime;
Console.WriteLine(Encoding.UTF8.GetString(zk.GetData("/root/childone", true, null)));
Console.WriteLine(ConvertIntDateTime(time) + ",实际创建毫秒数位置:" + ConvertIntDateTime(time).Millisecond);
//删除/root/childone这个节点,第二个参数为版本,-1的话直接删除,无视版本
zk.Delete("/root/childone", -1);
}
Console.ReadKey();
}
/// <summary>
/// 将Unix时间戳转换为DateTime类型时间
/// </summary>
/// <param name="d">double型数字</param>
/// <returns>DateTime</returns>
public static System.DateTime ConvertIntDateTime(double d)
{
System.DateTime time = System.DateTime.MinValue;
System.DateTime startTime = TimeZone.CurrentTimeZone.ToLocalTime(new System.DateTime(1970, 1, 1));
time = startTime.AddMilliseconds(d);
return time;
}
}
运行如图:
更多推荐
已为社区贡献17条内容
所有评论(0)