亚洲免费在线视频-亚洲啊v-久久免费精品视频-国产精品va-看片地址-成人在线视频网

您的位置:首頁技術(shù)文章
文章詳情頁

java - 有zookeeper相關(guān)的大神么?使用ZKClient創(chuàng)建節(jié)點,但是服務(wù)器中并沒有顯示?

瀏覽:122日期:2023-12-16 14:30:10

問題描述

我按照zk權(quán)威指南上的代碼創(chuàng)建節(jié)點:

package com.zkstudy;import java.io.IOException;import java.util.Random;import org.apache.zookeeper.CreateMode;import org.apache.zookeeper.KeeperException;import org.apache.zookeeper.WatchedEvent;import org.apache.zookeeper.Watcher;import org.apache.zookeeper.ZooDefs.Ids;import org.apache.zookeeper.ZooKeeper;import org.apache.zookeeper.data.Stat;public class Master implements Watcher { private ZooKeeper zk = null; private String host; private String serverId = null; private boolean isLeader = false; public Master(String host) {this.host = host;Random radom = new Random();serverId = Integer.toHexString(radom.nextInt()); } public void start() {try { this.zk = new ZooKeeper(host, 15000, this);} catch (IOException e) { e.printStackTrace();} } public void createMaster() {while (true) { try {zk.create('/master', serverId.getBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL);isLeader = true;break; } catch (KeeperException e) {e.printStackTrace();isLeader = false;break; } catch (InterruptedException e) {e.printStackTrace(); } if (checkMaster()) {break; }} } public boolean checkMaster() {while (true) { Stat stat = new Stat(); try {byte[] data = zk.getData('/master', false, stat);isLeader = new String(data).equals(serverId);return true; } catch (KeeperException e) {e.printStackTrace();return false; } catch (InterruptedException e) {e.printStackTrace(); }} } public void process(WatchedEvent event) {System.out.println('watcher thread:---------->' + Thread.currentThread().getId());System.out.println('event:---------->' + event); } public static void main(String[] args) throws InterruptedException {Master master = new Master('123.206.28.37:2181');master.start();master.createMaster();if (master.isLeader) { System.out.println('i am master');}System.out.println('main thread:---------->' + Thread.currentThread().getId());Thread.sleep(5000); }}

然后我運行了兩遍。出現(xiàn)了如下問題:

watcher thread:---------->10event:---------->WatchedEvent state:SyncConnected type:None path:nullorg.apache.zookeeper.KeeperException$NodeExistsException: KeeperErrorCode = NodeExists for /mastermain thread:---------->1 at org.apache.zookeeper.KeeperException.create(KeeperException.java:119) at org.apache.zookeeper.KeeperException.create(KeeperException.java:51) at org.apache.zookeeper.ZooKeeper.create(ZooKeeper.java:783) at com.zkstudy.Master.createMaster(Master.java:40) at com.zkstudy.Master.main(Master.java:83)

提示master節(jié)點已經(jīng)存在。但是我在命令行里面查看卻沒有發(fā)現(xiàn)master節(jié)點:

[zk: localhost:2181(CONNECTED) 10] ls[zk: localhost:2181(CONNECTED) 11] ls /[zk, zookeeper][zk: localhost:2181(CONNECTED) 12]

請問這是為什么呢?zk使用的是單節(jié)點,不是偽集群。

問題解答

回答1:

自問自答吧。因為我創(chuàng)建的是臨時節(jié)點,臨時節(jié)點在繪畫斷開以后會自動刪除,估計這個 ls / 命令應(yīng)該是列舉的持久節(jié)點。

標簽: java
主站蜘蛛池模板: 国内精品小视频 | 久久久美女视频 | 国产精品免费观看视频 | 99视频九九精品视频在线观看 | 精品400部自拍视频在线播放 | 欧美在线一区二区三区欧美 | 国产三级香港三韩国三级 | 国产精品国产自线在线观看 | 久久精品国产只有精品2020 | 欧美一级毛片在线观看 | 成年女人色毛片免费 | 操美女大逼视频 | 亚洲第一页乱 | 久热久操| 国产黄色一级毛片 | 国产手机在线视频放线视频 | 三级网站大全 | 黄色a毛片 | 日韩欧美毛片免费看播放 | 成年人在线免费网站 | 色吧久久 | 性国产精品| 免费小视频在线观看 | 久久久久综合 | 日韩免费一级片 | 日本二级毛片免费 | 日韩精品一区二区三区在线观看 | 日本 欧美 国产 | 久久久精品国产 | 欧美毛片网站 | 黄网在线免费 | 国产精品一区二区综合 | 毛片手机在线观看 | 亚洲另类激情综合偷自拍 | 欧美一级二级毛片视频 | 国产原创系列在线 | www中文字幕在线观看 | 欧美日韩高清观看一区二区 | 欧美一级特黄aa大片在线观看免费 | www.色亚洲| 色综合美国色农夫网 |