老师,我这样才能连上zk?
public static void main(String[] args) throws IOException, InterruptedException, KeeperException {
//连接操作是异步的(非阻塞连接),如果不做任何处理,可能导致还没连接成功,testConnect方法线程就已经关闭了。
//这里使用递减锁来处理
final CountDownLatch cdl = new CountDownLatch(1);
//ip端口,连接超时时间,监听者
ZooKeeper zk = new ZooKeeper("120.79.204.8:2181", 3000, new Watcher() {
@Override
public void process(WatchedEvent event) {
if(event.getState() == Event.KeeperState.SyncConnected) {
System.out.println("连接成功!");
cdl.countDown();
}
if (event.getState()== Event.KeeperState.Closed) {
System.out.println("连接关闭");
}
}
});
System.out.println("客户端开始连接ZK服务器");
States state = zk.getState();
System.out.println(state);
Thread.sleep(3000);
state = zk.getState();
System.out.println(state);
//递减锁没减到0则阻塞
cdl.await();
state = zk.getState();
System.out.println(state);
zk.close();
Thread.sleep(2000);
state = zk.getState();
System.out.println(state);
}问题描述:
老师上课那种方式连不上啊
18
收起
正在回答 回答被采纳积分+1
java工程师2020版
- 参与学习 人
- 提交作业 9410 份
- 解答问题 16556 个
综合就业常年第一,编程排行常年霸榜,无需脱产即可学习,北上广深月薪过万 无论你是未就业的学生还是想转行的在职人员,不需要基础,只要你有梦想,想高薪
了解课程
恭喜解决一个难题,获得1积分~
来为老师/同学的回答评分吧
0 星