gpt4 book ai didi

org.apache.dubbo.registry.zookeeper.ZookeeperRegistry.getUrl()方法的使用及代码示例

转载 作者:知者 更新时间:2024-03-13 09:57:04 27 4
gpt4 key购买 nike

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

ZookeeperRegistry.getUrl介绍

暂无

代码示例

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

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

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

@Override
public void doUnregister(URL url) {
  try {
    zkClient.delete(toUrlPath(url));
  } catch (Throwable e) {
    throw new RpcException("Failed to unregister " + url + " to zookeeper " + getUrl() + ", cause: " + e.getMessage(), e);
  }
}

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

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

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

@Override
public void doUnregister(URL url) {
  try {
    zkClient.delete(toUrlPath(url));
  } catch (Throwable e) {
    throw new RpcException("Failed to unregister " + url + " to zookeeper " + getUrl() + ", cause: " + e.getMessage(), e);
  }
}

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

@Override
public List<URL> lookup(URL url) {
  if (url == null) {
    throw new IllegalArgumentException("lookup url == null");
  }
  try {
    List<String> providers = new ArrayList<>();
    for (String path : toCategoriesPath(url)) {
      List<String> children = zkClient.getChildren(path);
      if (children != null) {
        providers.addAll(children);
      }
    }
    return toUrlsWithoutEmpty(url, providers);
  } catch (Throwable e) {
    throw new RpcException("Failed to lookup " + url + " from zookeeper " + getUrl() + ", cause: " + e.getMessage(), e);
  }
}

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

@Override
public List<URL> lookup(URL url) {
  if (url == null) {
    throw new IllegalArgumentException("lookup url == null");
  }
  try {
    List<String> providers = new ArrayList<>();
    for (String path : toCategoriesPath(url)) {
      List<String> children = zkClient.getChildren(path);
      if (children != null) {
        providers.addAll(children);
      }
    }
    return toUrlsWithoutEmpty(url, providers);
  } catch (Throwable e) {
    throw new RpcException("Failed to lookup " + url + " from zookeeper " + getUrl() + ", cause: " + e.getMessage(), e);
  }
}

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

@Override
public void doRegister(URL url) {
  try {
    zkClient.create(toUrlPath(url), url.getParameter(Constants.DYNAMIC_KEY, true));
  } catch (Throwable e) {
    throw new RpcException("Failed to register " + url + " to zookeeper " + getUrl() + ", cause: " + e.getMessage(), e);
  }
}

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

@Override
public void doRegister(URL url) {
  try {
    zkClient.create(toUrlPath(url), url.getParameter(Constants.DYNAMIC_KEY, true));
  } catch (Throwable e) {
    throw new RpcException("Failed to register " + url + " to zookeeper " + getUrl() + ", cause: " + e.getMessage(), e);
  }
}

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

throw new RpcException("Failed to subscribe " + url + " to zookeeper " + getUrl() + ", cause: " + e.getMessage(), e);

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

throw new RpcException("Failed to subscribe " + url + " to zookeeper " + getUrl() + ", cause: " + e.getMessage(), e);

代码示例来源:origin: org.apache.dubbo/dubbo-registry-zookeeper

@Override
public void doUnregister(URL url) {
  try {
    zkClient.delete(toUrlPath(url));
  } catch (Throwable e) {
    throw new RpcException("Failed to unregister " + url + " to zookeeper " + getUrl() + ", cause: " + e.getMessage(), e);
  }
}

代码示例来源:origin: org.apache.dubbo/dubbo

@Override
public void doUnregister(URL url) {
  try {
    zkClient.delete(toUrlPath(url));
  } catch (Throwable e) {
    throw new RpcException("Failed to unregister " + url + " to zookeeper " + getUrl() + ", cause: " + e.getMessage(), e);
  }
}

代码示例来源:origin: org.apache.dubbo/dubbo

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

代码示例来源:origin: org.apache.dubbo/dubbo-registry-zookeeper

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

代码示例来源:origin: org.apache.dubbo/dubbo-registry-zookeeper

@Override
public List<URL> lookup(URL url) {
  if (url == null) {
    throw new IllegalArgumentException("lookup url == null");
  }
  try {
    List<String> providers = new ArrayList<String>();
    for (String path : toCategoriesPath(url)) {
      List<String> children = zkClient.getChildren(path);
      if (children != null) {
        providers.addAll(children);
      }
    }
    return toUrlsWithoutEmpty(url, providers);
  } catch (Throwable e) {
    throw new RpcException("Failed to lookup " + url + " from zookeeper " + getUrl() + ", cause: " + e.getMessage(), e);
  }
}

代码示例来源:origin: org.apache.dubbo/dubbo

@Override
public List<URL> lookup(URL url) {
  if (url == null) {
    throw new IllegalArgumentException("lookup url == null");
  }
  try {
    List<String> providers = new ArrayList<String>();
    for (String path : toCategoriesPath(url)) {
      List<String> children = zkClient.getChildren(path);
      if (children != null) {
        providers.addAll(children);
      }
    }
    return toUrlsWithoutEmpty(url, providers);
  } catch (Throwable e) {
    throw new RpcException("Failed to lookup " + url + " from zookeeper " + getUrl() + ", cause: " + e.getMessage(), e);
  }
}

代码示例来源:origin: org.apache.dubbo/dubbo

@Override
public void doRegister(URL url) {
  try {
    zkClient.create(toUrlPath(url), url.getParameter(Constants.DYNAMIC_KEY, true));
  } catch (Throwable e) {
    throw new RpcException("Failed to register " + url + " to zookeeper " + getUrl() + ", cause: " + e.getMessage(), e);
  }
}

代码示例来源:origin: org.apache.dubbo/dubbo-registry-zookeeper

@Override
public void doRegister(URL url) {
  try {
    zkClient.create(toUrlPath(url), url.getParameter(Constants.DYNAMIC_KEY, true));
  } catch (Throwable e) {
    throw new RpcException("Failed to register " + url + " to zookeeper " + getUrl() + ", cause: " + e.getMessage(), e);
  }
}

代码示例来源:origin: org.apache.dubbo/dubbo

throw new RpcException("Failed to subscribe " + url + " to zookeeper " + getUrl() + ", cause: " + e.getMessage(), e);

代码示例来源:origin: org.apache.dubbo/dubbo-registry-zookeeper

throw new RpcException("Failed to subscribe " + url + " to zookeeper " + getUrl() + ", cause: " + e.getMessage(), e);

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