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

ZookeeperRegistry介绍

暂无

代码示例

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

public static Registry getRegistry(AppContext appContext) {

    String address = appContext.getConfig().getRegistryAddress();
    if (StringUtils.isEmpty(address)) {
      throw new IllegalArgumentException("address is null！");
    }
    if (address.startsWith("zookeeper://")) {
      return new ZookeeperRegistry(appContext);
    } else if (address.startsWith("redis://")) {
      return new RedisRegistry(appContext);
    } else if (address.startsWith("multicast://")) {
//            return new MulticastRegistry(config);
    }
    throw new IllegalArgumentException("illegal address protocol");
  }

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

@Override
protected void doSubscribe(Node node, NotifyListener listener) {
  List<NodeType> listenNodeTypes = node.getListenNodeTypes();
  if (CollectionUtils.isEmpty(listenNodeTypes)) {
    return;
  }
  for (NodeType listenNodeType : listenNodeTypes) {
    String listenNodePath = NodeRegistryUtils.getNodeTypePath(clusterName, listenNodeType);
    ChildListener zkListener = addZkListener(node, listener);
    // 为自己关注的 节点 添加监听
    List<String> children = zkClient.addChildListener(listenNodePath, zkListener);
    if (CollectionUtils.isNotEmpty(children)) {
      List<Node> listenedNodes = new ArrayList<Node>();
      for (String child : children) {
        Node listenedNode = NodeRegistryUtils.parse(listenNodePath + "/" + child);
        listenedNodes.add(listenedNode);
      }
      notify(NotifyEvent.ADD, listenedNodes, listener);
      cachedChildrenNodeMap.put(listenNodePath, children);
    }
  }
}

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

@Override
  public void destroy() {
    super.destroy();
    try {
      zkClient.close();
    } catch (Exception e) {
      LOGGER.warn("Failed to close zookeeper client " + getNode() + ", cause: " + e.getMessage(), e);
    }
  }
}

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

@Override
protected void doSubscribe(Node node, NotifyListener listener) {
  List<NodeType> listenNodeTypes = node.getListenNodeTypes();
  if (CollectionUtils.isEmpty(listenNodeTypes)) {
    return;
  }
  for (NodeType listenNodeType : listenNodeTypes) {
    String listenNodePath = NodeRegistryUtils.getNodeTypePath(clusterName, listenNodeType);
    ChildListener zkListener = addZkListener(node, listener);
    // 为自己关注的 节点 添加监听
    List<String> children = zkClient.addChildListener(listenNodePath, zkListener);
    if (CollectionUtils.isNotEmpty(children)) {
      List<Node> listenedNodes = new ArrayList<Node>();
      for (String child : children) {
        Node listenedNode = NodeRegistryUtils.parse(listenNodePath + "/" + child);
        listenedNodes.add(listenedNode);
      }
      notify(NotifyEvent.ADD, listenedNodes, listener);
      cachedChildrenNodeMap.put(listenNodePath, children);
    }
  }
}

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

@Override
  public void destroy() {
    super.destroy();
    try {
      zkClient.close();
    } catch (Exception e) {
      LOGGER.warn("Failed to close zookeeper client " + getNode() + ", cause: " + e.getMessage(), e);
    }
  }
}

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

public static Registry getRegistry(AppContext appContext) {

    String address = appContext.getConfig().getRegistryAddress();
    if (StringUtils.isEmpty(address)) {
      throw new IllegalArgumentException("address is null！");
    }
    if (address.startsWith("zookeeper://")) {
      return new ZookeeperRegistry(appContext);
    } else if (address.startsWith("redis://")) {
      return new RedisRegistry(appContext);
    } else if (address.startsWith("multicast://")) {
//            return new MulticastRegistry(config);
    }
    throw new IllegalArgumentException("illegal address protocol");
  }

代码示例来源：origin: com.github.ltsopensource/lts-core

@Override
protected void doSubscribe(Node node, NotifyListener listener) {
  List<NodeType> listenNodeTypes = node.getListenNodeTypes();
  if (CollectionUtils.isEmpty(listenNodeTypes)) {
    return;
  }
  for (NodeType listenNodeType : listenNodeTypes) {
    String listenNodePath = NodeRegistryUtils.getNodeTypePath(clusterName, listenNodeType);
    ChildListener zkListener = addZkListener(node, listener);
    // 为自己关注的 节点 添加监听
    List<String> children = zkClient.addChildListener(listenNodePath, zkListener);
    if (CollectionUtils.isNotEmpty(children)) {
      List<Node> listenedNodes = new ArrayList<Node>();
      for (String child : children) {
        Node listenedNode = NodeRegistryUtils.parse(listenNodePath + "/" + child);
        listenedNodes.add(listenedNode);
      }
      notify(NotifyEvent.ADD, listenedNodes, listener);
      cachedChildrenNodeMap.put(listenNodePath, children);
    }
  }
}

代码示例来源：origin: com.github.ltsopensource/lts-core

@Override
  public void destroy() {
    super.destroy();
    try {
      zkClient.close();
    } catch (Exception e) {
      LOGGER.warn("Failed to close zookeeper client " + getNode() + ", cause: " + e.getMessage(), e);
    }
  }
}

代码示例来源：origin: com.github.ltsopensource/lts-core

public static Registry getRegistry(AppContext appContext) {

    String address = appContext.getConfig().getRegistryAddress();
    if (StringUtils.isEmpty(address)) {
      throw new IllegalArgumentException("address is null！");
    }
    if (address.startsWith("zookeeper://")) {
      return new ZookeeperRegistry(appContext);
    } else if (address.startsWith("redis://")) {
      return new RedisRegistry(appContext);
    } else if (address.startsWith("multicast://")) {
//            return new MulticastRegistry(config);
    }
    throw new IllegalArgumentException("illegal address protocol");
  }