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

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

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

URL.removeParameters介绍

暂无

代码示例

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

public URL removeParameter(String key) {
  if (key == null || key.length() == 0) {
    return this;
  }
  return removeParameters(key);
}

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

public URL removeParameter(String key) {
  if (key == null || key.length() == 0) {
    return this;
  }
  return removeParameters(key);
}

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

public URL removeParameter(String key) {
  if (key == null || key.length() == 0) {
    return this;
  }
  return removeParameters(key);
}

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

public URL removeParameter(String key) {
  if (key == null || key.length() == 0) {
    return this;
  }
  return removeParameters(key);
}

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

public URL removeParameters(Collection<String> keys) {
  if (keys == null || keys.isEmpty()) {
    return this;
  }
  return removeParameters(keys.toArray(new String[0]));
}

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

public URL removeParameters(Collection<String> keys) {
  if (keys == null || keys.size() == 0) {
    return this;
  }
  return removeParameters(keys.toArray(new String[0]));
}

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

public URL removeParameters(Collection<String> keys) {
  if (keys == null || keys.isEmpty()) {
    return this;
  }
  return removeParameters(keys.toArray(new String[0]));
}

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

public URL removeParameters(Collection<String> keys) {
  if (keys == null || keys.size() == 0) {
    return this;
  }
  return removeParameters(keys.toArray(new String[0]));
}

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

/**
 * Get the key cached in bounds by invoker
 *
 * @param originInvoker
 * @return
 */
private String getCacheKey(final Invoker<?> originInvoker) {
  URL providerUrl = getProviderUrl(originInvoker);
  String key = providerUrl.removeParameters("dynamic", "enabled").toFullString();
  return key;
}

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

/**
 * Get the key cached in bounds by invoker
 *
 * @param originInvoker
 * @return
 */
private String getCacheKey(final Invoker<?> originInvoker) {
  URL providerUrl = getProviderUrl(originInvoker);
  String key = providerUrl.removeParameters("dynamic", "enabled").toFullString();
  return key;
}

代码示例来源:origin: linux-china/dubbo3

/**
 * 获取invoker在bounds中缓存的key
 * @param originInvoker
 * @return
 */
private String getCacheKey(final Invoker<?> originInvoker){
  URL providerUrl = getProviderUrl(originInvoker);
  String key = providerUrl.removeParameters("dynamic", "enabled").toFullString();
  return key;
}

代码示例来源:origin: linux-china/dubbo3

/**
 * 获取invoker在bounds中缓存的key
 * @param originInvoker
 * @return
 */
private String getCacheKey(final Invoker<?> originInvoker){
  URL providerUrl = getProviderUrl(originInvoker);
  String key = providerUrl.removeParameters("dynamic", "enabled").toFullString();
  return key;
}

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

@Override
public Registry getRegistry(URL url) {
  url = url.setPath(RegistryService.class.getName())
      .addParameter(Constants.INTERFACE_KEY, RegistryService.class.getName())
      .removeParameters(Constants.EXPORT_KEY, Constants.REFER_KEY);
  String key = url.toServiceString();
  // Lock the registry access process to ensure a single instance of the registry
  LOCK.lock();
  try {
    Registry registry = REGISTRIES.get(key);
    if (registry != null) {
      return registry;
    }
    registry = createRegistry(url);
    if (registry == null) {
      throw new IllegalStateException("Can not create registry " + url);
    }
    REGISTRIES.put(key, registry);
    return registry;
  } finally {
    // Release the lock
    LOCK.unlock();
  }
}

代码示例来源:origin: linux-china/dubbo3

public Registry getRegistry(URL url) {
  url = url.setPath(RegistryService.class.getName())
      .addParameter(Constants.INTERFACE_KEY, RegistryService.class.getName())
      .removeParameters(Constants.EXPORT_KEY, Constants.REFER_KEY);
  String key = url.toServiceString();
  // 锁定注册中心获取过程,保证注册中心单一实例
  LOCK.lock();
  try {
    Registry registry = REGISTRIES.get(key);
    if (registry != null) {
      return registry;
    }
    registry = createRegistry(url);
    if (registry == null) {
      throw new IllegalStateException("Can not create registry " + url);
    }
    REGISTRIES.put(key, registry);
    return registry;
  } finally {
    // 释放锁
    LOCK.unlock();
  }
}

代码示例来源:origin: linux-china/dubbo3

