org.apache.bookkeeper.zookeeper.ZooKeeperClient.newBuilder()方法的使用及代码示例-6ren

org.apache.bookkeeper.zookeeper.ZooKeeperClient.newBuilder()方法的使用及代码示例

转载作者：知者更新时间：2024-03-14 03:39:31

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

ZooKeeperClient.newBuilder介绍

暂无

代码示例

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

@SuppressWarnings("deprecation")
public ManagedLedgerFactoryImpl(ClientConfiguration bkClientConfiguration, ManagedLedgerFactoryConfig config)
    throws Exception {
  this(ZooKeeperClient.newBuilder()
      .connectString(bkClientConfiguration.getZkServers())
      .sessionTimeoutMs(bkClientConfiguration.getZkTimeout())
      .build(), bkClientConfiguration, config);
}

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

public void startServer() throws Exception {
  // create a ZooKeeper server(dataDir, dataLogDir, port)
  LOG.debug("Running ZK server");
  // ServerStats.registerAsConcrete();
  ClientBase.setupTestEnv();
  ZkTmpDir = File.createTempFile("zookeeper", "test");
  ZkTmpDir.delete();
  ZkTmpDir.mkdir();
  zks = new ZooKeeperServer(ZkTmpDir, ZkTmpDir, ZooKeeperServer.DEFAULT_TICK_TIME);
  serverFactory = new NIOServerCnxnFactory();
  serverFactory.configure(zkaddr, 100);
  serverFactory.startup(zks);
  boolean b = ClientBase.waitForServerUp(getZooKeeperConnectString(), ClientBase.CONNECTION_TIMEOUT);
  LOG.debug("Server up: " + b);
  // create a zookeeper client
  LOG.debug("Instantiate ZK Client");
  zkc = ZooKeeperClient.newBuilder().connectString(getZooKeeperConnectString()).build();
  // initialize the zk client with values
  zkc.create("/ledgers", new byte[0], Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
  zkc.create("/ledgers/available", new byte[0], Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
}

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

new BoundExponentialBackoffRetryPolicy(sessionTimeoutMs, sessionTimeoutMs, 0) :
    new BoundExponentialBackoffRetryPolicy(sessionTimeoutMs, sessionTimeoutMs, Integer.MAX_VALUE);
zk = org.apache.bookkeeper.zookeeper.ZooKeeperClient.newBuilder()
    .connectString(zooKeeperServers)
    .sessionTimeoutMs(sessionTimeoutMs)

代码示例来源：origin: pravega/pravega

private void initializeZookeeper() throws Exception {
  log.info("Formatting ZooKeeper ...");
  if (this.secureZK) {
    ZKTLSUtils.setSecureZKClientProperties(this.tlsTrustStore, JKSHelper.loadPasswordFrom(this.tLSKeyStorePasswordPath));
  }
  @Cleanup
  val zkc = ZooKeeperClient.newBuilder()
               .connectString(LOOPBACK_ADDRESS.getHostAddress() + ":" + this.zkPort)
               .sessionTimeoutMs(10000)
               .build();
  String znode;
  StringBuilder znodePath = new StringBuilder();
  for (String z : this.ledgersPath.split("/")) {
    znodePath.append(z);
    znode = znodePath.toString();
    if (!znode.isEmpty()) {
      zkc.create(znode, new byte[0], ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
    }
    znodePath.append("/");
  }
  znodePath.append("available");
  zkc.create(znodePath.toString(), new byte[0], ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
}

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

private BKHttpServiceProvider(BookieServer bookieServer,
               AutoRecoveryMain autoRecovery,
               ServerConfiguration serverConf,
               StatsProvider statsProvider)
  throws IOException, KeeperException, InterruptedException, BKException {
  this.bookieServer = bookieServer;
  this.autoRecovery = autoRecovery;
  this.serverConf = serverConf;
  this.statsProvider = statsProvider;
  String zkServers = ZKMetadataDriverBase.resolveZkServers(serverConf);
  this.zk = ZooKeeperClient.newBuilder()
   .connectString(zkServers)
   .sessionTimeoutMs(serverConf.getZkTimeout())
   .build();
  ClientConfiguration clientConfiguration = new ClientConfiguration(serverConf);
  this.bka = new BookKeeperAdmin(clientConfiguration);
  this.executor = Executors.newSingleThreadExecutor(
   new ThreadFactoryBuilder().setNameFormat("BKHttpServiceThread").setDaemon(true).build());
}

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

@SuppressWarnings("deprecation")
private void initializeZookeeper(String zkHost, int zkPort) throws IOException {
  LOG.info("Instantiate ZK Client");
  //initialize the zk client with values
  try (ZooKeeperClient zkc = ZooKeeperClient.newBuilder()
        .connectString(zkHost + ":" + zkPort)
        .sessionTimeoutMs(zkSessionTimeOut)
        .build()) {
    List<Op> multiOps = Lists.newArrayListWithExpectedSize(3);
    String zkLedgersRootPath = ZKMetadataDriverBase.resolveZkLedgersRootPath(baseConf);
    multiOps.add(
      Op.create(zkLedgersRootPath, new byte[0], Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT));
    multiOps.add(
      Op.create(zkLedgersRootPath + "/" + AVAILABLE_NODE,
        new byte[0], Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT));
    multiOps.add(
      Op.create(zkLedgersRootPath + "/" + AVAILABLE_NODE + "/" + READONLY,
        new byte[0], Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT));
    zkc.multi(multiOps);
    // No need to create an entry for each requested bookie anymore as the
    // BookieServers will register themselves with ZooKeeper on startup.
  } catch (KeeperException e) {
    LOG.error("Exception while creating znodes", e);
    throw new IOException("Error creating znodes : ", e);
  } catch (InterruptedException e) {
    Thread.currentThread().interrupt();
    LOG.error("Interrupted while creating znodes", e);
    throw new IOException("Error creating znodes : ", e);
  }
}

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

@Override
  public CompletableFuture<ZooKeeper> create(String serverList, SessionType sessionType, int zkSessionTimeoutMillis) {
    CompletableFuture<ZooKeeper> future = new CompletableFuture<>();

    executor.execute(safeRun(() -> {
      try {
        ZooKeeper zk = ZooKeeperClient.newBuilder().connectString(serverList)
            .sessionTimeoutMs(zkSessionTimeoutMillis)
            .connectRetryPolicy(new BoundExponentialBackoffRetryPolicy(zkSessionTimeoutMillis,
                zkSessionTimeoutMillis, 0))
            .build();

        if (zk.getState() == States.CONNECTEDREADONLY && sessionType != SessionType.AllowReadOnly) {
          future.completeExceptionally(new IllegalStateException("Cannot use a read-only session"));
        }

        log.info("ZooKeeper session established: {}", zk);
        future.complete(zk);
      } catch (IOException | KeeperException | InterruptedException exception) {
        log.error("Failed to establish ZooKeeper session: {}", exception.getMessage());
        future.completeExceptionally(exception);
      }
    }, throwable -> {
      future.completeExceptionally(throwable);
    }));

    return future;
  }
}

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

@VisibleForTesting
static ZooKeeperClient createConnectedZooKeeperClient(
    String connectString, int sessionTimeoutMs, Set<Watcher> childWatchers,
    RetryPolicy operationRetryPolicy)
        throws KeeperException, InterruptedException, IOException {
  return ZooKeeperClient.newBuilder()
      .connectString(connectString)
      .sessionTimeoutMs(sessionTimeoutMs)
      .watchers(childWatchers)
      .operationRetryPolicy(operationRetryPolicy)
      .build();
}

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

@Override
  int runCmd(CommandLine cmdLine) throws Exception {
    ZooKeeper zk = null;
    try {
      String metadataServiceUri = bkConf.getMetadataServiceUri();
      String zkServers = ZKMetadataDriverBase.getZKServersFromServiceUri(URI.create(metadataServiceUri));
      zk = ZooKeeperClient.newBuilder()
          .connectString(zkServers)
          .sessionTimeoutMs(bkConf.getZkTimeout())
          .build();
      BookieSocketAddress bookieId = AuditorElector.getCurrentAuditor(bkConf, zk);
      if (bookieId == null) {
        LOG.info("No auditor elected");
        return -1;
      }
      LOG.info("Auditor: " + getBookieSocketAddrStringRepresentation(bookieId));
    } finally {
      if (zk != null) {
        zk.close();
      }
    }
    return 0;
  }
}

代码示例来源：origin: org.apache.pulsar/managed-ledger-original

@SuppressWarnings("deprecation")
public ManagedLedgerFactoryImpl(ClientConfiguration bkClientConfiguration, ManagedLedgerFactoryConfig config)
    throws Exception {
  this(ZooKeeperClient.newBuilder()
      .connectString(bkClientConfiguration.getZkServers())
      .sessionTimeoutMs(bkClientConfiguration.getZkTimeout())
      .build(), bkClientConfiguration, config);
}

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

- lastOverReplicatedLedgerGcTimeMillis > gcOverReplicatedLedgerIntervalMillis);
if (checkOverreplicatedLedgers) {
  zk = ZooKeeperClient.newBuilder().connectString(zkServers)
      .sessionTimeoutMs(conf.getZkTimeout()).build();

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

this.zk = ZooKeeperClient.newBuilder()
  .connectString(zkServers)
  .sessionTimeoutMs(conf.getZkTimeout())

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

private ZooKeeperCache getAndSetZkCache(Configuration conf) {
  ZooKeeperCache zkCache = null;
  if (conf.getProperty(ZooKeeperCache.ZK_CACHE_INSTANCE) != null) {
    zkCache = (ZooKeeperCache) conf.getProperty(ZooKeeperCache.ZK_CACHE_INSTANCE);
  } else {
    int zkTimeout;
    String zkServers;
    if (conf instanceof ClientConfiguration) {
      zkTimeout = ((ClientConfiguration) conf).getZkTimeout();
      zkServers = ((ClientConfiguration) conf).getZkServers();
      try {
        ZooKeeper zkClient = ZooKeeperClient.newBuilder().connectString(zkServers)
            .sessionTimeoutMs(zkTimeout).build();
        zkCache = new ZooKeeperCache(zkClient) {
        };
        conf.addProperty(ZooKeeperCache.ZK_CACHE_INSTANCE, zkCache);
      } catch (Exception e) {
        LOG.error("Error creating zookeeper client", e);
      }
    } else {
      LOG.error("No zk configurations available");
    }
  }
  return zkCache;
}

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

private ZooKeeperDataCache<BookiesRackConfiguration> getAndSetZkCache(Configuration conf) {
  ZooKeeperCache zkCache = null;
  if (conf.getProperty(ZooKeeperCache.ZK_CACHE_INSTANCE) != null) {
    zkCache = (ZooKeeperCache) conf.getProperty(ZooKeeperCache.ZK_CACHE_INSTANCE);
  } else {
    int zkTimeout;
    String zkServers;
    if (conf instanceof ClientConfiguration) {
      zkTimeout = ((ClientConfiguration) conf).getZkTimeout();
      zkServers = ((ClientConfiguration) conf).getZkServers();
      try {
        ZooKeeper zkClient = ZooKeeperClient.newBuilder().connectString(zkServers)
            .sessionTimeoutMs(zkTimeout).build();
        zkCache = new ZooKeeperCache(zkClient) {
        };
        conf.addProperty(ZooKeeperCache.ZK_CACHE_INSTANCE, zkCache);
      } catch (Exception e) {
        LOG.error("Error creating zookeeper client", e);
      }
    } else {
      LOG.error("No zk configurations available");
    }
  }
  ZooKeeperDataCache<BookiesRackConfiguration> zkDataCache = getZkBookieRackMappingCache(
      zkCache);
  if (zkDataCache != null) {
    zkDataCache.registerListener(this);
  }
  return zkDataCache;
}

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

? new BoundExponentialBackoffRetryPolicy(sessionTimeoutMs, sessionTimeoutMs, 0) :
    new BoundExponentialBackoffRetryPolicy(sessionTimeoutMs, sessionTimeoutMs, Integer.MAX_VALUE);
zk = org.apache.bookkeeper.zookeeper.ZooKeeperClient.newBuilder()
    .connectString(zooKeeperServers)
    .sessionTimeoutMs(sessionTimeoutMs)

Ruby 方法() 方法
我想了解 Ruby 方法 methods() 是如何工作的。我尝试使用“ruby 方法”在 Google 上搜索，但这不是我需要的。我也看过 ruby-doc.org，但我没有找到这种方法。
VBS教程：方法-Test 方法
Test 方法对指定的字符串执行一个正则表达式搜索，并返回一个 Boolean 值指示是否找到匹配的模式。 object.Test(string) 参数 object 必选项。总是一个
VBS教程：方法-Replace 方法
Replace 方法替换在正则表达式查找中找到的文本。 object.Replace(string1, string2) 参数 object 必选项。总是一个 RegExp 对象的名称。
VBS教程：方法-Raise 方法
Raise 方法生成运行时错误 object.Raise(number, source, description, helpfile, helpcontext) 参数 object 应为
VBS教程：方法-Execute 方法
Execute 方法对指定的字符串执行正则表达式搜索。 object.Execute(string) 参数 object 必选项。总是一个 RegExp 对象的名称。 string
VBS教程：方法-Clear 方法
Clear 方法清除 Err 对象的所有属性设置。 object.Clear object 应为 Err 对象的名称。说明在错误处理后，使用 Clear 显式地清除 Err 对象。此
VBS教程：方法-CopyFile 方法
CopyFile 方法将一个或多个文件从某位置复制到另一位置。 object.CopyFile source, destination[, overwrite] 参数 object 必选
VBS教程：方法-Copy 方法
Copy 方法将指定的文件或文件夹从某位置复制到另一位置。 object.Copy destination[, overwrite] 参数 object 必选项。应为 File 或 F
VBS教程：方法-Close 方法
Close 方法关闭打开的 TextStream 文件。 object.Close object 应为 TextStream 对象的名称。说明下面例子举例说明如何使用 Close 方
VBS教程：方法-BuildPath 方法
BuildPath 方法向现有路径后添加名称。 object.BuildPath(path, name) 参数 object 必选项。应为 FileSystemObject 对象的名称
VBS教程：方法-GetFolder 方法
GetFolder 方法返回与指定的路径中某文件夹相应的 Folder 对象。 object.GetFolder(folderspec) 参数 object 必选项。应为 FileSy
VBS教程：方法-GetFileName 方法
GetFileName 方法返回指定路径（不是指定驱动器路径部分）的最后一个文件或文件夹。 object.GetFileName(pathspec) 参数 object 必选项。应为
VBS教程：方法-GetFile 方法
GetFile 方法返回与指定路径中某文件相应的 File 对象。 object.GetFile(filespec) 参数 object 必选项。应为 FileSystemObject
VBS教程：方法-GetExtensionName 方法
GetExtensionName 方法返回字符串，该字符串包含路径最后一个组成部分的扩展名。 object.GetExtensionName(path) 参数 object 必选项。应
VBS教程：方法-GetDriveName 方法
GetDriveName 方法返回包含指定路径中驱动器名的字符串。 object.GetDriveName(path) 参数 object 必选项。应为 FileSystemObjec
VBS教程：方法-GetDrive 方法
GetDrive 方法返回与指定的路径中驱动器相对应的 Drive 对象。 object.GetDrive drivespec 参数 object 必选项。应为 FileSystemO
VBS教程：方法-GetBaseName 方法
GetBaseName 方法返回字符串，其中包含文件的基本名 (不带扩展名), 或者提供的路径说明中的文件夹。 object.GetBaseName(path) 参数 object 必
VBS教程：方法-GetAbsolutePathName 方法
GetAbsolutePathName 方法从提供的指定路径中返回完整且含义明确的路径。 object.GetAbsolutePathName(pathspec) 参数 object
VBS教程：方法-FolderExists 方法
FolderExists 方法如果指定的文件夹存在，则返回 True；否则返回 False。 object.FolderExists(folderspec) 参数 object 必选项
VBS教程：方法-FileExists 方法
FileExists 方法如果指定的文件存在返回 True；否则返回 False。 object.FileExists(filespec) 参数 object 必选项。应为 FileS

知者

个人简介

我是一名优秀的程序员,十分优秀！

作者热门文章

滴滴打车优惠券免费领取

全站热门文章

首页

博学

6Ren·AI

商城

org.apache.bookkeeper.zookeeper.ZooKeeperClient.newBuilder()方法的使用及代码示例

ZooKeeperClient.newBuilder介绍

代码示例