废话少说直接上代码!
import java.net.InetAddress;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import org.apache.zookeeper.CreateMode;
import org.apache.zookeeper.KeeperException;
import org.apache.zookeeper.WatchedEvent;
import org.apache.zookeeper.Watcher;
import org.apache.zookeeper.Watcher.Event.EventType;
import org.apache.zookeeper.ZooDefs.Ids;
import org.apache.zookeeper.ZooKeeper;
public class ClusterTest {
static ZooKeeper zk = null;
static Map<String, Watcher> myWatchMap = new HashMap<String, Watcher>();
static String ip = null;
public static void init() throws InterruptedException {
for(int i = 1; i < 6; i++){
final int k = i;
Thread t = new Thread(new Runnable() {
@Override
public void run() {
// 创建一个与服务器的连接
try {
ZooKeeper zk = new ZooKeeper(
"localhost:2181,localhost:2182", 1000, null);
String path = ip+k;
if(zk.exists(path, false) == null){
zk.create(path, "testRootData".getBytes(), Ids.OPEN_ACL_UNSAFE,
CreateMode.EPHEMERAL);
}
Thread.sleep(1000);
zk.close();
} catch (Exception e) {
// e.printStackTrace();
}
}
});
t.start();
t.setName("RISHENG-THREAD-"+i);
}
}
/**
* @param args
* @throws Exception
*/
public static void main(String[] args) throws Exception {
InetAddress addr = InetAddress.getLocalHost();
ip="/zookeeper/"+addr.getHostAddress();
// 创建一个与服务器的连接
zk = new ZooKeeper("localhost:2181,localhost:2182",
1000, null);
List<String> nodeList = zk.getChildren("/zookeeper", false);
System.err.println(nodeList);
init();
regWatch();
while(true){
Thread.sleep(1000);
init();
regWatch();
}
}
public static void regWatch() throws KeeperException, InterruptedException{
for(int i = 1; i < 6; i++){
String path = ip+i;
Watcher watch = null;
if(!myWatchMap.containsKey(path)){
watch = new MyWatch(zk, path);
myWatchMap.put(path, watch);
}
zk.exists(path, watch);
}
}
}
class MyWatch implements Watcher{
private ZooKeeper zk = null;
private String path = null;
public MyWatch(ZooKeeper zk, String path){
this.zk = zk;
this.path = path;
}
@Override
public void process(WatchedEvent event) {
if(EventType.NodeDeleted.equals(event.getType())){
System.err.println(event.getPath()+"====服务关闭===="+path);
} else if(EventType.NodeCreated.equals(event.getType())){
System.out.println(event.getPath()+"====服务开启===="+path);
}
try {
zk.exists(event.getPath(), this);
} catch (KeeperException e) {
} catch (InterruptedException e) {
}
}
}
另外有几点需要关注:
1、如果重复的new新的Watcher会导致订阅端重复收到通知;
2、zk的Watcher是一次性消费,用完后记得重新注册;
3、zk不保证通知关系始终简历,所以需要轮询注册Watcher
分享到:
相关推荐
从Paxos到Zookeeper分布式一致性原理与实践.pdf从Paxos到Zookeeper分布式一致性原理与实践.pdf从Paxos到Zookeeper分布式一致性原理与实践.pdf从Paxos到Zookeeper分布式一致性原理与实践.pdf从Paxos到Zookeeper分布式...
从PAXOS到ZOOKEEPER分布式一致性原理与实践从PAXOS到ZOOKEEPER分布式一致性原理与实践从PAXOS到ZOOKEEPER分布式一致性原理与实践
从Paxos到Zookeeper分布式一致性原理与实践包括源码推荐给需要学习的童鞋
从Paxos到Zookeeper分布式一致性原理与实践 + ZooKeeper-分布式过程协同技术详解
从Paxos到Zookeeper 分布式一致性原理与实践 PDF电子书下载 带目录书签 完整版.pdf
ZooKeeper 是一个开源的分布式协调服务,ZooKeeper 框架最初是在“Yahoo!"上构建的,用于以简单而稳健的方式访问他们的应用程序。
从Paxos到Zookeeper 分布式一致性原理与实践
Zookeeper 分布式过程.pdf
zookeeper分布式进程协同.pdf
《从PAXOS到ZOOKEEPER分布式一致性原理与实践》,资源完整高清版
<<zookeeper分布式过程协同技术详解>>这是一本非常不错的书,但是中文翻译的太烂,导致有些章节理解起来很费劲。如果看下英文版,会发现,不明白的地方看英文原版反而非常容易理解。
先讲PAXOS算法,然后逐步进入时间zookeeper,从分布式一致性原理到实践,全盘讲解,带书签。
paxos算法,zookeeper分布式一致性,理论实践结合,详细的解析。
ZooKeeper是Google的Chubby项目的开源实现,它曾经作为Hadoop的 ⼦项目,在⼤数据领域得到⼴泛应用。
从Paxos到Zookeeper 分布式一致性原理与实践 [倪超著] 文件太大 分为两部分 这是第一部分