org.apache.dubbo.common.URL.isAnyHost()方法的使用及代码示例

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

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

URL.isAnyHost介绍

暂无

代码示例

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

@Override
public boolean isAnyHost() {
  return super.isAnyHost();
}

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

@Override
public boolean isAnyHost() {
  return super.isAnyHost();
}

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

public ZookeeperMetadataReport(URL url, ZookeeperTransporter zookeeperTransporter) {
  super(url);
  if (url.isAnyHost()) {
    throw new IllegalStateException("registry address == null");
  }
  String group = url.getParameter(Constants.GROUP_KEY, DEFAULT_ROOT);
  if (!group.startsWith(Constants.PATH_SEPARATOR)) {
    group = Constants.PATH_SEPARATOR + group;
  }
  this.root = group;
  zkClient = zookeeperTransporter.connect(url);
}

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

public ZookeeperMetadataReport(URL url, ZookeeperTransporter zookeeperTransporter) {
  super(url);
  if (url.isAnyHost()) {
    throw new IllegalStateException("registry address == null");
  }
  String group = url.getParameter(Constants.GROUP_KEY, DEFAULT_ROOT);
  if (!group.startsWith(Constants.PATH_SEPARATOR)) {
    group = Constants.PATH_SEPARATOR + group;
  }
  this.root = group;
  zkClient = zookeeperTransporter.connect(url);
}

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

public ZookeeperRegistry(URL url, ZookeeperTransporter zookeeperTransporter) {
  super(url);
  if (url.isAnyHost()) {
    throw new IllegalStateException("registry address == null");
  }
  String group = url.getParameter(Constants.GROUP_KEY, DEFAULT_ROOT);
  if (!group.startsWith(Constants.PATH_SEPARATOR)) {
    group = Constants.PATH_SEPARATOR + group;
  }
  this.root = group;
  zkClient = zookeeperTransporter.connect(url);
  zkClient.addStateListener(state -> {
    if (state == StateListener.RECONNECTED) {
      try {
        recover();
      } catch (Exception e) {
        logger.error(e.getMessage(), e);
      }
    }
  });
}

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

public ZookeeperRegistry(URL url, ZookeeperTransporter zookeeperTransporter) {
  super(url);
  if (url.isAnyHost()) {
    throw new IllegalStateException("registry address == null");
  }
  String group = url.getParameter(Constants.GROUP_KEY, DEFAULT_ROOT);
  if (!group.startsWith(Constants.PATH_SEPARATOR)) {
    group = Constants.PATH_SEPARATOR + group;
  }
  this.root = group;
  zkClient = zookeeperTransporter.connect(url);
  zkClient.addStateListener(state -> {
    if (state == StateListener.RECONNECTED) {
      try {
        recover();
      } catch (Exception e) {
        logger.error(e.getMessage(), e);
      }
    }
  });
}

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

