org.apache.bookkeeper.util.ZkUtils类的使用及代码示例

x33g5p2x  于2022-02-05 转载在 其他  
字(10.1k)|赞(0)|评价(0)|浏览(123)

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

ZkUtils介绍

[英]Provided utilites for zookeeper access, etc.
[中]提供动物园管理员访问等实用工具。

代码示例

代码示例来源：origin: twitter/distributedlog

private void initializePool() throws IOException {
  try {
    List<String> allocators;
    try {
      allocators = zkc.get().getChildren(poolPath, false);
    } catch (KeeperException.NoNodeException e) {
      logger.info("Allocator Pool {} doesn't exist. Creating it.", poolPath);
      ZkUtils.createFullPathOptimistic(zkc.get(), poolPath, new byte[0], zkc.getDefaultACL(),
          CreateMode.PERSISTENT);
      allocators = zkc.get().getChildren(poolPath, false);
    }
    if (null == allocators) {
      allocators = new ArrayList<String>();
    }
    if (allocators.size() < corePoolSize) {
      createAllocators(corePoolSize - allocators.size());
      allocators = zkc.get().getChildren(poolPath, false);
    }
    initializeAllocators(allocators);
  } catch (InterruptedException ie) {
    throw new DLInterruptedException("Interrupted when ensuring " + poolPath + " created : ", ie);
  } catch (KeeperException ke) {
    throw new IOException("Encountered zookeeper exception when initializing pool " + poolPath + " : ", ke);
  }
}

代码示例来源：origin: twitter/distributedlog

private void createDefaultAccessControlEntryIfNeeded(final Promise<ZKAccessControl> promise) {
  ZooKeeper zk;
  try {
    zk = zkc.get();
  } catch (ZooKeeperClient.ZooKeeperConnectionException e) {
    promise.setException(e);
    return;
  } catch (InterruptedException e) {
    promise.setException(e);
    return;
  }
  ZkUtils.asyncCreateFullPathOptimistic(zk, zkRootPath, new byte[0], zkc.getDefaultACL(),
      CreateMode.PERSISTENT, new AsyncCallback.StringCallback() {
    @Override
    public void processResult(int rc, String path, Object ctx, String name) {
      if (KeeperException.Code.OK.intValue() == rc) {
        logger.info("Created zk path {} for default ACL.", zkRootPath);
        fetchDefaultAccessControlEntry(promise);
      } else {
        promise.setException(KeeperException.create(KeeperException.Code.get(rc)));
      }
    }
  }, null);
}

代码示例来源：origin: org.apache.bookkeeper/bookkeeper-server

List<ACL> zkAcls = ZkUtils.getACLs(conf);
ZkUtils.asyncCreateFullPathOptimistic(zk, ledgerPath, data, zkAcls,
                   CreateMode.PERSISTENT, scb, null);
return promise;

代码示例来源：origin: org.apache.bookkeeper/bookkeeper-server

@Override
public CompletableFuture<Void> markLedgerUnderreplicatedAsync(long ledgerId, Collection<String> missingReplicas) {
  if (LOG.isDebugEnabled()) {
    LOG.debug("markLedgerUnderreplicated(ledgerId={}, missingReplica={})", ledgerId, missingReplicas);
  }
  final List<ACL> zkAcls = ZkUtils.getACLs(conf);
  final String znode = getUrLedgerZnode(ledgerId);
  final CompletableFuture<Void> createFuture = new CompletableFuture<>();
  tryMarkLedgerUnderreplicatedAsync(znode, missingReplicas, zkAcls, createFuture);
  return createFuture;
}

代码示例来源：origin: org.apache.bookkeeper/bookkeeper-server