public Registry getRegistry(URL url) {
  url = url.setPath(RegistryService.class.getName())
      .addParameter(Constants.INTERFACE_KEY, RegistryService.class.getName())
      .removeParameters(Constants.EXPORT_KEY, Constants.REFER_KEY);
  String key = url.toServiceString();
  // 锁定注册中心获取过程,保证注册中心单一实例
  LOCK.lock();
  try {
    Registry registry = REGISTRIES.get(key);
    if (registry != null) {
      return registry;
    }
    registry = createRegistry(url);
    if (registry == null) {
      throw new IllegalStateException("Can not create registry " + url);
    }
    REGISTRIES.put(key, registry);
    return registry;
  } finally {
    // 释放锁
    LOCK.unlock();
  }
}

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

private URL configureIfMatch(String host, URL url) {
  if (Constants.ANYHOST_VALUE.equals(configuratorUrl.getHost()) || host.equals(configuratorUrl.getHost())) {
    String configApplication = configuratorUrl.getParameter(Constants.APPLICATION_KEY,
        configuratorUrl.getUsername());
    String currentApplication = url.getParameter(Constants.APPLICATION_KEY, url.getUsername());
    if (configApplication == null || Constants.ANY_VALUE.equals(configApplication)
        || configApplication.equals(currentApplication)) {
      Set<String> conditionKeys = new HashSet<String>();
      conditionKeys.add(Constants.CATEGORY_KEY);
      conditionKeys.add(Constants.CHECK_KEY);
      conditionKeys.add(Constants.DYNAMIC_KEY);
      conditionKeys.add(Constants.ENABLED_KEY);
      for (Map.Entry<String, String> entry : configuratorUrl.getParameters().entrySet()) {
        String key = entry.getKey();
        String value = entry.getValue();
        if (key.startsWith("~") || Constants.APPLICATION_KEY.equals(key) || Constants.SIDE_KEY.equals(key)) {
          conditionKeys.add(key);
          if (value != null && !Constants.ANY_VALUE.equals(value)
              && !value.equals(url.getParameter(key.startsWith("~") ? key.substring(1) : key))) {
            return url;
          }
        }
      }
      return doConfigure(url, configuratorUrl.removeParameters(conditionKeys));
    }
  }
  return url;
}

代码示例来源:origin: linux-china/dubbo3

/**
 * 返回注册到注册中心的URL,对URL参数进行一次过滤
 * @param originInvoker
 * @return
 */
private URL getRegistedProviderUrl(final Invoker<?> originInvoker){
  URL providerUrl = getProviderUrl(originInvoker);
  //注册中心看到的地址
  final URL registedProviderUrl = providerUrl.removeParameters(getFilteredKeys(providerUrl)).removeParameter(Constants.MONITOR_KEY);
  return registedProviderUrl;
}

代码示例来源:origin: linux-china/dubbo3

/**
 * 返回注册到注册中心的URL,对URL参数进行一次过滤
 * @param originInvoker
 * @return
 */
private URL getRegistedProviderUrl(final Invoker<?> originInvoker){
  URL providerUrl = getProviderUrl(originInvoker);
  //注册中心看到的地址
  final URL registedProviderUrl = providerUrl.removeParameters(getFilteredKeys(providerUrl)).removeParameter(Constants.MONITOR_KEY);
  return registedProviderUrl;
}

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

/**
 * Return the url that is registered to the registry and filter the url parameter once
 *
 * @param originInvoker
 * @return
 */
private URL getRegisteredProviderUrl(final Invoker<?> originInvoker) {
  URL providerUrl = getProviderUrl(originInvoker);
  //The address you see at the registry
  return providerUrl.removeParameters(getFilteredKeys(providerUrl))
      .removeParameter(Constants.MONITOR_KEY)
      .removeParameter(Constants.BIND_IP_KEY)
      .removeParameter(Constants.BIND_PORT_KEY)
      .removeParameter(QOS_ENABLE)
      .removeParameter(QOS_PORT)
      .removeParameter(ACCEPT_FOREIGN_IP)
      .removeParameter(VALIDATION_KEY);
}

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

/**
 * Return the url that is registered to the registry and filter the url parameter once
 *
 * @param originInvoker
 * @return
 */
private URL getRegisteredProviderUrl(final Invoker<?> originInvoker) {
  URL providerUrl = getProviderUrl(originInvoker);
  //The address you see at the registry
  return providerUrl.removeParameters(getFilteredKeys(providerUrl))
      .removeParameter(Constants.MONITOR_KEY)
      .removeParameter(Constants.BIND_IP_KEY)
      .removeParameter(Constants.BIND_PORT_KEY)
      .removeParameter(QOS_ENABLE)
      .removeParameter(QOS_PORT)
      .removeParameter(ACCEPT_FOREIGN_IP)
      .removeParameter(VALIDATION_KEY);
}

相关文章

微信公众号

最新文章

更多