org.I0Itec.zkclient.ZkClient.getChildren()方法的使用及代码示例

x33g5p2x  于2022-02-05 转载在 其他  
字(7.9k)|赞(0)|评价(0)|浏览(190)

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

ZkClient.getChildren介绍

暂无

代码示例

代码示例来源：origin: ltsopensource/light-task-scheduler

@Override
public List<String> getChildren(String path) {
  try {
    return zkClient.getChildren(path);
  } catch (ZkNoNodeException e) {
    return null;
  }
}

代码示例来源：origin: ltsopensource/light-task-scheduler

@Override
public List<String> getChildren(String path) {
  try {
    return zkClient.getChildren(path);
  } catch (ZkNoNodeException e) {
    return null;
  }
}

代码示例来源：origin: killme2008/Metamorphosis

public static List<String> getChildrenMaybeNull(final ZkClient client, final String path) {
  try {
    return client.getChildren(path);
  }
  catch (final ZkNoNodeException e) {
    return null;
  }
}

代码示例来源：origin: networknt/light-4j

@Override
public List<String> getChildren(String path) {
  return zkClient.getChildren(path);
}

代码示例来源：origin: killme2008/Metamorphosis

public static List<String> getChildren(final ZkClient client, final String path) {
  return client.getChildren(path);
}

代码示例来源：origin: apache/incubator-dubbo

public List<String> getChildren(String path) {
  Assert.notNull(client, new IllegalStateException("Zookeeper is not connected yet!"));
  return client.getChildren(path);
}

代码示例来源：origin: apache/incubator-dubbo

public List<String> getChildren(String path) {
  Assert.notNull(client, new IllegalStateException("Zookeeper is not connected yet!"));
  return client.getChildren(path);
}

代码示例来源：origin: crossoverJie/cim

/**
 * 获取所有注册节点
 * @return
 */
public List<String> getAllNode(){
  List<String> children = zkClient.getChildren("/route");
  logger.info("查询所有节点成功=【{}】", JSON.toJSONString(children));
  return children;
}

代码示例来源：origin: crossoverJie/cim

/**
 * 获取所有注册节点
 * @return
 */
public List<String> getAllNode(){
  List<String> children = zkClient.getChildren("/route");
  logger.info("查询所有节点成功=【{}】", JSON.toJSONString(children));
  return children;
}

代码示例来源：origin: weibocom/motan

private List<String> getChildren(String path) {
  List<String> children = new ArrayList<String>();
  if (zkClient.exists(path)) {
    children = zkClient.getChildren(path);
  }
  return children;
}

代码示例来源：origin: weibocom/motan

private List<String> getChildren(String path) {
    List<String> children = new ArrayList<String>();
    if (zkClient.exists(path)) {
      children = zkClient.getChildren(path);
    }
    return children;
  }
}

代码示例来源：origin: weibocom/motan

@Override
protected List<URL> discoverService(URL url) {
  try {
    String parentPath = ZkUtils.toNodeTypePath(url, ZkNodeType.AVAILABLE_SERVER);
    List<String> currentChilds = new ArrayList<>();
    if (zkClient.exists(parentPath)) {
      currentChilds = zkClient.getChildren(parentPath);
    }
    return nodeChildsToUrls(url, parentPath, currentChilds);
  } catch (Throwable e) {
    throw new MotanFrameworkException(String.format("Failed to discover service %s from zookeeper(%s), cause: %s", url, getUrl(), e.getMessage()), e);
  }
}

代码示例来源：origin: uber/chaperone

private void loadBlacklistedTopics() {
 _blacklistedTopics.clear();
 _blacklistedTopics.addAll(_zkClient.getChildren(_blacklistedTopicsZPath));
}

代码示例来源：origin: javahongxi/whatsmars

public List<String> getChildren(String path) {
  Assert.notNull(client, new IllegalStateException("Zookeeper is not connected yet!"));
  return client.getChildren(path);
}

代码示例来源：origin: uber/chaperone

