com.alibaba.dubbo.common.URL.setAddress()方法的使用及代码示例

x33g5p2x  于2022-01-31 转载在 其他  
字(7.8k)|赞(0)|评价(0)|浏览(96)

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

URL.setAddress介绍

暂无

代码示例

代码示例来源：origin: com.alibaba/dubbo

public List<URL> getBackupUrls() {
  List<URL> urls = new ArrayList<URL>();
  urls.add(this);
  String[] backups = getParameter(Constants.BACKUP_KEY, new String[0]);
  if (backups != null && backups.length > 0) {
    for (String backup : backups) {
      urls.add(this.setAddress(backup));
    }
  }
  return urls;
}

代码示例来源：origin: remoting/dubbox

public List<URL> getBackupUrls() {
  List<URL> urls = new ArrayList<URL>();
  urls.add(this);
  String[] backups = getParameter(Constants.BACKUP_KEY, new String[0]);
  if (backups != null && backups.length > 0) {
    for (String backup : backups) {
      urls.add(this.setAddress(backup));
    }
  }
  return urls;
}

代码示例来源：origin: com.alibaba/dubbo-common

public List<URL> getBackupUrls() {
  List<URL> urls = new ArrayList<URL>();
  urls.add(this);
  String[] backups = getParameter(Constants.BACKUP_KEY, new String[0]);
  if (backups != null && backups.length > 0) {
    for (String backup : backups) {
      urls.add(this.setAddress(backup));
    }
  }
  return urls;
}

代码示例来源：origin: remoting/dubbox

public List<URL> getBackupUrls() {
  List<URL> urls = new ArrayList<URL>();
  urls.add(this);
  String[] backups = getParameter(Constants.BACKUP_KEY, new String[0]);
  if (backups != null && backups.length > 0) {
    for (String backup : backups) {
      urls.add(this.setAddress(backup));
    }
  }
  return urls;
}

代码示例来源：origin: com.alibaba/dubbo

.setAddress(Constants.ANYHOST_VALUE)
.setPath(toServiceName(key))
.addParameter(Constants.CATEGORY_KEY, category));

代码示例来源：origin: com.alibaba/dubbo-registry-redis

.setAddress(Constants.ANYHOST_VALUE)
.setPath(toServiceName(key))
.addParameter(Constants.CATEGORY_KEY, category));

代码示例来源：origin: hutai123/dubbox

.setAddress(Constants.ANYHOST_VALUE)
.setPath(toServiceName(key))
.addParameter(Constants.CATEGORY_KEY, category));

代码示例来源：origin: remoting/dubbox

public Registry createRegistry(URL url) {
  url = getRegistryURL(url);
  List<URL> urls = new ArrayList<URL>();
  urls.add(url.removeParameter(Constants.BACKUP_KEY));
  String backup = url.getParameter(Constants.BACKUP_KEY);
  if (backup != null && backup.length() > 0) {
    String[] addresses = Constants.COMMA_SPLIT_PATTERN.split(backup);
    for (String address : addresses) {
      urls.add(url.setAddress(address));
    }
  }
  RegistryDirectory<RegistryService> directory = new RegistryDirectory<RegistryService>(RegistryService.class, url.addParameter(Constants.INTERFACE_KEY, RegistryService.class.getName()).addParameterAndEncoded(Constants.REFER_KEY, url.toParameterString()));
  Invoker<RegistryService> registryInvoker = cluster.join(directory);
  RegistryService registryService = proxyFactory.getProxy(registryInvoker);
  DubboRegistry registry = new DubboRegistry(registryInvoker, registryService);
  directory.setRegistry(registry);
  directory.setProtocol(protocol);
  directory.notify(urls);
  directory.subscribe(new URL(Constants.CONSUMER_PROTOCOL, NetUtils.getLocalHost(), 0, RegistryService.class.getName(), url.getParameters()));
  return registry;
}

代码示例来源：origin: net.jahhan/dubbo-registry-default

public Registry createRegistry(URL url) {
  url = getRegistryURL(url);
  List<URL> urls = new ArrayList<URL>();
  urls.add(url.removeParameter(Constants.BACKUP_KEY));
  String backup = url.getParameter(Constants.BACKUP_KEY);
  if (backup != null && backup.length() > 0) {
    String[] addresses = Constants.COMMA_SPLIT_PATTERN.split(backup);
    for (String address : addresses) {
      urls.add(url.setAddress(address));
    }
  }
  RegistryDirectory<RegistryService> directory = new RegistryDirectory<RegistryService>(RegistryService.class, url.addParameter(Constants.INTERFACE_KEY, RegistryService.class.getName()).addParameterAndEncoded(Constants.REFER_KEY, url.toParameterString()));
  Invoker<RegistryService> registryInvoker = cluster.join(directory);
  RegistryService registryService = proxyFactory.getProxy(registryInvoker);
  DubboRegistry registry = new DubboRegistry(registryInvoker, registryService);
  directory.setRegistry(registry);
  directory.setProtocol(protocol);
  directory.notify(urls);
  directory.subscribe(new URL(Constants.CONSUMER_PROTOCOL, NetUtils.getLocalHost(), 0, RegistryService.class.getName(), url.getParameters()));
  return registry;
}

