本文整理了Java中org.apache.curator.utils.ZKPaths.mkdirs()方法的一些代码示例，展示了ZKPaths.mkdirs()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。ZKPaths.mkdirs()方法的具体详情如下：
包路径：org.apache.curator.utils.ZKPaths
类名称：ZKPaths
方法名：mkdirs

ZKPaths.mkdirs介绍

[英]Make sure all the nodes in the path are created. NOTE: Unlike File.mkdirs(), Zookeeper doesn't distinguish between directories and files. So, every node in the path is created. The data for each node is an empty blob
[中]确保路径中的所有节点都已创建。注意：与文件不同。mkdirs（），Zookeeper不区分目录和文件。因此，路径中的每个节点都会被创建。每个节点的数据都是一个空blob

代码示例

代码示例来源：origin: org.apache.curator/curator-framework

@Override
  public Void call() throws Exception
  {
    try
    {
      ZKPaths.mkdirs(client.getZooKeeper(), parent, true, acling.getACLProviderForParents(), createParentContainersIfNeeded);
    }
    catch ( KeeperException.NodeExistsException e )
    {
      // ignore
    }
    catch ( KeeperException.NoNodeException e )
    {
      // ignore
    }
    return null;
  }
}

代码示例来源：origin: org.apache.curator/curator-framework

@Override
  public Object call() throws Exception
  {
    ZKPaths.mkdirs(zookeeperClient.getZooKeeper(), ZKPaths.makePath("/", namespace), true, client.getAclProvider(), true);
    return null;
  }
}

代码示例来源：origin: org.apache.curator/curator-framework

@Override
  public void performBackgroundOperation(OperationAndData<T> dummy) throws Exception
  {
    try
    {
      ZKPaths.mkdirs(client.getZooKeeper(), path, false, aclProvider, createParentsAsContainers);
    }
    catch ( KeeperException e )
    {
      if ( !RetryLoop.isRetryException(e) )
      {
        throw e;
      }
      // otherwise safe to ignore as it will get retried
    }
    client.queueOperation(mainOperationAndData);
  }
};

代码示例来源：origin: org.apache.curator/curator-client

/**
 * Make sure all the nodes in the path are created. NOTE: Unlike File.mkdirs(), Zookeeper doesn't distinguish
 * between directories and files. So, every node in the path is created. The data for each node is an empty blob
 *
 * @param zookeeper the client
 * @param path      path to ensure
 * @throws InterruptedException                 thread interruption
 * @throws org.apache.zookeeper.KeeperException Zookeeper errors
 */
public static void mkdirs(ZooKeeper zookeeper, String path) throws InterruptedException, KeeperException
{
  mkdirs(zookeeper, path, true, null, false);
}

代码示例来源：origin: org.apache.curator/curator-client

/**
 * Make sure all the nodes in the path are created. NOTE: Unlike File.mkdirs(), Zookeeper doesn't distinguish
 * between directories and files. So, every node in the path is created. The data for each node is an empty blob
 *
 * @param zookeeper    the client
 * @param path         path to ensure
 * @param makeLastNode if true, all nodes are created. If false, only the parent nodes are created
 * @param aclProvider  if not null, the ACL provider to use when creating parent nodes
 * @throws InterruptedException                 thread interruption
 * @throws org.apache.zookeeper.KeeperException Zookeeper errors
 */
public static void mkdirs(ZooKeeper zookeeper, String path, boolean makeLastNode, InternalACLProvider aclProvider) throws InterruptedException, KeeperException
{
  mkdirs(zookeeper, path, makeLastNode, aclProvider, false);
}

代码示例来源：origin: xiancloud/xian

/**
 * Make sure all the nodes in the path are created. NOTE: Unlike File.mkdirs(), Zookeeper doesn't distinguish
 * between directories and files. So, every node in the path is created. The data for each node is an empty blob
 *
 * @param zookeeper the client
 * @param path      path to ensure
 * @throws InterruptedException                 thread interruption
 * @throws org.apache.zookeeper.KeeperException Zookeeper errors
 */
public static void mkdirs(ZooKeeper zookeeper, String path) throws InterruptedException, KeeperException
{
  mkdirs(zookeeper, path, true, null, false);
}

代码示例来源：origin: xiancloud/xian

/**
 * Make sure all the nodes in the path are created. NOTE: Unlike File.mkdirs(), Zookeeper doesn't distinguish
 * between directories and files. So, every node in the path is created. The data for each node is an empty blob
 *
 * @param zookeeper    the client
 * @param path         path to ensure
 * @param makeLastNode if true, all nodes are created. If false, only the parent nodes are created
 * @throws InterruptedException                 thread interruption
 * @throws org.apache.zookeeper.KeeperException Zookeeper errors
 */