public MulticastRegistry(URL url) {
  super(url);
  if (url.isAnyHost()) {
    throw new IllegalStateException("registry address == null");

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

public MulticastRegistry(URL url) {
  super(url);
  if (url.isAnyHost()) {
    throw new IllegalStateException("registry address == null");

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

@Override
protected void doStart(URL url) {
  String bindIp = url.getParameter(Constants.BIND_IP_KEY, url.getHost());
  if (!url.isAnyHost() && NetUtils.isValidLocalHost(bindIp)) {
    server.setHostname(bindIp);
  }
  server.setPort(url.getParameter(Constants.BIND_PORT_KEY, url.getPort()));
  Map<ChannelOption, Object> channelOption = new HashMap<ChannelOption, Object>();
  channelOption.put(ChannelOption.SO_KEEPALIVE, url.getParameter(Constants.KEEP_ALIVE_KEY, Constants.DEFAULT_KEEP_ALIVE));
  server.setChildChannelOptions(channelOption);
  server.setExecutorThreadCount(url.getParameter(Constants.THREADS_KEY, Constants.DEFAULT_THREADS));
  server.setIoWorkerCount(url.getParameter(Constants.IO_THREADS_KEY, Constants.DEFAULT_IO_THREADS));
  server.setMaxRequestSize(url.getParameter(Constants.PAYLOAD_KEY, Constants.DEFAULT_PAYLOAD));
  server.start();
}

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

if (!url.isAnyHost() && NetUtils.isValidLocalHost(bindIp)) {
  connector.setHost(bindIp);

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

public RedisRegistry(URL url) {
  super(url);
  if (url.isAnyHost()) {
    throw new IllegalStateException("registry address == null");

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

@Override
protected void doStart(URL url) {
  String bindIp = url.getParameter(Constants.BIND_IP_KEY, url.getHost());
  if (!url.isAnyHost() && NetUtils.isValidLocalHost(bindIp)) {
    server.setHostname(bindIp);
  }
  server.setPort(url.getParameter(Constants.BIND_PORT_KEY, url.getPort()));
  Map<ChannelOption, Object> channelOption = new HashMap<ChannelOption, Object>();
  channelOption.put(ChannelOption.SO_KEEPALIVE, url.getParameter(Constants.KEEP_ALIVE_KEY, Constants.DEFAULT_KEEP_ALIVE));
  server.setChildChannelOptions(channelOption);
  server.setExecutorThreadCount(url.getParameter(Constants.THREADS_KEY, Constants.DEFAULT_THREADS));
  server.setIoWorkerCount(url.getParameter(Constants.IO_THREADS_KEY, Constants.DEFAULT_IO_THREADS));
  server.setMaxRequestSize(url.getParameter(Constants.PAYLOAD_KEY, Constants.DEFAULT_PAYLOAD));
  server.start();
}

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

public RedisRegistry(URL url) {
  super(url);
  if (url.isAnyHost()) {
    throw new IllegalStateException("registry address == null");

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

if (!url.isAnyHost() && NetUtils.isValidLocalHost(bindIp)) {
  connector.setHost(bindIp);

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

@Override
public boolean isAnyHost() {
  return super.isAnyHost();
}

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

@Override
public boolean isAnyHost() {
  return super.isAnyHost();
}

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

public ZookeeperMetadataReport(URL url, ZookeeperTransporter zookeeperTransporter) {
  super(url);
  if (url.isAnyHost()) {
    throw new IllegalStateException("registry address == null");
  }
  String group = url.getParameter(Constants.GROUP_KEY, DEFAULT_ROOT);
  if (!group.startsWith(Constants.PATH_SEPARATOR)) {
    group = Constants.PATH_SEPARATOR + group;
  }
  this.root = group;
  zkClient = zookeeperTransporter.connect(url);
}

代码示例来源：origin: org.apache.dubbo/dubbo-metadata-report-zookeeper

public ZookeeperMetadataReport(URL url, ZookeeperTransporter zookeeperTransporter) {
  super(url);
  if (url.isAnyHost()) {
    throw new IllegalStateException("registry address == null");
  }
  String group = url.getParameter(Constants.GROUP_KEY, DEFAULT_ROOT);
  if (!group.startsWith(Constants.PATH_SEPARATOR)) {
    group = Constants.PATH_SEPARATOR + group;
  }
  this.root = group;
  zkClient = zookeeperTransporter.connect(url);
}

代码示例来源：origin: org.apache.dubbo/dubbo-rpc-rest

@Override
protected void doStart(URL url) {
  String bindIp = url.getParameter(Constants.BIND_IP_KEY, url.getHost());
  if (!url.isAnyHost() && NetUtils.isValidLocalHost(bindIp)) {
    server.setHostname(bindIp);
  }
  server.setPort(url.getParameter(Constants.BIND_PORT_KEY, url.getPort()));
  Map<ChannelOption, Object> channelOption = new HashMap<ChannelOption, Object>();
  channelOption.put(ChannelOption.SO_KEEPALIVE, url.getParameter(Constants.KEEP_ALIVE_KEY, Constants.DEFAULT_KEEP_ALIVE));
  server.setChildChannelOptions(channelOption);
  server.setExecutorThreadCount(url.getParameter(Constants.THREADS_KEY, Constants.DEFAULT_THREADS));
  server.setIoWorkerCount(url.getParameter(Constants.IO_THREADS_KEY, Constants.DEFAULT_IO_THREADS));
  server.setMaxRequestSize(url.getParameter(Constants.PAYLOAD_KEY, Constants.DEFAULT_PAYLOAD));
  server.start();
}

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

@Override
protected void doStart(URL url) {
  String bindIp = url.getParameter(Constants.BIND_IP_KEY, url.getHost());
  if (!url.isAnyHost() && NetUtils.isValidLocalHost(bindIp)) {
    server.setHostname(bindIp);
  }
  server.setPort(url.getParameter(Constants.BIND_PORT_KEY, url.getPort()));
  Map<ChannelOption, Object> channelOption = new HashMap<ChannelOption, Object>();
  channelOption.put(ChannelOption.SO_KEEPALIVE, url.getParameter(Constants.KEEP_ALIVE_KEY, Constants.DEFAULT_KEEP_ALIVE));
  server.setChildChannelOptions(channelOption);
  server.setExecutorThreadCount(url.getParameter(Constants.THREADS_KEY, Constants.DEFAULT_THREADS));
  server.setIoWorkerCount(url.getParameter(Constants.IO_THREADS_KEY, Constants.DEFAULT_IO_THREADS));
  server.setMaxRequestSize(url.getParameter(Constants.PAYLOAD_KEY, Constants.DEFAULT_PAYLOAD));
  server.start();
}

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

URL

相关文章

    查看更多

    热门标签

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

    最新文章

    更多

    URL类方法

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