無法使用java從根創建zookeeper節點（它不存在）使用java

我打算從java創建一個zookeeper節點。我最初創建了curator客戶機，用它來檢索zookeeper對象並創建失敗的節點。無法使用java從根創建zookeeper節點（它不存在）使用java

我該怎麼辦？

 //client is the CuratorFramework object 
     String MUTEX_LEADER_PATH = "/leader/jobadmin"; 
     client.getZookeeperClient().getZooKeeper().create(MUTEX_LEADER_PATH, new byte[0], Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);

我得到了什麼？

[2015-04-20 10:53:17,992] [ERROR] [org.apache.curator.framework.recipes.leader.LeaderSelector] [LeaderSelector-0] mutex.acquire() threw an exception 
org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /leader 
    at org.apache.zookeeper.KeeperException.create(KeeperException.java:111) 
    at org.apache.zookeeper.KeeperException.create(KeeperException.java:51) 
    at org.apache.zookeeper.ZooKeeper.create(ZooKeeper.java:783) 
    at org.apache.curator.utils.ZKPaths.mkdirs(ZKPaths.java:199) 
    at org.apache.curator.framework.imps.CreateBuilderImpl$11.call(CreateBuilderImpl.java:682) 
    at org.apache.curator.framework.imps.CreateBuilderImpl$11.call(CreateBuilderImpl.java:660) 
    at org.apache.curator.RetryLoop.callWithRetry(RetryLoop.java:107) 
    at org.apache.curator.framework.imps.CreateBuilderImpl.pathInForeground(CreateBuilderImpl.java:656) 
    at org.apache.curator.framework.imps.CreateBuilderImpl.protectedPathInForeground(CreateBuilderImpl.java:441) 
    at org.apache.curator.framework.imps.CreateBuilderImpl.forPath(CreateBuilderImpl.java:431) 
    at org.apache.curator.framework.imps.CreateBuilderImpl.forPath(CreateBuilderImpl.java:411) 
    at org.apache.curator.framework.imps.CreateBuilderImpl.forPath(CreateBuilderImpl.java:44) 
    at org.apache.curator.framework.recipes.locks.LockInternals.attemptLock(LockInternals.java:224) 
    at org.apache.curator.framework.recipes.locks.InterProcessMutex.internalLock(InterProcessMutex.java:221) 
    at org.apache.curator.framework.recipes.locks.InterProcessMutex.acquire(InterProcessMutex.java:77) 
    at org.apache.curator.framework.recipes.leader.LeaderSelector.doWork(LeaderSelector.java:378) 
    at org.apache.curator.framework.recipes.leader.LeaderSelector.doWorkLoop(LeaderSelector.java:436) 
    at org.apache.curator.framework.recipes.leader.LeaderSelector.access$100(LeaderSelector.java:64) 
    at org.apache.curator.framework.recipes.leader.LeaderSelector$2.call(LeaderSelector.java:241) 
    at org.apache.curator.framework.recipes.leader.LeaderSelector$2.call(LeaderSelector.java:235) 
    at java.util.concurrent.FutureTask.run(FutureTask.java:262) 
    at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471) 
    at java.util.concurrent.FutureTask.run(FutureTask.java:262) 
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) 
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) 
    at java.lang.Thread.run(Thread.java:745)

試過不同的創建模式，但結果是一樣的。

private synchronized CuratorFramework createClient() { 
    if (client != null) { 
     return client; 
    } 

    RetryPolicy retryPolicy = new RetryUntilElapsed(SESSION_TIMEOUT, 1000); 
    client = CuratorFrameworkFactory.newClient(MUTEX_LEADER_PATH, SESSION_TIMEOUT, 100, retryPolicy); 
    client.start(); 

    return client; 
}

如何創建不從根本上存在的動物園管理員節點：

使用下面的代碼創建客戶端？

來源

2015-04-20 Arun

我用下面的一段代碼解決了這個問題。

client.create().creatingParentsIfNeeded().withMode(CreateMode.PERSISTENT).withACL(Ids.OPEN_ACL_UNSAFE).forPath(MUTEX_LEADER_PATH, new byte[0]);

它工作完美！

來源

2015-04-20 16:58:56 Arun

無法使用java從根創建zookeeper節點（它不存在）使用java

回答

相關問題