public static void mkdirs(ZooKeeper zookeeper, String path, boolean makeLastNode) throws InterruptedException, KeeperException
{
  mkdirs(zookeeper, path, makeLastNode, null, false);
}

代码示例来源：origin: org.apache.curator/curator-client

/**
 * Make sure all the nodes in the path are created. NOTE: Unlike File.mkdirs(), Zookeeper doesn't distinguish
 * between directories and files. So, every node in the path is created. The data for each node is an empty blob
 *
 * @param zookeeper    the client
 * @param path         path to ensure
 * @param makeLastNode if true, all nodes are created. If false, only the parent nodes are created
 * @throws InterruptedException                 thread interruption
 * @throws org.apache.zookeeper.KeeperException Zookeeper errors
 */
public static void mkdirs(ZooKeeper zookeeper, String path, boolean makeLastNode) throws InterruptedException, KeeperException
{
  mkdirs(zookeeper, path, makeLastNode, null, false);
}

代码示例来源：origin: xiancloud/xian

/**
 * Make sure all the nodes in the path are created. NOTE: Unlike File.mkdirs(), Zookeeper doesn't distinguish
 * between directories and files. So, every node in the path is created. The data for each node is an empty blob
 *
 * @param zookeeper    the client
 * @param path         path to ensure
 * @param makeLastNode if true, all nodes are created. If false, only the parent nodes are created
 * @param aclProvider  if not null, the ACL provider to use when creating parent nodes
 * @throws InterruptedException                 thread interruption
 * @throws org.apache.zookeeper.KeeperException Zookeeper errors
 */
public static void mkdirs(ZooKeeper zookeeper, String path, boolean makeLastNode, InternalACLProvider aclProvider) throws InterruptedException, KeeperException
{
  mkdirs(zookeeper, path, makeLastNode, aclProvider, false);
}

代码示例来源：origin: org.apache.curator/curator-client

@Override
  public Object call() throws Exception
  {
    ZKPaths.mkdirs(client.getZooKeeper(), path, makeLastNode, aclProvider, asContainers());
    helper.set(doNothingHelper);
    isSet = true;
    return null;
  }
}

代码示例来源：origin: actiontech/dble

public boolean createPath(String path) {
  LOGGER.trace("createPath child path is {}", path);
  boolean result = true;
  try {
    ZKPaths.mkdirs(curator.getZookeeperClient().getZooKeeper(), path);
  } catch (Exception e) {
    LOGGER.warn(" createPath error", e);
    result = false;
  }
  return result;
}

代码示例来源：origin: org.seaborne.rdf-delta/rdf-delta-server-local

public static String zkEnsure(CuratorFramework client, String path) {
  try {
    ZKPaths.mkdirs(client.getZookeeperClient().getZooKeeper(), path, true);
    return path;
  } catch (Exception e) {
    LOG.error("Failed: mkdirs("+path+")",e);
    return null;
  }
}

代码示例来源：origin: xiancloud/xian

@Override
  public Object call() throws Exception
  {
    ZKPaths.mkdirs(client.getZooKeeper(), path, makeLastNode, aclProvider, asContainers());
    helper.set(doNothingHelper);
    isSet = true;
    return null;
  }
}

代码示例来源：origin: info.xiancloud/xian-curator-framework

@Override
  public Void call() throws Exception
  {
    try
    {
      ZKPaths.mkdirs(client.getZooKeeper(), parent, true, client.getAclProvider(), true);
    }
    catch ( KeeperException.NodeExistsException e )
    {
      // ignore
    }
    catch ( KeeperException.NoNodeException e )
    {
      // ignore
    }
    return null;
  }
}

代码示例来源：origin: info.xiancloud/xian-curator-framework

@Override
  public Object call() throws Exception
  {
    ZKPaths.mkdirs(zookeeperClient.getZooKeeper(), ZKPaths.makePath("/", namespace), true, client.getAclProvider(), true);
    return null;
  }
}

代码示例来源：origin: smallnest/ZKRecipesByExample

public static void main(String[] args) throws Exception {
  TestingServer server = new TestingServer();
  CuratorFramework client = null;
  try {
    client = createSimple(server.getConnectString());
    client.start();
    ZKPaths.mkdirs(client.getZookeeperClient().getZooKeeper(),"/a");
    ZKPaths.mkdirs(client.getZookeeperClient().getZooKeeper(),"/another/path");
    ZKPaths.mkdirs(client.getZookeeperClient().getZooKeeper(),"/yet/another/path");
    transaction(client);
  } catch (Exception ex) {
    ex.printStackTrace();
  } finally {
    CloseableUtils.closeQuietly(client);
    CloseableUtils.closeQuietly(server);
  }
}

代码示例来源：origin: info.xiancloud/xian-curator-framework

