老师,我这样才能连上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版
- 参与学习 人
- 提交作业 9393 份
- 解答问题 16556 个
综合就业常年第一,编程排行常年霸榜,无需脱产即可学习,北上广深月薪过万 无论你是未就业的学生还是想转行的在职人员,不需要基础,只要你有梦想,想高薪
了解课程
恭喜解决一个难题,获得1积分~
来为老师/同学的回答评分吧
0 星