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

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

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

ZkClient.getChildren介绍

暂无

代码示例

代码示例来源:origin: adyliu/jafka

/**
 * get children nodes name
 *
 * @param zkClient zkClient
 * @param path     full path
 * @return children nodes name or null while path not exist
 */
public static List<String> getChildrenParentMayNotExist(ZkClient zkClient, String path) {
  try {
    return zkClient.getChildren(path);
  } catch (ZkNoNodeException e) {
    return null;
  }
}

代码示例来源:origin: adyliu/jafka

public void handleChildChange(String parentPath, List<String> currentChilds) throws Exception {
    synchronized (lock) {
      if (zkClient == null)
        return;
      try {
        List<String> latestTopics = zkClient.getChildren(ZkUtils.BrokerTopicsPath);
        logger.debug("all Topics: " + latestTopics);
        eventHandler.handleTopicEvent(latestTopics);
      } catch (ConsumerRebalanceFailedException e) {
        logger.error("can't rebalance in embedded consumer); proceed to shutdown", e);
        serverStartable.close();
      } catch (Exception e) {
        logger.error("error in handling child changes in embedded consumer", e);
      }
    }
  }
}

代码示例来源:origin: com.github.adyliu/zkclient

@Override
  public List<String> call() throws Exception {
    exists(path, true);
    try {
      return getChildren(path, true);
    } catch (ZkNoNodeException e) {
      // ignore, the "exists" watch will listen for the parent node to appear
    }
    return null;
  }
});

代码示例来源:origin: adyliu/zkclient

@Override
  public List<String> call() throws Exception {
    exists(path, true);
    try {
      return getChildren(path, true);
    } catch (ZkNoNodeException e) {
      // ignore, the "exists" watch will listen for the parent node to appear
    }
    return null;
  }
});

代码示例来源:origin: adyliu/zkclient

public List<String> getChildren(String path) {
  return getChildren(path, hasListeners(path));
}

代码示例来源:origin: com.github.adyliu/zkclient

public List<String> getChildren(String path) {
  return getChildren(path, hasListeners(path));
}

代码示例来源:origin: com.github.adyliu/zkclient

public boolean deleteRecursive(String path) {
  List<String> children;
  try {
    children = getChildren(path, false);
  } catch (ZkNoNodeException e) {
    return true;
  }
  if (children != null){
    for (String subPath : children) {
      if (!deleteRecursive(path + "/" + subPath)) {
        return false;
      }
    }
  }
  return delete(path);
}

代码示例来源:origin: adyliu/zkclient

public boolean deleteRecursive(String path) {
  List<String> children;
  try {
    children = getChildren(path, false);
  } catch (ZkNoNodeException e) {
    return true;
  }
  if (children != null){
    for (String subPath : children) {
      if (!deleteRecursive(path + "/" + subPath)) {
        return false;
      }
    }
  }
  return delete(path);
}

代码示例来源:origin: com.github.adyliu/zkclient

@Override
  public void run() throws Exception {
    try {
      // if the node doesn't exist we should listen for the root node to reappear
      exists(path);
      List<String> children = getChildren(path);
      listener.handleChildChange(path, children);
    } catch (ZkNoNodeException e) {
      listener.handleChildChange(path, null);
    }
  }
});

代码示例来源:origin: adyliu/zkclient

@Override
  public void run() throws Exception {
    try {
      // if the node doesn't exist we should listen for the root node to reappear
      exists(path);
      List<String> children = getChildren(path);
      listener.handleChildChange(path, children);
    } catch (ZkNoNodeException e) {
      listener.handleChildChange(path, null);
    }
  }
});

相关文章