老师我的不知道为什么不走process
/**
*
*/
package com.ginger.zookeeper;
import java.util.concurrent.CountDownLatch;
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.ZooKeeper;
import org.apache.zookeeper.data.Stat;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
* @Description: 获取节点数据
* @author 姜锋
* @date 2018年8月20日 下午5:04:28
* @version V1.0
*/
public class ZKGetNodeData implements Watcher {
final static Logger log = LoggerFactory.getLogger(ZKGetNodeData.class);
private ZooKeeper zooKeeper = null;
// 服务端地址
public static final String connectionString = "www.justginger.top:2181,www.justginger.top:2182,www.justginger.top:2183";
// session过期时间
public static final Integer sessionTimeout = 5000;
private static Stat stat = new Stat();
public ZKGetNodeData() {
}
/**
* @Description: TODO(这里用一句话描述这个方法的作用) @author 姜锋 @date 2018年8月20日 下午5:46:30 @param @param
* i @param @return @return CountDownLatch @throws
*/
public ZKGetNodeData(String connectionString) {
try {
zooKeeper = new ZooKeeper(connectionString, sessionTimeout, new ZKNodeOpteator());
} catch (Exception e) {
e.printStackTrace();
if (zooKeeper != null) {
try {
zooKeeper.close();
} catch (InterruptedException e1) {
e1.printStackTrace();
}
}
}
}
private static CountDownLatch countDown = new CountDownLatch(1);
public static void main(String[] args) throws Exception {
ZKGetNodeData zkServer = new ZKGetNodeData(connectionString);
/**
* 参数: path:节点路径 watch:true或者false, 注册一个watch事件 stat : 状态
*/
byte[] resByte = zkServer.getZooKeeper().getData("/ginger", true, stat);
String result = new String(resByte);
System.out.println("此次查询结果" + result);
countDown.await();
}
@Override
public void process(WatchedEvent event) {
try {
if (event.getType() == EventType.NodeDataChanged) {
ZKGetNodeData zkServer = new ZKGetNodeData(connectionString);
byte[] resByte = zkServer.getZooKeeper().getData("/ginger", false, stat);
String result = new String(resByte);
System.out.println("更改后的值" + result);
System.out.println("更改后的版本号New Version: " + stat.getVersion());
countDown.countDown();
} else if (event.getType() == EventType.NodeCreated) {
} else if (event.getType() == EventType.NodeChildrenChanged) {
} else if (event.getType() == EventType.NodeDeleted) {
}
} catch (KeeperException e) {
e.printStackTrace();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
/**
* @return zooKeeper
*/
public ZooKeeper getZooKeeper() {
return zooKeeper;
}
/**
* @param zooKeeper 要设置的 zooKeeper
*/
public void setZooKeeper(ZooKeeper zooKeeper) {
this.zooKeeper = zooKeeper;
}
}控制台日志
18:31:43.208 [main] DEBUG org.apache.zookeeper.ClientCnxn - zookeeper.disableAutoWatchReset is false
18:31:43.607 [main-SendThread(www.justginger.top:2181)] INFO org.apache.zookeeper.ClientCnxn - Opening socket connection to server www.justginger.top/139.199.36.32:2181. Will not attempt to authenticate using SASL (unknown error)
18:31:43.618 [main-SendThread(www.justginger.top:2181)] INFO org.apache.zookeeper.ClientCnxn - Socket connection established to www.justginger.top/139.199.36.32:2181, initiating session
18:31:43.619 [main-SendThread(www.justginger.top:2181)] DEBUG org.apache.zookeeper.ClientCnxn - Session establishment request sent on www.justginger.top/139.199.36.32:2181
18:31:43.640 [main-SendThread(www.justginger.top:2181)] INFO org.apache.zookeeper.ClientCnxn - Session establishment complete on server www.justginger.top/139.199.36.32:2181, sessionid = 0x100000ced1f000e, negotiated timeout = 5000
18:31:43.656 [main-SendThread(www.justginger.top:2181)] DEBUG org.apache.zookeeper.ClientCnxn - Reading reply sessionid:0x100000ced1f000e, packet:: clientPath:null serverPath:null finished:false header:: 1,4 replyHeader:: 1,4294967371,0 request:: '/ginger,T response:: #617364617364617364,s{4294967304,4294967369,1534647571665,1534761083862,6,2,0,0,9,0,4294967312}
此次查询结果asdasdasd
18:31:45.322 [main-SendThread(www.justginger.top:2181)] DEBUG org.apache.zookeeper.ClientCnxn - Got ping response for sessionid: 0x100000ced1f000e after 10ms
18:31:46.986 [main-SendThread(www.justginger.top:2181)] DEBUG org.apache.zookeeper.ClientCnxn - Got ping response for sessionid: 0x100000ced1f000e after 7ms
18:31:48.594 [main-SendThread(www.justginger.top:2181)] DEBUG org.apache.zookeeper.ClientCnxn - Got notification sessionid:0x100000ced1f000e
18:31:48.595 [main-SendThread(www.justginger.top:2181)] DEBUG org.apache.zookeeper.ClientCnxn - Got WatchedEvent state:SyncConnected type:NodeDataChanged path:/ginger for sessionid 0x100000ced1f000e
18:31:48.602 [main-SendThread(www.justginger.top:2181)] DEBUG org.apache.zookeeper.ClientCnxn - Got ping response for sessionid: 0x100000ced1f000e after 8ms
18:31:50.268 [main-SendThread(www.justginger.top:2181)] DEBUG org.apache.zookeeper.ClientCnxn - Got ping response for sessionid: 0x100000ced1f000e after 8ms
18:31:51.935 [main-SendThread(www.justginger.top:2181)] DEBUG org.apache.zookeeper.ClientCnxn - Got ping response for sessionid: 0x100000ced1f000e after 8ms
正在回答
3回答
你把域名改为ip试试，另外要触发watch的话，在另一端去修改监听的数据即可
相似问题
登录后可查看更多问答，登录/注册