代码示例来源：origin: com.alibaba/dubbo-registry-default

@Override
  public Registry createRegistry(URL url) {
    url = getRegistryURL(url);
    List<URL> urls = new ArrayList<URL>();
    urls.add(url.removeParameter(Constants.BACKUP_KEY));
    String backup = url.getParameter(Constants.BACKUP_KEY);
    if (backup != null && backup.length() > 0) {
      String[] addresses = Constants.COMMA_SPLIT_PATTERN.split(backup);
      for (String address : addresses) {
        urls.add(url.setAddress(address));
      }
    }
    RegistryDirectory<RegistryService> directory = new RegistryDirectory<RegistryService>(RegistryService.class, url.addParameter(Constants.INTERFACE_KEY, RegistryService.class.getName()).addParameterAndEncoded(Constants.REFER_KEY, url.toParameterString()));
    Invoker<RegistryService> registryInvoker = cluster.join(directory);
    RegistryService registryService = proxyFactory.getProxy(registryInvoker);
    DubboRegistry registry = new DubboRegistry(registryInvoker, registryService);
    directory.setRegistry(registry);
    directory.setProtocol(protocol);
    directory.notify(urls);
    directory.subscribe(new URL(Constants.CONSUMER_PROTOCOL, NetUtils.getLocalHost(), 0, RegistryService.class.getName(), url.getParameters()));
    return registry;
  }
}

代码示例来源：origin: remoting/dubbox

public Registry createRegistry(URL url) {
  url = getRegistryURL(url);
  List<URL> urls = new ArrayList<URL>();
  urls.add(url.removeParameter(Constants.BACKUP_KEY));
  String backup = url.getParameter(Constants.BACKUP_KEY);
  if (backup != null && backup.length() > 0) {
    String[] addresses = Constants.COMMA_SPLIT_PATTERN.split(backup);
    for (String address : addresses) {
      urls.add(url.setAddress(address));
    }
  }
  RegistryDirectory<RegistryService> directory = new RegistryDirectory<RegistryService>(RegistryService.class, url.addParameter(Constants.INTERFACE_KEY, RegistryService.class.getName()).addParameterAndEncoded(Constants.REFER_KEY, url.toParameterString()));
  Invoker<RegistryService> registryInvoker = cluster.join(directory);
  RegistryService registryService = proxyFactory.getProxy(registryInvoker);
  DubboRegistry registry = new DubboRegistry(registryInvoker, registryService);
  directory.setRegistry(registry);
  directory.setProtocol(protocol);
  directory.notify(urls);
  directory.subscribe(new URL(Constants.CONSUMER_PROTOCOL, NetUtils.getLocalHost(), 0, RegistryService.class.getName(), url.getParameters()));
  return registry;
}

代码示例来源：origin: com.alibaba/dubbo

@Override
  public Registry createRegistry(URL url) {
    url = getRegistryURL(url);
    List<URL> urls = new ArrayList<URL>();
    urls.add(url.removeParameter(Constants.BACKUP_KEY));
    String backup = url.getParameter(Constants.BACKUP_KEY);
    if (backup != null && backup.length() > 0) {
      String[] addresses = Constants.COMMA_SPLIT_PATTERN.split(backup);
      for (String address : addresses) {
        urls.add(url.setAddress(address));
      }
    }
    RegistryDirectory<RegistryService> directory = new RegistryDirectory<RegistryService>(RegistryService.class, url.addParameter(Constants.INTERFACE_KEY, RegistryService.class.getName()).addParameterAndEncoded(Constants.REFER_KEY, url.toParameterString()));
    Invoker<RegistryService> registryInvoker = cluster.join(directory);
    RegistryService registryService = proxyFactory.getProxy(registryInvoker);
    DubboRegistry registry = new DubboRegistry(registryInvoker, registryService);
    directory.setRegistry(registry);
    directory.setProtocol(protocol);
    directory.notify(urls);
    directory.subscribe(new URL(Constants.CONSUMER_PROTOCOL, NetUtils.getLocalHost(), 0, RegistryService.class.getName(), url.getParameters()));
    return registry;
  }
}

代码示例来源：origin: hutai123/dubbox

.setAddress(Constants.ANYHOST_VALUE)
.setPath(toServiceName(key))
.addParameter(Constants.CATEGORY_KEY, category));

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

URL

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

    更多

    URL类方法

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