13518219792
今天就跟大家聊聊有关zookeeper服务器动态上下线代码怎么写，可能很多人都不太了解，为了让大家更加了解，小编给大家总结了以下内容，希望大家根据这篇文章可以有所收获。
10年积累的成都做网站、成都网站制作、成都外贸网站建设经验，可以快速应对客户对网站的新想法和需求。提供各种问题对应的解决方案。让选择我们的客户得到更好、更有力的网络服务。我虽然不认识你，你也不认识我。但先做网站后付款的网站建设流程，更有武城免费网站建设让你可以放心的选择与我们合作。
服务端：
package com.hgs.test;
import java.io.IOException;
import java.util.List;
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 ZKserver {
private ZooKeeper zk = null;
private final static String connectString = "192.168.6.131:2181,192.168.6.132:2181,192.168.6.133:2181";
private final static int sessionTimeout = 2000;
private final static String parentNode="/servers";
public static void main(String[] args) {
ZKserver zkserver = new ZKserver();
zkserver.getConnect();
zkserver.register(args[0]);
zkserver.doSomthing();
}
public void getConnect() {
try {
zk = new ZooKeeper(connectString, sessionTimeout, new Watcher() {
@Override
public void process(WatchedEvent event) {
try {
if (zk.exists(parentNode,false)==null) {
System.out.println(zk.getChildren("/", true));
}else {
if(event.getType()==EventType.NodeChildrenChanged) {
try {
System.out.println(zk.getChildren(parentNode, true)+ event.getType().toString()+" "+(event.getType()==EventType.NodeChildrenChanged));
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
} catch (Exception e2) {
// TODO Auto-generated catch block
e2.printStackTrace();
}
}
});
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
public void register(String host) {
try {
if(zk.exists(parentNode,false)==null ) {
zk.create(parentNode, null, Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
}
zk.create(parentNode+"/server", host.getBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL_SEQUENTIAL);
} catch (Exception e) {
// TODO Auto-generated catch block
System.out.println("register sever failed !");
System.exit(1);
}
}
public void doSomthing() {
System.out.println("doSomething......");
try {
Thread.sleep(Long.MAX_VALUE);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
服务端：
package com.hgs.test;
import java.io.IOException;
import java.util.ArrayList;
import java.util.List;
import org.apache.zookeeper.KeeperException;
import org.apache.zookeeper.WatchedEvent;
import org.apache.zookeeper.Watcher;
import org.apache.zookeeper.ZooKeeper;
import org.apache.zookeeper.data.Stat;
public class ZKclient {
private ZooKeeper zk = null;
private final static String connectString = "192.168.6.131:2181,192.168.6.132:2181,192.168.6.133:2181";
private final static int sessionTimeout = 2000;
private volatile List serverList = new ArrayList();
private final static String parentNode="/servers";
int i = 10;
public static void main(String[] args) {
ZKclient client = new ZKclient();
client.getConnect();
client.getServerList();
client.doSomething();
}
public void getConnect() {
try {
zk = new ZooKeeper(connectString, sessionTimeout, new Watcher(){
@Override
public void process(WatchedEvent event) {
try {
Stat st = zk.exists(parentNode, true);
//System.out.println(st);
if(st!=null) {
getServerList();
}else {
zk.getChildren("/", true);
}
} catch (KeeperException | InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
});
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
public void getServerList() {
List ls = new ArrayList();
try {
Stat st = zk.exists(parentNode, true);
if(st!=null) {
for(String str:zk.getChildren(parentNode, true)) {
String hosts = new String(zk.getData(parentNode+"/"+str, false , null));
ls.add(hosts);
}
}else {
zk.getChildren("/", true);
}
} catch (KeeperException | InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
serverList = ls;
System.out.println(ls);
}
public void doSomething() {
System.out.println(serverList);
try {
Thread.sleep(Long.MAX_VALUE);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
} 看完上述内容，你们对zookeeper服务器动态上下线代码怎么写有进一步的了解吗？如果还想了解更多知识或者相关内容，请关注创新互联行业资讯频道，感谢大家的支持。
