zoukankan      html  css  js  c++  java
  • 阿里云安装zk并连接javaAPI测试

    1、安装

    可参照Ubuntu 搭建Zookeeper服务进行安装并启动。

    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);
       }

    执行如下则说明访问成功:

    4、附注

    可通过ZKInspector来查看管理zookeeper节点,下载地址:https://issues.apache.org/jira/secure/attachment/12436620/ZooInspector.zip

    解压下载包,进入build目录,点击zookeeper-dev-ZooInspector.jar运行

    启动后填写zk服务地址进行连接:

     连上之后如下图:

    后面就可以对zk的节点进行管理了。

  • 相关阅读:
    Java集合的Stack、Queue、Map的遍历
    LinkedHashMap的实现原理
    HashSet的实现原理
    HashMap的实现原理
    leetcode526
    leetcode406
    leetcode413
    leetcode513
    leetcode338
    leetcode419
  • 原文地址:https://www.cnblogs.com/kingsonfu/p/11391932.html
Copyright © 2011-2022 走看看