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

URL.getParameter介绍

暂无

代码示例

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

@Override
  public boolean isRuntime() {
    // We always return true for previously defined Router, that is, old Router doesn't support cache anymore.
//        return true;
    return this.url.getParameter(Constants.RUNTIME_KEY, false);
  }

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

public Statistics(URL url) {
  this.url = url;
  this.application = url.getParameter(MonitorService.APPLICATION);
  this.service = url.getParameter(MonitorService.INTERFACE);
  this.method = url.getParameter(MonitorService.METHOD);
  this.group = url.getParameter(MonitorService.GROUP);
  this.version = url.getParameter(MonitorService.VERSION);
  this.client = url.getParameter(MonitorService.CONSUMER, url.getAddress());
  this.server = url.getParameter(MonitorService.PROVIDER, url.getAddress());
}

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

public AbstractClusterInvoker(Directory<T> directory, URL url) {
  if (directory == null) {
    throw new IllegalArgumentException("service directory == null");
  }
  this.directory = directory;
  //sticky: invoker.isAvailable() should always be checked before using when availablecheck is true.
  this.availablecheck = url.getParameter(Constants.CLUSTER_AVAILABLE_CHECK_KEY, Constants.DEFAULT_CLUSTER_AVAILABLE_CHECK);
}

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

/**
 * @see #getParameter(String, int)
 * @deprecated Replace to <code>getParameter(String, int)</code>
 */
@Deprecated
public int getIntParameter(String key) {
  return getParameter(key, 0);
}

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

public float getPositiveParameter(String key, float defaultValue) {
  if (defaultValue <= 0) {
    throw new IllegalArgumentException("defaultValue <= 0");
  }
  float value = getParameter(key, defaultValue);
  if (value <= 0) {
    return defaultValue;
  }
  return value;
}

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

public MetadataIdentifier(URL url) {
  this.serviceInterface = url.getServiceInterface();
  this.version = url.getParameter(Constants.VERSION_KEY);
  this.group = url.getParameter(Constants.GROUP_KEY);
  this.side = url.getParameter(Constants.SIDE_KEY);
  setApplication(url.getParameter(Constants.APPLICATION_KEY));
}

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

AbstractRetryTask(URL url, FailbackRegistry registry, String taskName) {
  if (url == null || StringUtils.isBlank(taskName)) {
    throw new IllegalArgumentException();
  }
  this.url = url;
  this.registry = registry;
  this.taskName = taskName;
  cancel = false;
  this.retryPeriod = url.getParameter(Constants.REGISTRY_RETRY_PERIOD_KEY, Constants.DEFAULT_REGISTRY_RETRY_PERIOD);
  this.retryTimes = url.getParameter(Constants.REGISTRY_RETRY_TIMES_KEY, Constants.DEFAULT_REGISTRY_RETRY_TIMES);
}

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

protected static String serviceKey(URL url) {
  int port = url.getParameter(Constants.BIND_PORT_KEY, url.getPort());
  return serviceKey(port, url.getPath(), url.getParameter(Constants.VERSION_KEY),
      url.getParameter(Constants.GROUP_KEY));
}

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

@Override
public Executor getExecutor(URL url) {
  String name = url.getParameter(Constants.THREAD_NAME_KEY, Constants.DEFAULT_THREAD_NAME);
  int cores = url.getParameter(Constants.CORE_THREADS_KEY, Constants.DEFAULT_CORE_THREADS);
  int threads = url.getParameter(Constants.THREADS_KEY, Constants.DEFAULT_THREADS);
  int queues = url.getParameter(Constants.QUEUES_KEY, Constants.DEFAULT_QUEUES);
  return new ThreadPoolExecutor(cores, threads, Long.MAX_VALUE, TimeUnit.MILLISECONDS,
      queues == 0 ? new SynchronousQueue<Runnable>() :
          (queues < 0 ? new LinkedBlockingQueue<Runnable>()
              : new LinkedBlockingQueue<Runnable>(queues)),
      new NamedInternalThreadFactory(name, true), new AbortPolicyWithReport(name, url));
}

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

public String getParameter(String key, String defaultValue) {
  String value = getParameter(key);
  if (StringUtils.isEmpty(value)) {
    return defaultValue;
  }
  return value;
}

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

public String[] getParameter(String key, String[] defaultValue) {
  String value = getParameter(key);
  if (StringUtils.isEmpty(value)) {
    return defaultValue;
  }
  return Constants.COMMA_SPLIT_PATTERN.split(value);
}

代码示例来源：origin: apache/incubator-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: apache/incubator-dubbo

public String getParameter(String key, String defaultValue) {
  String value = getParameter(key);
  if (StringUtils.isEmpty(value)) {
    return defaultValue;
  }
  return value;
}

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

public char getParameter(String key, char defaultValue) {
  String value = getParameter(key);
  if (StringUtils.isEmpty(value)) {
    return defaultValue;
  }
  return value.charAt(0);
}

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

/**
 * is consumer side.
 *
 * @return consumer side.
 */
public boolean isConsumerSide() {
  return getUrl().getParameter(Constants.SIDE_KEY, Constants.PROVIDER_SIDE).equals(Constants.CONSUMER_SIDE);
}

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

public ExpiringCache(URL url) {
  // cache time (second)
  final int secondsToLive = url.getParameter("cache.seconds", 180);
  // Cache check interval (second)
  final int intervalSeconds = url.getParameter("cache.interval", 4);
  ExpiringMap<Object, Object> expiringMap = new ExpiringMap<Object, Object>(secondsToLive, intervalSeconds);
  expiringMap.getExpireThread().startExpiryIfNotStarted();
  this.store = expiringMap;
}

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

protected static TProtocol newProtocol(URL url, ChannelBuffer buffer) throws IOException {
  String protocol = url.getParameter(ThriftConstants.THRIFT_PROTOCOL_KEY,
      ThriftConstants.DEFAULT_PROTOCOL);
  if (ThriftConstants.BINARY_THRIFT_PROTOCOL.equals(protocol)) {
    return new TBinaryProtocol(new TIOStreamTransport(new ChannelBufferOutputStream(buffer)));
  }
  throw new IOException("Unsupported protocol type " + protocol);
}

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

public ScriptRouter(URL url) {
  this.url = url;
  this.priority = url.getParameter(Constants.PRIORITY_KEY, 0);
  
  engine = getEngine(url);
  rule = getRule(url);
}

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

public ScriptRouter(URL url) {
  this.url = url;
  this.priority = url.getParameter(Constants.PRIORITY_KEY, 0);
  
  engine = getEngine(url);
  rule = getRule(url);
}

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

private static boolean isInstancesOverLimit(Channel channel, URL url, String interfaceClass, int instid, boolean isServer) {
  Integer count = (Integer) channel.getAttribute(isServer ? getServerSideCountKey(channel, interfaceClass) : getClientSideCountKey(interfaceClass));
  int limit = url.getParameter(Constants.CALLBACK_INSTANCES_LIMIT_KEY, Constants.DEFAULT_CALLBACK_INSTANCES);
  if (count != null && count >= limit) {
    //client side error
    throw new IllegalStateException("interface " + interfaceClass + " `s callback instances num exceed providers limit :" + limit
        + " ,current num: " + (count + 1) + ". The new callback service will not work !!! you can cancle the callback service which exported before. channel :" + channel);
  } else {
    return false;
  }
}