<ruby id="bdb3f"></ruby>

    <p id="bdb3f"><cite id="bdb3f"></cite></p>

      <p id="bdb3f"><cite id="bdb3f"><th id="bdb3f"></th></cite></p><p id="bdb3f"></p>
        <p id="bdb3f"><cite id="bdb3f"></cite></p>

          <pre id="bdb3f"></pre>
          <pre id="bdb3f"><del id="bdb3f"><thead id="bdb3f"></thead></del></pre>

          <ruby id="bdb3f"><mark id="bdb3f"></mark></ruby><ruby id="bdb3f"></ruby>
          <pre id="bdb3f"><pre id="bdb3f"><mark id="bdb3f"></mark></pre></pre><output id="bdb3f"></output><p id="bdb3f"></p><p id="bdb3f"></p>

          <pre id="bdb3f"><del id="bdb3f"><progress id="bdb3f"></progress></del></pre>

                <ruby id="bdb3f"></ruby>

                合規國際互聯網加速 OSASE為企業客戶提供高速穩定SD-WAN國際加速解決方案。 廣告
                ## 一、概述 Zookeeper可以用客戶端命令來操作,也可以用Java等編程語言來操作; ## 二、客戶端 連接: ``` bin/zkCli.sh -server localhost:2181 ``` 使用 ls 命令來查看當前 ZooKeeper 中所包含的內容; ``` [zk: localhost:2181(CONNECTED) 0] ls / ``` 創建一個新的 znode; ``` [zk: localhost:2181(CONNECTED) 2] create /ray ``` 再次使用 ls 命令來查看現在 zookeeper 中所包含的內容; ``` [zk: localhost:2181(CONNECTED) 4] ls / ``` ![](https://img.kancloud.cn/ee/f3/eef339ce81e74c0bad7df778e17a137f_738x209.png) ## 三、代碼開發 引入依賴: ``` <!-- https://mvnrepository.com/artifact/org.apache.zookeeper/zookeeper --> <dependency> <groupId>org.apache.zookeeper</groupId> <artifactId>zookeeper</artifactId> <version>3.7.0</version> </dependency> ``` 實例代碼: ``` private static CountDownLatch connectedSemaphore = new CountDownLatch(1); private static ZooKeeper zk = null; private static Stat stat = new Stat(); public static void main(String[] args) throws Exception { String path = "/ray"; zk = new ZooKeeper("211.149.232.36:2181", 5000, new Zk()); // 等待zk連接成功的通知 connectedSemaphore.await(); System.out.println("znode節點值是:" + new String(zk.getData(path, true, stat))); while (true) { } } public void process(WatchedEvent event) { if (KeeperState.SyncConnected == event.getState()) { if (EventType.None == event.getType() && null == event.getPath()) { connectedSemaphore.countDown(); } else if (event.getType() == EventType.NodeDataChanged) { // zk目錄節點數據變化通知事件 try { System.out.println("znode節點值已經被修改:" + new String(zk.getData(event.getPath(), true, stat))); } catch (Exception e) { } } } } ``` 效果展示: 代碼展示了,如果znode節點值發生變化,就被通知,并顯示出來; 命令中修改節點值: ![](https://img.kancloud.cn/e7/fd/e7fdc18f9e2502a2635dfe62db570f71_1427x188.png) 代碼執行效果: ![](https://img.kancloud.cn/72/69/7269c95332602d231aa5dad20cd5fb23_1409x288.png)
                  <ruby id="bdb3f"></ruby>

                  <p id="bdb3f"><cite id="bdb3f"></cite></p>

                    <p id="bdb3f"><cite id="bdb3f"><th id="bdb3f"></th></cite></p><p id="bdb3f"></p>
                      <p id="bdb3f"><cite id="bdb3f"></cite></p>

                        <pre id="bdb3f"></pre>
                        <pre id="bdb3f"><del id="bdb3f"><thead id="bdb3f"></thead></del></pre>

                        <ruby id="bdb3f"><mark id="bdb3f"></mark></ruby><ruby id="bdb3f"></ruby>
                        <pre id="bdb3f"><pre id="bdb3f"><mark id="bdb3f"></mark></pre></pre><output id="bdb3f"></output><p id="bdb3f"></p><p id="bdb3f"></p>

                        <pre id="bdb3f"><del id="bdb3f"><progress id="bdb3f"></progress></del></pre>

                              <ruby id="bdb3f"></ruby>

                              哎呀哎呀视频在线观看