阿里云安装zk并连接javaAPI测试

时间：2019-08-22 00:48:43 阅读：122 评论：0 收藏：0 [点我收藏+]

标签：post RoCE ref inspect cti oid 成功 received nbsp

1、安装

2、注意

阿里云环境开放2181端口

2.1 查看已开放端口：

firewall-cmd --permanent --zone=public --list-ports

2.2 永久的添加该端口。去掉--permanent则表示临时。

firewall-cmd --permanent --zone=public --add-port=2181/tcp

2.3 加载配置，使得修改有效

firewall-cmd --reload

2.4 阿里云安全规则添

技术图片

3、java来接测试

pom文件依赖引入

        <!-- ZooKeeper -->
    <dependency>
        <groupId>org.apache.zookeeper</groupId>
        <artifactId>zookeeper</artifactId>
        <version>3.4.8</version>
    </dependency>

测试代码：

public static void main(String[] args) throws Exception {
      /**
       * 超时时间
       */
      final int SESSION_TIME_OUT = 2000;
      CountDownLatch countDownLatch = new CountDownLatch(1);
      ZooKeeper zookeeper = new ZooKeeper("ip:2181", SESSION_TIME_OUT, new Watcher() {
         @Override
         public void process(WatchedEvent event) {
            if (event.getState() == Event.KeeperState.SyncConnected) {
               System.out.println("Watch received event");
               countDownLatch.countDown();
            }
         }
      });
      countDownLatch.await();
      System.out.println("zookeeper connection success");

       List<String> children = zookeeper.getChildren("/", false);
       System.out.println(children);
   }