- 使用 Spring Initializr 创建 Spring Boot 应用程序
- 在Spring Boot中配置Cassandra
- 在 Spring Boot 上配置 Tomcat 连接池
- 将Camel消息路由到嵌入WildFly的Artemis上
本文整理了Java中org.apache.bookkeeper.zookeeper.ZooKeeperClient.newBuilder()
方法的一些代码示例,展示了ZooKeeperClient.newBuilder()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZooKeeperClient.newBuilder()
方法的具体详情如下:
包路径:org.apache.bookkeeper.zookeeper.ZooKeeperClient
类名称: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)
函数newBuilder()有什么作用?在 OkHttp 中确实如此。它是创建一个全新的客户端还是调整现有的客户端给定 here .在这种情况下,“调整”到底意味着什么? 最佳答案 它创建一个浅拷贝,
你能帮我模拟 StorageOptions.newBuilder() 要模拟的代码: StorageOptions.newBuilder.setProjectId("Test").build().ge
我想测试 protobuf 的工作原理并将其实现到我的示例项目中。基本上我刚刚将 .proto 编译为 .java 并将这个 java 类复制到我的项目源中。但是每当我尝试访问此类的内部方法时,IDE
我正在尝试使用 Stash 插件的代码片段,但编译器一直给我一个我似乎无法解决的错误。它使用 com.google.common.cache.Cache (Guava) static final R
关于 javax.ws.rs.client.ClientBuilder,我已经阅读了 JavaDoc和 Jersey Documentation , 但我仍然不清楚什么时候应该使用 newClient
要从现有 URL 创建新的 HttpUrl.Builder 实例,我使用 HttpUrl.newBuilder(String) : new HttpUrl().build().newBuilder(s
我是来自 google 的 Protocol Buffer 的新手,所以我尝试了 Java 教程并且一切顺利,直到我尝试创建协议(protocol)类的实例。所以我试着制作自己的原型(prototyp
本文整理了Java中com.twitter.distributedlog.ZooKeeperClientBuilder.newBuilder()方法的一些代码示例,展示了ZooKeeperClient
在 Kotlin 中使用 gRPC API 执行此操作。这两者有区别吗? ApiRequest.newBuilder().build() 和 ApiRequest.getDefaultInstance
看着 val sb = Seq.newBuilder[Int] println(sb.getClass.getName) sb += 1 sb += 2 val s = sb.result() pri
我正在尝试实现一个遵循相同习惯用法的新集合类型作为标准库,但我无法弄清楚如何处理 Builder力学。我已经阅读了优秀的 "Architecture of ScalaCollections" docp
本文整理了Java中org.apache.bookkeeper.zookeeper.ZooKeeperClient.newBuilder()方法的一些代码示例,展示了ZooKeeperClient.n
本文整理了Java中com.twitter.distributedlog.zk.ZKWatcherManager.newBuilder()方法的一些代码示例,展示了ZKWatcherManager.n
我正在使用以下 Go 代码在我的 dynamoDB 表中仅获取一个注册表,但它返回了所有注册表: condition1 := expression.Name("id").Equal(express
本文整理了Java中com.google.cloud.compute.v1.ZoneSettings.newBuilder()方法的一些代码示例,展示了ZoneSettings.newBuilder(
本文整理了Java中org.apache.logging.log4j.core.appender.WriterAppender.newBuilder()方法的一些代码示例,展示了WriterAppen
我正在尝试使用 Guava 缓存库创建缓存。我的主要要求之一是我想在 CacheLoader.load(..) 函数之后设置缓存过期,而不是我在网络上遇到的大多数示例,如下所示。 LoadingCac
我尝试在程序中使用 Unirest,但不断收到此错误 java.lang.NoSuchMethodError: com.google.gson.Gson.newBuilder()Lcom/google
我是一名优秀的程序员,十分优秀!