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

ZkClientx.getZkClient介绍

暂无

代码示例

代码示例来源：origin: alibaba/canal

private synchronized ZkClientx getZkclientx() {
  // 做一下排序，保证相同的机器只使用同一个链接
  List<String> zkClusters = new ArrayList<String>(parameters.getZkClusters());
  Collections.sort(zkClusters);
  return ZkClientx.getZkClient(StringUtils.join(zkClusters, ";"));
}

代码示例来源：origin: alibaba/canal

/**
   * 创建带cluster模式的客户端链接，自动完成failover切换，服务器列表自动扫描
   *
   * @param zkServers
   * @param destination
   * @param username
   * @param password
   * @return
   */
  public static CanalConnector newClusterConnector(String zkServers, String destination, String username,
                           String password) {
    ClusterCanalConnector canalConnector = new ClusterCanalConnector(username,
      password,
      destination,
      new ClusterNodeAccessStrategy(destination, ZkClientx.getZkClient(zkServers)));
    canalConnector.setSoTimeout(60 * 1000);
    canalConnector.setIdleTimeout(60 * 60 * 1000);
    return canalConnector;
  }
}

代码示例来源：origin: alibaba/canal

zkclientx = ZkClientx.getZkClient(zkServers);

代码示例来源：origin: com.alibaba.otter/canal.instance.manager

private synchronized ZkClientx getZkclientx() {
  // 做一下排序，保证相同的机器只使用同一个链接
  List<String> zkClusters = new ArrayList<String>(parameters.getZkClusters());
  Collections.sort(zkClusters);
  return ZkClientx.getZkClient(StringUtils.join(zkClusters, ";"));
}

代码示例来源：origin: com.alibaba.otter/canal.client

/**
   * 创建带cluster模式的客户端链接，自动完成failover切换，服务器列表自动扫描
   *
   * @param zkServers
   * @param destination
   * @param username
   * @param password
   * @return
   */
  public static CanalConnector newClusterConnector(String zkServers, String destination, String username,
                           String password) {
    ClusterCanalConnector canalConnector = new ClusterCanalConnector(username,
      password,
      destination,
      new ClusterNodeAccessStrategy(destination, ZkClientx.getZkClient(zkServers)));
    canalConnector.setSoTimeout(60 * 1000);
    canalConnector.setIdleTimeout(60 * 60 * 1000);
    return canalConnector;
  }
}

代码示例来源：origin: com.alibaba.otter/canal.deployer

zkclientx = ZkClientx.getZkClient(zkServers);