- 使用 Spring Initializr 创建 Spring Boot 应用程序
- 在Spring Boot中配置Cassandra
- 在 Spring Boot 上配置 Tomcat 连接池
- 将Camel消息路由到嵌入WildFly的Artemis上
本文整理了Java中com.twitter.distributedlog.ZooKeeperClientBuilder.sessionTimeoutMs()
方法的一些代码示例,展示了ZooKeeperClientBuilder.sessionTimeoutMs()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZooKeeperClientBuilder.sessionTimeoutMs()
方法的具体详情如下:
包路径:com.twitter.distributedlog.ZooKeeperClientBuilder
类名称:ZooKeeperClientBuilder
方法名:sessionTimeoutMs
[英]Set zookeeper session timeout in milliseconds.
[中]以毫秒为单位设置zookeeper会话超时。
代码示例来源:origin: twitter/distributedlog
public void create(URI uri) throws IOException {
DistributedLogConfiguration conf = new DistributedLogConfiguration();
ZooKeeperClient zkc = ZooKeeperClientBuilder.newBuilder()
.sessionTimeoutMs(conf.getZKSessionTimeoutMilliseconds())
.retryThreadCount(conf.getZKClientNumberRetryThreads())
.requestRateLimit(conf.getZKRequestRateLimit())
.zkAclId(conf.getZkAclId())
.uri(uri)
.build();
byte[] data = serialize();
try {
Utils.zkCreateFullPathOptimistic(zkc, uri.getPath(), data,
zkc.getDefaultACL(), CreateMode.PERSISTENT);
} catch (KeeperException e) {
throw new IOException("Fail to write dl metadata " + new String(data, UTF_8)
+ " to uri " + uri, e);
} catch (InterruptedException e) {
throw new IOException("Interrupted when writing dl metadata " + new String(data, UTF_8)
+ " to uri " + uri, e);
} finally {
zkc.close();
}
}
代码示例来源:origin: twitter/distributedlog
public void update(URI uri) throws IOException {
DistributedLogConfiguration conf = new DistributedLogConfiguration();
ZooKeeperClient zkc = ZooKeeperClientBuilder.newBuilder()
.sessionTimeoutMs(conf.getZKSessionTimeoutMilliseconds())
.retryThreadCount(conf.getZKClientNumberRetryThreads())
.requestRateLimit(conf.getZKRequestRateLimit())
.zkAclId(conf.getZkAclId())
.uri(uri)
.build();
byte[] data = serialize();
try {
zkc.get().setData(uri.getPath(), data, -1);
} catch (KeeperException e) {
throw new IOException("Fail to update dl metadata " + new String(data, UTF_8)
+ " to uri " + uri, e);
} catch (InterruptedException e) {
throw new IOException("Interrupted when updating dl metadata "
+ new String(data, UTF_8) + " to uri " + uri, e);
} finally {
zkc.close();
}
}
代码示例来源:origin: twitter/distributedlog
public static void unbind(URI uri) throws IOException {
DistributedLogConfiguration conf = new DistributedLogConfiguration();
ZooKeeperClient zkc = ZooKeeperClientBuilder.newBuilder()
.sessionTimeoutMs(conf.getZKSessionTimeoutMilliseconds())
.retryThreadCount(conf.getZKClientNumberRetryThreads())
.requestRateLimit(conf.getZKRequestRateLimit())
.zkAclId(conf.getZkAclId())
.uri(uri)
.build();
byte[] data = new byte[0];
try {
zkc.get().setData(uri.getPath(), data, -1);
} catch (KeeperException ke) {
throw new IOException("Fail to unbound dl metadata on uri " + uri, ke);
} catch (InterruptedException ie) {
throw new IOException("Interrupted when unbinding dl metadata on uri " + uri, ie);
} finally {
zkc.close();
}
}
代码示例来源:origin: twitter/distributedlog
/**
* Return a zookeeper client builder for testing.
*
* @return a zookeeper client builder
*/
public static ZooKeeperClientBuilder newBuilder() {
return ZooKeeperClientBuilder.newBuilder()
.retryPolicy(RetryPolicyUtils.DEFAULT_INFINITE_RETRY_POLICY)
.connectionTimeoutMs(10000)
.sessionTimeoutMs(60000)
.zkAclId(null)
.statsLogger(NullStatsLogger.INSTANCE);
}
代码示例来源:origin: twitter/distributedlog
@Before
public void setup() throws Exception {
zkc = TestZooKeeperClientBuilder.newBuilder()
.uri(createURI("/"))
.sessionTimeoutMs(10000)
.build();
resolver = new ZkMetadataResolver(zkc);
}
代码示例来源:origin: twitter/distributedlog
@Before
public void setup() throws Exception {
zkc = TestZooKeeperClientBuilder.newBuilder()
.name("zkc")
.uri(DLMTestUtil.createDLMURI(zkPort, "/"))
.sessionTimeoutMs(sessionTimeoutMs)
.build();
}
代码示例来源:origin: twitter/distributedlog
@Before
public void setup() throws Exception {
zkc = TestZooKeeperClientBuilder.newBuilder()
.name("zkc")
.uri(DLMTestUtil.createDLMURI(zkPort, "/"))
.sessionTimeoutMs(sessionTimeoutMs)
.build();
}
代码示例来源:origin: twitter/distributedlog
private ZooKeeperClientBuilder clientBuilder(int sessionTimeoutMs)
throws Exception {
return ZooKeeperClientBuilder.newBuilder()
.name("zkc")
.uri(DLMTestUtil.createDLMURI(zkPort, "/"))
.sessionTimeoutMs(sessionTimeoutMs)
.zkServers(zkServers)
.retryPolicy(new BoundExponentialBackoffRetryPolicy(100, 200, 2));
}
代码示例来源:origin: twitter/distributedlog
@Before
public void setup() throws Exception {
zkc = TestZooKeeperClientBuilder.newBuilder()
.uri(createDLMURI("/"))
.sessionTimeoutMs(zkSessionTimeoutMs)
.build();
scheduler = OrderedScheduler.newBuilder()
.name("test-zk-namespace-watcher")
.corePoolSize(1)
.build();
}
代码示例来源:origin: twitter/distributedlog
public SimpleBookKeeperClient(DistributedLogConfiguration conf, URI uri) {
try {
zkc = ZooKeeperClientBuilder.newBuilder()
.sessionTimeoutMs(conf.getZKSessionTimeoutMilliseconds())
.zkAclId(conf.getZkAclId())
.uri(uri)
.build();
BKDLConfig bkdlConfig = BKDLConfig.resolveDLConfig(zkc, uri);
BKDLConfig.propagateConfiguration(bkdlConfig, conf);
bkc = BookKeeperClientBuilder.newBuilder()
.zkc(zkc)
.dlConfig(conf)
.ledgersPath(bkdlConfig.getBkLedgersPath())
.name("dlog")
.build();
} catch (Exception e) {
close();
}
}
public BookKeeperClient client() {
代码示例来源:origin: twitter/distributedlog
private static ZooKeeperClientBuilder createBKZKClientBuilder(String zkcName,
DistributedLogConfiguration conf,
String zkServers,
StatsLogger statsLogger) {
RetryPolicy retryPolicy = null;
if (conf.getZKNumRetries() > 0) {
retryPolicy = new BoundExponentialBackoffRetryPolicy(
conf.getBKClientZKRetryBackoffStartMillis(),
conf.getBKClientZKRetryBackoffMaxMillis(),
conf.getBKClientZKNumRetries());
}
ZooKeeperClientBuilder builder = ZooKeeperClientBuilder.newBuilder()
.name(zkcName)
.sessionTimeoutMs(conf.getBKClientZKSessionTimeoutMilliSeconds())
.retryThreadCount(conf.getZKClientNumberRetryThreads())
.requestRateLimit(conf.getBKClientZKRequestRateLimit())
.zkServers(zkServers)
.retryPolicy(retryPolicy)
.statsLogger(statsLogger)
.zkAclId(conf.getZkAclId());
LOG.info("Created shared zooKeeper client builder {}: zkServers = {}, numRetries = {}, sessionTimeout = {}, retryBackoff = {},"
+ " maxRetryBackoff = {}, zkAclId = {}.", new Object[] { zkcName, zkServers, conf.getBKClientZKNumRetries(),
conf.getBKClientZKSessionTimeoutMilliSeconds(), conf.getBKClientZKRetryBackoffStartMillis(),
conf.getBKClientZKRetryBackoffMaxMillis(), conf.getZkAclId() });
return builder;
}
代码示例来源:origin: twitter/distributedlog
private static ZooKeeperClientBuilder createDLZKClientBuilder(String zkcName,
DistributedLogConfiguration conf,
String zkServers,
StatsLogger statsLogger) {
RetryPolicy retryPolicy = null;
if (conf.getZKNumRetries() > 0) {
retryPolicy = new BoundExponentialBackoffRetryPolicy(
conf.getZKRetryBackoffStartMillis(),
conf.getZKRetryBackoffMaxMillis(), conf.getZKNumRetries());
}
ZooKeeperClientBuilder builder = ZooKeeperClientBuilder.newBuilder()
.name(zkcName)
.sessionTimeoutMs(conf.getZKSessionTimeoutMilliseconds())
.retryThreadCount(conf.getZKClientNumberRetryThreads())
.requestRateLimit(conf.getZKRequestRateLimit())
.zkServers(zkServers)
.retryPolicy(retryPolicy)
.statsLogger(statsLogger)
.zkAclId(conf.getZkAclId());
LOG.info("Created shared zooKeeper client builder {}: zkServers = {}, numRetries = {}, sessionTimeout = {}, retryBackoff = {},"
+ " maxRetryBackoff = {}, zkAclId = {}.", new Object[] { zkcName, zkServers, conf.getZKNumRetries(),
conf.getZKSessionTimeoutMilliseconds(), conf.getZKRetryBackoffStartMillis(),
conf.getZKRetryBackoffMaxMillis(), conf.getZkAclId() });
return builder;
}
代码示例来源:origin: twitter/distributedlog
@Before
public void setup() throws Exception {
scheduler = OrderedScheduler.newBuilder()
.name("test-logsegment-metadata-store-updater")
.corePoolSize(1)
.build();
zkc = TestZooKeeperClientBuilder.newBuilder()
.uri(createURI("/"))
.sessionTimeoutMs(10000)
.build();
metadataStore = new ZKLogSegmentMetadataStore(conf, zkc, scheduler);
}
代码示例来源:origin: twitter/distributedlog
@Before
public void setup() throws Exception {
zkc = ZooKeeperClientBuilder.newBuilder()
.name("zkc")
.uri(createDLMURI("/"))
.sessionTimeoutMs(sessionTimeoutMs)
.zkAclId(null)
.build();
zkc0 = ZooKeeperClientBuilder.newBuilder()
.name("zkc0")
.uri(createDLMURI("/"))
.sessionTimeoutMs(sessionTimeoutMs)
.zkAclId(null)
.build();
lockStateExecutor = OrderedScheduler.newBuilder()
.name("test-scheduer")
.corePoolSize(1)
.build();
}
代码示例来源:origin: twitter/distributedlog
/**
* Create a zookeeper client builder with provided <i>conf</i> for testing.
*
* @param conf distributedlog configuration
* @return zookeeper client builder
*/
public static ZooKeeperClientBuilder newBuilder(DistributedLogConfiguration conf) {
return ZooKeeperClientBuilder.newBuilder()
.retryPolicy(RetryPolicyUtils.DEFAULT_INFINITE_RETRY_POLICY)
.sessionTimeoutMs(conf.getZKSessionTimeoutMilliseconds())
.zkAclId(conf.getZkAclId())
.retryThreadCount(conf.getZKClientNumberRetryThreads())
.requestRateLimit(conf.getZKRequestRateLimit())
.statsLogger(NullStatsLogger.INSTANCE);
}
}
代码示例来源:origin: twitter/distributedlog
@Before
public void setup() throws Exception {
zkc = ZooKeeperClientBuilder.newBuilder()
.name("zkc")
.uri(DLMTestUtil.createDLMURI(zkPort, "/"))
.sessionTimeoutMs(sessionTimeoutMs)
.zkServers(zkServers)
.zkAclId(null)
.build();
zkc0 = ZooKeeperClientBuilder.newBuilder()
.name("zkc0")
.uri(DLMTestUtil.createDLMURI(zkPort, "/"))
.sessionTimeoutMs(sessionTimeoutMs)
.zkServers(zkServers)
.zkAclId(null)
.build();
lockStateExecutor = OrderedScheduler.newBuilder()
.corePoolSize(1)
.build();
}
代码示例来源:origin: twitter/distributedlog
@Test(timeout = 60000)
public void testZooKeeperSessionExpired() throws Exception {
Set<String> allLogs = createLogs(2 * maxLogsPerSubnamespace, "test-zookeeper-session-expired-");
TestNamespaceListenerWithExpectedSize listener =
new TestNamespaceListenerWithExpectedSize(2 * maxLogsPerSubnamespace + 1);
metadataStore.registerNamespaceListener(listener);
ZooKeeperClientUtils.expireSession(zkc, DLUtils.getZKServersFromDLUri(uri), zkSessionTimeoutMs);
String testLogName = "test-log-name";
allLogs.add(testLogName);
DistributedLogConfiguration anotherConf = new DistributedLogConfiguration();
anotherConf.addConfiguration(baseConf);
ZooKeeperClient anotherZkc = TestZooKeeperClientBuilder.newBuilder()
.uri(uri)
.sessionTimeoutMs(zkSessionTimeoutMs)
.build();
FederatedZKLogMetadataStore anotherMetadataStore =
new FederatedZKLogMetadataStore(anotherConf, uri, anotherZkc, scheduler);
FutureUtils.result(anotherMetadataStore.createLog(testLogName));
listener.waitForDone();
Set<String> receivedLogs = listener.getResult();
assertEquals(2 * maxLogsPerSubnamespace + 1, receivedLogs.size());
assertEquals(allLogs, receivedLogs);
}
代码示例来源:origin: twitter/distributedlog
@Before
public void setup() throws Exception {
zkc = TestZooKeeperClientBuilder.newBuilder()
.uri(createDLMURI("/"))
.sessionTimeoutMs(zkSessionTimeoutMs)
.build();
scheduler = OrderedScheduler.newBuilder()
.name("test-zk-logsegment-metadata-store")
.corePoolSize(1)
.build();
DistributedLogConfiguration conf = new DistributedLogConfiguration();
conf.addConfiguration(baseConf);
this.uri = createDLMURI("/" + runtime.getMethodName());
lsmStore = new ZKLogSegmentMetadataStore(conf, zkc, scheduler);
zkc.get().create(
"/" + runtime.getMethodName(),
new byte[0],
ZooDefs.Ids.OPEN_ACL_UNSAFE,
CreateMode.PERSISTENT);
this.rootZkPath = "/" + runtime.getMethodName();
}
代码示例来源:origin: twitter/distributedlog
@Before
public void setup() throws Exception {
zkc = TestZooKeeperClientBuilder.newBuilder()
.uri(createDLMURI("/"))
.sessionTimeoutMs(zkSessionTimeoutMs)
.build();
scheduler = OrderedScheduler.newBuilder()
.name("test-zk-logmetadata-store")
.corePoolSize(1)
.build();
DistributedLogConfiguration conf = new DistributedLogConfiguration();
conf.addConfiguration(baseConf);
this.uri = createDLMURI("/" + runtime.getMethodName());
metadataStore = new ZKLogMetadataStore(conf, uri, zkc, scheduler);
}
代码示例来源:origin: twitter/distributedlog
@Before
public void setup() throws Exception {
zkc = TestZooKeeperClientBuilder.newBuilder()
.uri(createDLMURI("/"))
.sessionTimeoutMs(zkSessionTimeoutMs)
.build();
scheduler = OrderedScheduler.newBuilder()
.name("test-zk-logmetadata-store")
.corePoolSize(2)
.build();
DistributedLogConfiguration conf = new DistributedLogConfiguration();
conf.addConfiguration(baseConf);
this.uri = createDLMURI("/" + runtime.getMethodName());
FederatedZKLogMetadataStore.createFederatedNamespace(uri, zkc);
metadataStore = new FederatedZKLogMetadataStore(conf, uri, zkc, scheduler);
}
本文整理了Java中com.twitter.distributedlog.ZooKeeperClientBuilder.sessionTimeoutMs()方法的一些代码示例,展示了ZooKeeper
我是一名优秀的程序员,十分优秀!