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

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);
}