客户端将初始值加1,然后写入server。
2个客户端输出的值的顺序是一致的。 说明客户端可已感知其他客户端的处理结果。
github 地址
https://github.com/noobthinker/zookeeper-simple-demo
贴代码区域
server
public class Server {
NIOServerCnxnFactory serverCnxnFactory;
public void zkStart(Conf conf) throws IOException, InterruptedException {
ZooKeeperServer zkServer = new ZooKeeperServer();
File dataDirectory = new File(conf.DIR);
FileTxnSnapLog ftxn = new FileTxnSnapLog(dataDirectory, dataDirectory);
zkServer.setTxnLogFactory(ftxn);
zkServer.setTickTime(conf.TICK_TIME);
serverCnxnFactory = new NIOServerCnxnFactory();
serverCnxnFactory.configure(new InetSocketAddress(conf.PORT), conf.MAX_CLIENT_CONNECTIONS);
serverCnxnFactory.startup(zkServer);
}
}
client
public class Client implements Watcher, AsyncCallback.StatCallback {
ZooKeeper zk;
boolean dead;
String znode;
Stat stat;
int index;
public void initZkClient(String ipport,int timetout,String znode) {
try {
this.znode = znode;
zk = new ZooKeeper(ipport, timetout, this);
stat = zk.exists(znode, false);
if(null == stat){
zk.create(znode,new byte[0], ZooDefs.Ids.OPEN_ACL_UNSAFE,
CreateMode.PERSISTENT);
}
zk.getData(znode,this,stat);
} catch (IOException e) {
e.printStackTrace();
}catch (KeeperException e) {
e.printStackTrace();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
public void processResult(int rc, String s, Object o, Stat stat) {
boolean exists;
switch (rc) {
case KeeperException.Code.Ok:
exists = true;
break;
case KeeperException.Code.NoNode:
exists = false;
break;
case KeeperException.Code.SessionExpired:
case KeeperException.Code.NoAuth:
dead = true;
return;
default:
zk.exists(znode, true, this, null);
return;
}
byte b[] = null;
if (exists) {
try {
b = zk.getData(znode, false, null);
System.out.println(new String(b));
} catch (KeeperException e) {
e.printStackTrace();
} catch (InterruptedException e) {
return;
}
}
}
public void process(WatchedEvent event) {
String path = event.getPath();
if (event.getType() == Event.EventType.None) {
switch (event.getState()) {
case SyncConnected:
break;
case Expired:
dead = true;
break;
}
} else {
if (path != null && path.equals(znode)) {
zk.exists(znode, true, this, null);
}
}
}
public void dataMaker(int i){
index=i;
int max=index+10;
boolean run=true;
while(run){
try {
zk.setData(znode, ((index++) + "").getBytes(), -1);
Thread.sleep(50);
if(index>max){
run=false;
zk.close();
}
} catch (KeeperException e) {
e.printStackTrace();
} catch (InterruptedException e) {
e.printStackTrace();
}catch (Exception e){
e.printStackTrace();
}
}
}
}
conf
public class Conf {
public String DIR;
public int TICK_TIME;
public int PORT;
public int MAX_CLIENT_CONNECTIONS;
}
test 类
server
public class ZkServer {
public static void main(String[]args){
Conf conf = new Conf();
conf.DIR="/zookeeper";
conf.PORT=22801;
conf.TICK_TIME=2000;
conf.MAX_CLIENT_CONNECTIONS=60;
Server srv = new Server();
try {
srv.zkStart(conf);
} catch (IOException e) {
e.printStackTrace();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
client1
public class ZkClient1 {
public static void main(String[]args){
Client client = new Client();
client.initZkClient("localhost:22801",3000,"/zka");
client.dataMaker(0);
}
}
client1 输出
0 20 1 21 2 22 3 23 4 24 5 25 6 26 7 27 8 28 9 29 10 30
client2
public class ZkClient2 {
public static void main(String[]args){
Client client = new Client();
client.initZkClient("localhost:22801",3000,"/zka");
client.dataMaker(20);
}
}
client2输出
20 1 21 2 22 3 23 4 24 5 25 6 26 7 27 8 28 9 29 10 30
2个端输出一致。
分享到:
相关推荐
linux下编译zookeeper3.7.0出的头文件和库: proto.h recordio.h zookeeper.h zookeeper.jute.h zookeeper_log.h zookeeper_version.h libzookeeper_mt.a libzookeeper_mt.la libzookeeper_mt.so libzookeeper_mt....
apache-zookeeper-3.7.1 apache-zookeeper-3.7.1 apache-zookeeper-3.7.1 apache-zookeeper-3.7.1 apache-zookeeper-3.7.1 apache-zookeeper-3.7.1 apache-zookeeper-3.7.1 apache-zookeeper-3.7.1 apache-zookeeper...
zookeeper-3.4.14,包含添加系统服务插件及添加bat. 1. zookeeper-3.4.14源包 2. commons-daemon-1.1.0-bin-windows.zip 插件 3. 配置好插件的zookeeper-3.4.14包,右键管理员权限执行zk-server-install.bat
赠送jar包:zookeeper-3.4.10.jar; 赠送原API文档:zookeeper-3.4.10-javadoc.jar; 赠送源代码:zookeeper-3.4.10-sources.jar; 赠送Maven依赖信息文件:zookeeper-3.4.10.pom; 包含翻译后的API文档:zookeeper-...
apache-zookeeper-3.6.0.tar.gz
zookeeper-3.4.9.tar.gz
apache-zookeeper-3.5.7-bin.tar.gz 。
zookeeper-3.4.5-cdh5.16.2.tar.gz 资源包,之前的原网站上无法下载,后经多种途径下载到该资源包,上传到博客上供大家使用。
zookeeper-3.4.8zookeeper-3.4.8zookeeper-3.4.8zookeeper-3.4.8
放在压缩包里了, 在windows下解压出"zookeeper-3.4.14.tar.gz"之后上传至虚拟机即可
zookeeper-3.4.6 解压后可直接运行 bin/zkServer.cmd 来启动
ZooKeeper的目标就是封装好复杂易出错的关键服务,将简单易用的接口和性能高效、功能稳定的系统提供给用户。 ZooKeeper包含一个简单的原语集,提供Java和C的接口。 ZooKeeper代码版本中,提供了分布式独享锁、选举、...
赠送jar包:zookeeper-3.3.3.jar; 赠送原API文档:zookeeper-3.3.3-javadoc.jar; 赠送源代码:zookeeper-3.3.3-sources.jar; 包含翻译后的API文档:zookeeper-3.3.3-javadoc-API文档-中文(简体)版.zip 对应...
apache-zookeeper分布式框架,压缩包内容:(apache-zookeeper-3.7.1-bin.tar.gz、apache-zookeeper-3.7.1.tar.gz、apache-zookeeper-3.6.4-bin.tar.gz、apache-zookeeper-3.6.4.tar.gz、apache-zookeeper-3.5.10-...
zookeeper-3.4.8.jar
zookeeper-3.4.5.jar; zookeeper-3.4.5.jar; zookeeper-3.4.5.jar;
最新版linux apache-zookeeper-3.7.0-bin.tar.gz最新版linux apache-zookeeper-3.7.0-bin.tar.gz
zookeeper-3.4.10和zookeeper-3.4.12
zookeeper-3.5.7.zip文件 zookeeper-3.5.7.zip文件 zookeeper-3.5.7.zip文件 zookeeper-3.5.7.zip文件 zookeeper-3.5.7.zip文件 zookeeper-3.5.7.zip文件 zookeeper-3.5.7.zip文件 zookeeper-3.5.7.zip文件 ...