@Override
  public void performBackgroundOperation(OperationAndData<T> dummy) throws Exception
  {
    try
    {
      ZKPaths.mkdirs(client.getZooKeeper(), path, false, client.getAclProvider(), createParentsAsContainers);
    }
    catch ( KeeperException e )
    {
      if ( !RetryLoop.isRetryException(e) )
      {
        throw e;
      }
      // otherwise safe to ignore as it will get retried
    }
    client.queueOperation(mainOperationAndData);
  }
};

代码示例来源：origin: net.oschina.zcx7878/cicada.boot-thrift.service

private void repairProcess() throws Exception
{
  if (this._zooKeeper != null && !this._zooKeeper.getState().isAlive())
  {
    this.close();
    Thread.sleep(120 * 1000);
  }
  try
  {
    if (this._zooKeeper == null)
    {
      this.create();
    }
    delExistsNode();
    ZKPaths.mkdirs(this._zooKeeper, this._path);
    this._zooKeeper.create(this._dataPath, new byte[0], Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL);
    this.validateExistPath();
  }
  catch (Exception ex)
  {
    throw ex;
  }
}

代码示例来源：origin: org.apache.airavata/airavata-gfac-service

private void initZkDataStructure() throws Exception {
  /*
  *|/servers
  *    - /gfac
  *        - /gfac-node0 (localhost:2181)
  *|/experiments
   */
  airavataServerHostPort = ServerSettings.getGfacServerHost() + ":" + ServerSettings.getGFacServerPort();
  // create PERSISTENT nodes
  ZKPaths.mkdirs(curatorClient.getZookeeperClient().getZooKeeper(), GFacUtils.getZKGfacServersParentPath());
  ZKPaths.mkdirs(curatorClient.getZookeeperClient().getZooKeeper(), ZkConstants.ZOOKEEPER_EXPERIMENT_NODE);
  // create EPHEMERAL server name node
  String gfacName = ServerSettings.getGFacServerName();
  if (curatorClient.checkExists().forPath(ZKPaths.makePath(GFacUtils.getZKGfacServersParentPath() ,gfacName)) == null) {
    curatorClient.create().withMode(CreateMode.EPHEMERAL).withACL(ZooDefs.Ids.OPEN_ACL_UNSAFE)
        .forPath(ZKPaths.makePath(GFacUtils.getZKGfacServersParentPath(), gfacName));
  }
  curatorClient.setData().withVersion(-1).forPath(ZKPaths.makePath(GFacUtils.getZKGfacServersParentPath(),
      gfacName), airavataServerHostPort.getBytes());
}

代码示例来源：origin: org.apache.airavata/airavata-gfac-service

private void createProcessZKNode(CuratorFramework curatorClient, String gfacServerName,ProcessSubmitEvent event
    ,MessageContext messageContext) throws Exception {
  String processId  = event.getProcessId();
  String token = event.getTokenId();
  String experimentId = event.getExperimentId();
  long deliveryTag = messageContext.getDeliveryTag();
  // create /experiments//{experimentId}{processId} node and set data - serverName, add redelivery listener
  String experimentNodePath = GFacUtils.getExperimentNodePath(experimentId);
  String zkProcessNodePath = ZKPaths.makePath(experimentNodePath, processId);
  ZKPaths.mkdirs(curatorClient.getZookeeperClient().getZooKeeper(), zkProcessNodePath);
  curatorClient.setData().withVersion(-1).forPath(zkProcessNodePath, gfacServerName.getBytes());
  curatorClient.getData().usingWatcher(Factory.getRedeliveryReqeustWatcher(experimentId, processId)).forPath(zkProcessNodePath);
  // create /experiments//{experimentId}{processId}/cancelListener
  String zkProcessCancelPath = ZKPaths.makePath(zkProcessNodePath, ZkConstants.ZOOKEEPER_CANCEL_LISTENER_NODE);
  ZKPaths.mkdirs(curatorClient.getZookeeperClient().getZooKeeper(), zkProcessCancelPath);
  // create /experiments/{experimentId}/{processId}/deliveryTag node and set data - deliveryTag
  String deliveryTagPath = ZKPaths.makePath(zkProcessNodePath, ZkConstants.ZOOKEEPER_DELIVERYTAG_NODE);
  ZKPaths.mkdirs(curatorClient.getZookeeperClient().getZooKeeper(), deliveryTagPath);
  curatorClient.setData().withVersion(-1).forPath(deliveryTagPath, GFacUtils.longToBytes(deliveryTag));
  // create /experiments/{experimentId}/{processId}/token node and set data - token
  String tokenNodePath = ZKPaths.makePath(zkProcessNodePath, ZkConstants.ZOOKEEPER_TOKEN_NODE);
  ZKPaths.mkdirs(curatorClient.getZookeeperClient().getZooKeeper(), tokenNodePath);
  curatorClient.setData().withVersion(-1).forPath(tokenNodePath, token.getBytes());
}