gpt4 book ai didi

com.colobu.rpcx.utils.ZkClient.ins()方法的使用及代码示例

转载 作者:知者 更新时间:2024-03-13 12:26:29 27 4
gpt4 key购买 nike

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

ZkClient.ins介绍

暂无

代码示例

代码示例来源: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());

27 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com