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

ZkClient介绍

[英]Created by zhangzhiyong on 2018/7/4.
[中]张志勇于2018年7月4日创作。

代码示例

代码示例来源：origin: smallnest/rpcx-java

/**
 * 服务注册
 */
@Override
public void register() {
  try {
    ZkClient.ins().create(this.basePath, this.serviceNameSet, this.addr);
  } catch (Exception e) {
    e.printStackTrace();
  }
}

代码示例来源：origin: smallnest/rpcx-java

@Override
  public void close() {
    this.queue.offer(new PathStatus(true));
    ZkClient.ins().close();
    stop.compareAndSet(false, true);
  }
}

代码示例来源：origin: smallnest/rpcx-java

@Override
public void addServices(final String... serviceNames) {
  Arrays.stream(serviceNames).forEach(it -> this.serviceNameSet.add(it));
  Arrays.stream(serviceNames).forEach(it -> {
    Set<Pair<String, String>> set = ZkClient.ins().get(basePath, it).stream().map(it2 -> {
      String addr = "";
      try {
        if (it2.getObject1().contains("@")) {
          addr = it2.getObject1().split("@")[1];
        } else {
          addr = it2.getObject1();
        }
      } catch (Exception ex) {
      }
      return Pair.of(addr, it2.getObject2());
    }).collect(Collectors.toSet());
    this.map.putIfAbsent(it, set);
    try {
      ZkClient.ins().watch(queue, basePath + it);
    } catch (Exception e) {
      logger.error("service name foreach {} error:{}", it, e.getMessage());
    }
  });
}

代码示例来源：origin: smallnest/rpcx-java

private void zkServiceDiscovery(String basePath) {
  this.serviceNameSet.stream().forEach(it -> {
    Set<Pair<String, String>> set = ZkClient.ins().get(basePath, it).stream().map(it2 -> {
      String addr = "";
      try {
        if (it2.getObject1().contains("@")) {
          addr = it2.getObject1().split("@")[1];
        } else {
          addr = it2.getObject1();
        }
      } catch (Exception ex) {
      }
      return Pair.of(addr, it2.getObject2());
    }).collect(Collectors.toSet());
    this.map.put(it, set);
  });
  //监控zk
  watch();
}

代码示例来源：origin: smallnest/rpcx-java

ZkClient.ins().watch(queue, basePath + it);
} catch (Exception e) {
  logger.error("service name foreach {} error:{}", it, e.getMessage());