0
点赞
收藏
分享

微信扫一扫

zookeeper的使用demo(c#/java)

Zookeeper 作为一个分布式的服务框架,主要用来解决分布式集群中应用系统的一致性问题,它能提供基于类似于文件系统的目录节点树方式的数据存储,但是 Zookeeper 并不是用来专门存储数据的,它的作用主要是用来维护和监控你存储的数据的状态变化。通过监控这些数据状态的变化,从而可以达到基于数据的集群管理。

● 通过C#代码使用zookeeper

Zookeeper的使用主要是通过创建其Nuget ZooKeeper.Net包下的ZooKeeper实例,并且调用其接口方法进行的,主要的操作就是对znode的增删改查操作,监听znode的变化以及处理。

using System;
using ZooKeeperNet;
namespace ConsoleApplication1
{
class Watcher : IWatcher
{
public void Process(WatchedEvent @event)
{
if (@event.Type == EventType.NodeDataChanged)
{
Console.WriteLine(@event.Path + "节点的值被修改");
}

}
}
}

using System;
using System.Linq;
using System.Text;
using ZooKeeperNet;
namespace ConsoleApplication1
{
class Program
{
static void Main(string[] args)
{
//创建一个Zookeeper实例,第一个参数为目标服务器地址和端口,第二个参数为Session超时时间,第三个为节点变化时的回调方法
using (ZooKeeper zk = new ZooKeeper("127.0.0.1:2181", new TimeSpan(0, 0, 0, 10), new Watcher()))
{
String znode_root = "/dubbo/com.alibaba.dubbo.demo.SubDemoService/consumers";
var stat = zk.Exists(znode_root, true);

if (null == stat)
{
//创建一个节点root,数据是mydata,不进行ACL权限控制,节点为永久性的(即客户端shutdown了也不会消失)
zk.Create(znode_root, "mydata".GetBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.Persistent);
}
else
{
var data1 = zk.GetData(znode_root, true, null);
Console.WriteLine(znode_root + ":" + Encoding.Default.GetString(data1));
}
//在root下面创建一个child1 znode,数据为child1,不进行ACL权限控制,节点为永久性的
string c = zk.Create("/root/child1", "child1".GetBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.Persistent);
Console.WriteLine(c);

//取得/root节点下的子节点名称,返回List<String>
var childrenNodes = zk.GetChildren("/root", true);
Console.WriteLine("子节点个数:"+childrenNodes.Count());

//取得/root/child1节点下的数据,返回byte[]
byte[] data = zk.GetData("/root/child1", true, null);
Console.WriteLine("节点存储的数据:"+Encoding.Default.GetString(data));

//修改节点/root/child1下的数据,第三个参数为版本,如果是-1,那会无视被修改的数据版本,直接改掉
zk.SetData("/root/child1", "child1modify".GetBytes(), -1);

//删除/root/child1这个节点,第二个参数为版本,-1的话直接删除,无视版本
zk.Delete("/root/child1", -1);
}

Console.Read();
}
}
}

程序运行结果:

/dubbo/com.alibaba.dubbo.demo.SubDemoService/consumers:192.168.40.69
/root/child1
子节点个数:3
节点存储的数据:child1
节点的值被修改:/root/child1

 

 

● 通过java代码使用zookeeper

java的使用方式同样也是实例化ZooKeeper对象并调用其方法,来操作znode。

zookeeper包依赖:

<dependency>
<groupId>org.apache.zookeeper</groupId>
<artifactId>zookeeper</artifactId>
<version>3.4.6</version>
<exclusions>
<exclusion>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-log4j12</artifactId>
</exclusion>
</exclusions>
</dependency>

code:

import com.alibaba.fastjson.JSON;
import org.apache.zookeeper.*;
import org.apache.zookeeper.data.Stat;

import java.util.List;
import java.util.UUID;

public class ZkDemo {

public static void main(String[] args) throws Exception {
String host = "127.0.0.1:2181";
int timeout = 1000;
ZooKeeper zk = new ZooKeeper(host, timeout, new Watcher() {
public void process(WatchedEvent watchedEvent) {
if (watchedEvent.getType() == Event.EventType.NodeDataChanged) {
System.out.println(watchedEvent.getPath() + "节点的值被修改");
}
}
});

String znode_root = "/dubbo/com.alibaba.dubbo.demo.SubDemoService/consumers";
Stat stat = zk.exists(znode_root, true);
if (null == stat) {
zk.create(znode_root, "mydata".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
System.out.println(znode_root + "被创建");
} else {
byte[] data = zk.getData(znode_root, true, null);
System.out.println(znode_root + ":" + new String(data));
}

if(zk.exists("/root/node2",true)==null) {
//在root下面创建一个名为node2的znode,数据为node2val,不进行ACL权限控制,节点为永久性的
zk.create("/root/node2", "node2val".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
}

//取得/root节点下的子节点名称,返回List<String>
List<String> childrenNodes = zk.getChildren("/root", true);
System.out.println(String.format("子节点(%s个):%s", childrenNodes.size(), JSON.toJSONString(childrenNodes)));

zk.setData("/root/node2", UUID.randomUUID().toString().getBytes(), -1);

zk.close();

}
}

程序运行结果:

/dubbo/com.alibaba.dubbo.demo.SubDemoService/consumers:192.168.40.69
子节点(2个):["childone","node2"]
/root/node2节点的值被修改

 ● 通过监控管理工具查看zk节点树

zookeeper的使用demo(c#/java)_子节点

 

举报

相关推荐

0 条评论