Set<String> servingTopics;
try {
 servingTopics = ImmutableSet.copyOf(_zkClient.getChildren(KAFKA_TOPICS_PATH));
} catch (Exception e) {
 LOGGER.warn("Failed to get topics from kafka zk: {}", e);

代码示例来源：origin: Dromara/soul

private void loadWatchAppAuth() {
  final String appAuthParent = ZkPathConstants.APP_AUTH_PARENT;
  if (!zkClient.exists(appAuthParent)) {
    zkClient.createPersistent(appAuthParent, true);
  }
  final List<String> childrenList = zkClient.getChildren(appAuthParent);
  if (CollectionUtils.isNotEmpty(childrenList)) {
    childrenList.forEach(children -> {
      String realPath = buildRealPath(appAuthParent, children);
      final AppAuthZkDTO appAuthZkDTO = zkClient.readData(realPath);
      Optional.ofNullable(appAuthZkDTO)
          .ifPresent(dto -> AUTH_MAP.put(dto.getAppKey(), dto));
      subscribeAppAuthDataChanges(realPath);
    });
  }
  zkClient.subscribeChildChanges(appAuthParent, (parentPath, currentChilds) -> {
    if (CollectionUtils.isNotEmpty(currentChilds)) {
      final List<String> unsubscribePath = unsubscribePath(childrenList, currentChilds);
      unsubscribePath.stream().map(children -> buildRealPath(parentPath, children))
          .forEach(this::subscribeAppAuthDataChanges);
    }
  });
}

代码示例来源：origin: Dromara/soul

private void loadWatcherRule() {
  Arrays.stream(PluginEnum.values()).forEach(pluginEnum -> {
    final String ruleParent = ZkPathConstants.buildRuleParentPath(pluginEnum.getName());
    if (!zkClient.exists(ruleParent)) {
      zkClient.createPersistent(ruleParent, true);
    }
    final List<String> childrenList = zkClient.getChildren(ruleParent);
    if (CollectionUtils.isNotEmpty(childrenList)) {
      childrenList.forEach(children -> {
        String realPath = buildRealPath(ruleParent, children);
        final RuleZkDTO ruleZkDTO = zkClient.readData(realPath);
        Optional.ofNullable(ruleZkDTO)
            .ifPresent(dto -> {
              String key = dto.getSelectorId();
              setRuleMapByKey(key, ruleZkDTO);
            });
        subscribeRuleDataChanges(realPath);
      });
    }
    zkClient.subscribeChildChanges(ruleParent, (parentPath, currentChilds) -> {
      if (CollectionUtils.isNotEmpty(currentChilds)) {
        final List<String> unsubscribePath = unsubscribePath(childrenList, currentChilds);
        //获取新增的节点数据，并对该节点进行订阅
        unsubscribePath.stream().map(p -> buildRealPath(parentPath, p))
            .forEach(this::subscribeRuleDataChanges);
      }
    });
  });
}

代码示例来源：origin: Dromara/soul

private void loadWatcherSelector() {
  Arrays.stream(PluginEnum.values()).forEach(pluginEnum -> {
    //获取选择器的节点
    String selectorParentPath =
        ZkPathConstants.buildSelectorParentPath(pluginEnum.getName());
    if (!zkClient.exists(selectorParentPath)) {
      zkClient.createPersistent(selectorParentPath, true);
    }
    final List<String> childrenList = zkClient.getChildren(selectorParentPath);
    if (CollectionUtils.isNotEmpty(childrenList)) {
      childrenList.forEach(children -> {
        String realPath = buildRealPath(selectorParentPath, children);
        final SelectorZkDTO selectorZkDTO = zkClient.readData(realPath);
        Optional.ofNullable(selectorZkDTO)
            .ifPresent(dto -> {
              final String key = dto.getPluginName();
              setSelectorMapByKey(key, dto);
            });
        subscribeSelectorDataChanges(realPath);
      });
    }
    zkClient.subscribeChildChanges(selectorParentPath, (parentPath, currentChilds) -> {
      if (CollectionUtils.isNotEmpty(currentChilds)) {
        final List<String> unsubscribePath = unsubscribePath(childrenList, currentChilds);
        unsubscribePath.stream().map(p -> buildRealPath(parentPath, p))
            .forEach(this::subscribeSelectorDataChanges);
      }
    });
  });
}

代码示例来源：origin: Dromara/soul

List<PluginDO> pluginDOs = pluginMapper.selectByQuery(new PluginQuery());
if (CollectionUtils.isNotEmpty(pluginDOs)) {
  List<String> pluginZKs = zkClient.getChildren(ZkPathConstants.buildPluginParentPath());
  pluginDOs.forEach(pluginDO -> {
    if (CollectionUtils.isNotEmpty(pluginZKs)) {

代码示例来源：origin: Dromara/soul

pluginDO.getName(), pluginDO.getEnabled()));
List<String> selectorZKs = zkClient.getChildren(ZkPathConstants.buildSelectorParentPath(pluginDO.getName()));
selectorMapper.selectByQuery(new SelectorQuery(pluginDO.getId(), null)).forEach(selectorDO -> {
  if (CollectionUtils.isNotEmpty(selectorZKs)) {
      selectorDO.getLoged(), selectorDO.getContinued(), selectorDO.getHandle(), selectorConditionZkDTOs));
  List<String> ruleZKs = zkClient.getChildren(ZkPathConstants.buildRuleParentPath(pluginDO.getName()));
  ruleMapper.selectByQuery(new RuleQuery(selectorDO.getId(), null)).forEach(ruleDO -> {
    if (CollectionUtils.isNotEmpty(ruleZKs)) {
  zkClient.delete(ZkPathConstants.buildSelectorRealPath(pluginDO.getName(), selectorZK));
  String ruleParentPath = ZkPathConstants.buildRuleParentPath(pluginDO.getName());
  zkClient.getChildren(ruleParentPath).forEach(selectorRulePath -> {
    if (selectorRulePath.split(ZkPathConstants.SELECTOR_JOIN_RULE)[0].equals(selectorZK)) {
      zkClient.delete(ruleParentPath + "/" + selectorRulePath);

内容来源于网络，如有侵权，请联系作者删除！

zkclient

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多

    ZkClient类方法

    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com