final AsyncCallback.VoidCallback finalCb, final Object ctx,
  final int successRc, final int failureRc) {
ZkUtils.getChildrenInSingleNode(zk, path, new GenericCallback<List<String>>() {
  @Override
  public void operationComplete(int rc, List<String> ledgerNodes) {

代码示例来源：origin: org.apache.bookkeeper/bookkeeper-server

public static void deleteFullPathOptimistic(ZooKeeper zkc, String path, int znodeVersion)
    throws KeeperException, InterruptedException {
  final CountDownLatch latch = new CountDownLatch(1);
  final AtomicInteger rc = new AtomicInteger(Code.OK.intValue());
  asyncDeleteFullPathOptimistic(zkc, path, znodeVersion, new VoidCallback() {
    @Override
    public void processResult(int rc2, String path, Object ctx) {
      rc.set(rc2);
      latch.countDown();
    }
  }, path);
  latch.await();
  if (rc.get() != Code.OK.intValue()) {
    throw KeeperException.create(Code.get(rc.get()));
  }
}

代码示例来源：origin: org.apache.bookkeeper/bookkeeper-server

@Override
public LedgerIdGenerator newLedgerIdGenerator() {
  List<ACL> zkAcls = ZkUtils.getACLs(conf);
  String ledgersRootPath = ZKMetadataDriverBase.resolveZkLedgersRootPath(conf);
  return new ZkLedgerIdGenerator(zk, ledgersRootPath, null, zkAcls);
}

代码示例来源：origin: org.apache.bookkeeper/bookkeeper-server

/**
 * Returns all children with path as a parent.  If path is non-existent,
 * returns an empty list anyway (after all, there are no children there).
 * Maps all exceptions (other than NoNode) to IOException in keeping with
 * LedgerRangeIterator.
 *
 * @param path
 * @return Iterator into set of all children with path as a parent
 * @throws IOException
 */
List<String> getChildrenAt(String path) throws IOException {
  try {
    List<String> children = ZkUtils.getChildrenInSingleNode(zk, path);
    Collections.sort(children);
    return children;
  } catch (KeeperException.NoNodeException e) {
    if (LOG.isDebugEnabled()) {
      LOG.debug("NoNodeException at path {}, assumed race with deletion", path);
    }
    return new ArrayList<>();
  } catch (InterruptedException ie) {
    Thread.currentThread().interrupt();
    throw new IOException("Interrupted while reading ledgers at path " + path, ie);
  }
}

代码示例来源：origin: org.apache.bookkeeper/bookkeeper-server

@Override
  public void processResult(int rc, String path, Object ctx) {
    if (rc == Code.OK.intValue()) {
      String parent = new File(originalPath).getParent().replace("\\", "/");
      asyncDeleteFullPathOptimistic(zk, parent, -1, callback, leafNodePath);
    } else {
      if (path.equals(leafNodePath)) {
        callback.processResult(rc, path, leafNodePath);
      } else {
        callback.processResult(Code.OK.intValue(), path, leafNodePath);
      }
    }
  }
}, leafNodePath);

代码示例来源：origin: apache/pulsar

/**
 * Start cluster
 *
 * @throws Exception
 */
protected void startBookKeeper() throws Exception {
  zkc = MockZooKeeper.newInstance();
  for (int i = 0; i < numBookies; i++) {
    ZkUtils.createFullPathOptimistic(zkc, "/ledgers/available/192.168.1.1:" + (5000 + i), "".getBytes(), null,
        null);
  }
  zkc.create("/ledgers/LAYOUT", "1\nflat:1".getBytes(), null, null);
  bkc = new PulsarMockBookKeeper(zkc, executor.chooseThread(this));
}

代码示例来源：origin: org.apache.bookkeeper/bookkeeper-server

private void createLongLedgerIdPathAndGenerateLongLedgerId(final GenericCallback<Long> cb, String createPath) {
  ZkUtils.asyncCreateFullPathOptimistic(zk, ledgerIdGenPath, new byte[0], Ids.OPEN_ACL_UNSAFE,
      CreateMode.PERSISTENT, new StringCallback() {
        @Override
        public void processResult(int rc, String path, Object ctx, String name) {
          try {
            setLedgerIdGenPathStatus(HighOrderLedgerIdGenPathStatus.PRESENT);
            generateLongLedgerId(cb);
          } catch (KeeperException e) {
            LOG.error("Failed to create long ledger ID path", e);
            setLedgerIdGenPathStatus(HighOrderLedgerIdGenPathStatus.UNKNOWN);
            cb.operationComplete(BKException.Code.ZKException, null);
          } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
            LOG.error("Failed to create long ledger ID path", e);
            setLedgerIdGenPathStatus(HighOrderLedgerIdGenPathStatus.UNKNOWN);
            cb.operationComplete(BKException.Code.InterruptedException, null);
          } catch (IOException e) {
            LOG.error("Failed to create long ledger ID path", e);
            setLedgerIdGenPathStatus(HighOrderLedgerIdGenPathStatus.UNKNOWN);
            cb.operationComplete(BKException.Code.IllegalOpException, null);
          }
        }
      }, null);
}

代码示例来源：origin: org.apache.bookkeeper/bookkeeper-server

@Override
public LedgerIdGenerator newLedgerIdGenerator() {
  List<ACL> zkAcls = ZkUtils.getACLs(conf);
  return new ZkLedgerIdGenerator(
    zk,
    ZKMetadataDriverBase.resolveZkLedgersRootPath(conf),
    LegacyHierarchicalLedgerManager.IDGEN_ZNODE,
    zkAcls);
}

代码示例来源：origin: org.apache.bookkeeper/bookkeeper-server

private synchronized void preload() throws IOException {
  if (nextRange != null) {
    return;
  }
  Set<Long> zkActiveLedgers = null;
  try {
    zkActiveLedgers = ledgerListToSet(
        ZkUtils.getChildrenInSingleNode(zk, ledgerRootPath), ledgerRootPath);
    nextRange = new LedgerRange(zkActiveLedgers);
  } catch (KeeperException.NoNodeException e) {
    throw new IOException("Path does not exist: " + ledgerRootPath, e);
  } catch (InterruptedException ie) {
    Thread.currentThread().interrupt();
    throw new IOException("Error when get child nodes from zk", ie);
  }
}

代码示例来源：origin: org.apache.bookkeeper/bookkeeper-server

ZkUtils.asyncDeleteFullPathOptimistic(zk, ledgerZnodePath, znodeVersion, callbackForDelete,
      ledgerZnodePath);
} else {

代码示例来源：origin: org.apache.pulsar/pulsar-broker

private static void createZPathIfNotExists(final ZooKeeper zkClient, final String path) throws Exception {
  if (zkClient.exists(path, false) == null) {
    try {
      ZkUtils.createFullPathOptimistic(zkClient, path, new byte[0], ZooDefs.Ids.OPEN_ACL_UNSAFE,
          CreateMode.PERSISTENT);
    } catch (KeeperException.NodeExistsException e) {
      // Ignore if already exists.
    }
  }
}

代码示例来源：origin: org.apache.bookkeeper/bookkeeper-server

public static void generateLedgerIdImpl(final GenericCallback<Long> cb, ZooKeeper zk, String ledgerPrefix,
    List<ACL> zkAcls) {
  ZkUtils.asyncCreateFullPathOptimistic(zk, ledgerPrefix, new byte[0], zkAcls,
      CreateMode.EPHEMERAL_SEQUENTIAL,
      new StringCallback() {

代码示例来源：origin: org.apache.bookkeeper/bookkeeper-server

@Override
public LedgerIdGenerator newLedgerIdGenerator() {
  List<ACL> zkAcls = ZkUtils.getACLs(conf);
  return new ZkLedgerIdGenerator(
    zk,
    ZKMetadataDriverBase.resolveZkLedgersRootPath(conf),
    MsLedgerManager.IDGEN_ZNODE,
    zkAcls);
}

代码示例来源：origin: org.apache.bookkeeper/bookkeeper-server

List<String> ledgerNodes = null;
try {
  ledgerNodes = ZkUtils.getChildrenInSingleNode(zk, nodePath);
} catch (KeeperException.NoNodeException e) {

代码示例来源：origin: com.yahoo.pulsar/pulsar-broker

private static void createZPathIfNotExists(final ZooKeeper zkClient, final String path) throws Exception {
  if (zkClient.exists(path, false) == null) {
    try {
      ZkUtils.createFullPathOptimistic(zkClient, path, new byte[0], ZooDefs.Ids.OPEN_ACL_UNSAFE,
          CreateMode.PERSISTENT);
    } catch (KeeperException.NodeExistsException e) {
      // Ignore if already exists.
    }
  }
}

代码示例来源：origin: org.apache.distributedlog/distributedlog-core

private void createDefaultAccessControlEntryIfNeeded(final CompletableFuture<ZKAccessControl> promise) {
  ZooKeeper zk;
  try {
    zk = zkc.get();
  } catch (ZooKeeperClient.ZooKeeperConnectionException e) {
    promise.completeExceptionally(e);
    return;
  } catch (InterruptedException e) {
    Thread.currentThread().interrupt();
    promise.completeExceptionally(e);
    return;
  }
  ZkUtils.asyncCreateFullPathOptimistic(zk, zkRootPath, new byte[0], zkc.getDefaultACL(),
      CreateMode.PERSISTENT, new AsyncCallback.StringCallback() {
    @Override
    public void processResult(int rc, String path, Object ctx, String name) {
      if (KeeperException.Code.OK.intValue() == rc) {
        logger.info("Created zk path {} for default ACL.", zkRootPath);
        fetchDefaultAccessControlEntry(promise);
      } else {
        promise.completeExceptionally(KeeperException.create(KeeperException.Code.get(rc)));
      }
    }
  }, null);
}

内容来源于网络，如有侵权，请联系作者删除！

ZkUtils

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com