老师,我这样才能连上zk?

老师,我这样才能连上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);

}

问题描述:

老师上课那种方式连不上啊

正在回答 回答被采纳积分+1

登陆购买课程后可参与讨论,去登陆

1回答
好帮手慕小脸 2021-11-03 16:15:12

同学你好,上述代码能正确连接使用也是可以的,这里想问一下同学,使用视频里的代码是会出现报错吗?如果是,建议将报错信息反馈

祝学习愉快~

  • 提问者 慕楠枫桥 #1

    就是一直连接不上,我那个也有点问题,监听节点修改和删除卡点的时候卡住不动了

    2021-11-03 18:25:25
  • 好帮手慕小脸 回复 提问者 慕楠枫桥 #2

    同学你好,老师这边测试是可以的,建议同学下载课程源码运行试一下~

    祝学习愉快~

    2021-11-03 18:30:05
问题已解决,确定采纳
还有疑问,暂不采纳

恭喜解决一个难题,获得1积分~

来为老师/同学的回答评分吧

0 星
请稍等 ...
意见反馈 帮助中心 APP下载
官方微信

在线咨询

领取优惠

免费试听

领取大纲

扫描二维码,添加
你的专属老师