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

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

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

URL.setProtocol介绍

暂无

代码示例

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

protected static List<URL> filterEmpty(URL url, List<URL> urls) {
  if (urls == null || urls.size() == 0) {
    List<URL> result = new ArrayList<URL>(1);
    result.add(url.setProtocol(Constants.EMPTY_PROTOCOL));
    return result;
  }
  return urls;
}

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

protected static List<URL> filterEmpty(URL url, List<URL> urls) {
  if (urls == null || urls.isEmpty()) {
    List<URL> result = new ArrayList<URL>(1);
    result.add(url.setProtocol(Constants.EMPTY_PROTOCOL));
    return result;
  }
  return urls;
}

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

protected static List<URL> filterEmpty(URL url, List<URL> urls) {
  if (urls == null || urls.isEmpty()) {
    List<URL> result = new ArrayList<URL>(1);
    result.add(url.setProtocol(Constants.EMPTY_PROTOCOL));
    return result;
  }
  return urls;
}

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

protected static List<URL> filterEmpty(URL url, List<URL> urls) {
  if (urls == null || urls.size() == 0) {
    List<URL> result = new ArrayList<URL>(1);
    result.add(url.setProtocol(Constants.EMPTY_PROTOCOL));
    return result;
  }
  return urls;
}

代码示例来源：origin: dubboclub/dubbo-plus

@Override
public <T> Invoker<T> refer(Class<T> type, URL url) throws RpcException {
  if(!REFER_MAPPER.containsKey(type)){
    REFER_MAPPER.put(type,new RestfulInvoker(url.setProtocol("http"),type));
  }
  return (Invoker<T>) REFER_MAPPER.get(type);
}

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

private URL getSubscribedOverrideUrl(URL registedProviderUrl) {
  return registedProviderUrl.setProtocol(Constants.PROVIDER_PROTOCOL)
      .addParameters(Constants.CATEGORY_KEY, Constants.CONFIGURATORS_CATEGORY,
          Constants.CHECK_KEY, String.valueOf(false));
}

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

private URL getSubscribedOverrideUrl(URL registedProviderUrl) {
  return registedProviderUrl.setProtocol(Constants.PROVIDER_PROTOCOL)
      .addParameters(Constants.CATEGORY_KEY, Constants.CONFIGURATORS_CATEGORY,
          Constants.CHECK_KEY, String.valueOf(false));
}

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

private URL getSubscribedOverrideUrl(URL registedProviderUrl){
  return registedProviderUrl.setProtocol(Constants.PROVIDER_PROTOCOL)
      .addParameters(Constants.CATEGORY_KEY, Constants.CONFIGURATORS_CATEGORY, 
          Constants.CHECK_KEY, String.valueOf(false));
}

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

private URL getSubscribedOverrideUrl(URL registedProviderUrl){
  return registedProviderUrl.setProtocol(Constants.PROVIDER_PROTOCOL)
      .addParameters(Constants.CATEGORY_KEY, Constants.CONFIGURATORS_CATEGORY, 
          Constants.CHECK_KEY, String.valueOf(false));
}

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

private List<URL> toUrlsWithEmpty(URL consumer, String path, List<String> providers) {
  List<URL> urls = toUrlsWithoutEmpty(consumer, providers);
  if (urls == null || urls.isEmpty()) {
    int i = path.lastIndexOf('/');
    String category = i < 0 ? path : path.substring(i + 1);
    URL empty = consumer.setProtocol(Constants.EMPTY_PROTOCOL).addParameter(Constants.CATEGORY_KEY, category);
    urls.add(empty);
  }
  return urls;
}

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

private List<URL> toUrlsWithEmpty(URL consumer, String path, List<String> providers) {
  List<URL> urls = toUrlsWithoutEmpty(consumer, providers);
  if (urls.isEmpty()) {
    int i = path.lastIndexOf('/');
    String category = i < 0 ? path : path.substring(i + 1);
    URL empty = consumer.setProtocol(Constants.EMPTY_PROTOCOL).addParameter(Constants.CATEGORY_KEY, category);
    urls.add(empty);
  }
  return urls;
}

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

private List<URL> toUrlsWithEmpty(URL consumer, String path, List<String> providers) {
  List<URL> urls = toUrlsWithoutEmpty(consumer, providers);
  if (urls.isEmpty()) {
    int i = path.lastIndexOf('/');
    String category = i < 0 ? path : path.substring(i + 1);
    URL empty = consumer.setProtocol(Constants.EMPTY_PROTOCOL).addParameter(Constants.CATEGORY_KEY, category);
    urls.add(empty);
  }
  return urls;
}

代码示例来源：origin: io.eventcenter/ec-remote-dubbo

private URL buildProviderURL(URL url){
  URL copied = URL.valueOf(url.toFullString());
  copied.setProtocol(Constants.DUBBO_VERSION_KEY);
  return copied;
}

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

private URL getRegistryUrl(Invoker<?> originInvoker) {
  URL registryUrl = originInvoker.getUrl();
  if (Constants.REGISTRY_PROTOCOL.equals(registryUrl.getProtocol())) {
    String protocol = registryUrl.getParameter(Constants.REGISTRY_KEY, Constants.DEFAULT_DIRECTORY);
    registryUrl = registryUrl.setProtocol(protocol).removeParameter(Constants.REGISTRY_KEY);
  }
  return registryUrl;
}

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

private URL getRegistryUrl(Invoker<?> originInvoker) {
  URL registryUrl = originInvoker.getUrl();
  if (Constants.REGISTRY_PROTOCOL.equals(registryUrl.getProtocol())) {
    String protocol = registryUrl.getParameter(Constants.REGISTRY_KEY, Constants.DEFAULT_DIRECTORY);
    registryUrl = registryUrl.setProtocol(protocol).removeParameter(Constants.REGISTRY_KEY);
  }
  return registryUrl;
}

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

/**
 * 根据invoker的地址获取registry实例
 * @param originInvoker
 * @return
 */
private Registry getRegistry(final Invoker<?> originInvoker){
  URL registryUrl = originInvoker.getUrl();
  if (Constants.REGISTRY_PROTOCOL.equals(registryUrl.getProtocol())) {
    String protocol = registryUrl.getParameter(Constants.REGISTRY_KEY, Constants.DEFAULT_DIRECTORY);
    registryUrl = registryUrl.setProtocol(protocol).removeParameter(Constants.REGISTRY_KEY);
  }
  return registryFactory.getRegistry(registryUrl);
}

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

/**
 * 根据invoker的地址获取registry实例
 * @param originInvoker
 * @return
 */
private Registry getRegistry(final Invoker<?> originInvoker){
  URL registryUrl = originInvoker.getUrl();
  if (Constants.REGISTRY_PROTOCOL.equals(registryUrl.getProtocol())) {
    String protocol = registryUrl.getParameter(Constants.REGISTRY_KEY, Constants.DEFAULT_DIRECTORY);
    registryUrl = registryUrl.setProtocol(protocol).removeParameter(Constants.REGISTRY_KEY);
  }
  return registryFactory.getRegistry(registryUrl);
}

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

@SuppressWarnings({"unchecked", "rawtypes"})
private void exportLocal(URL url) {
  if (!Constants.LOCAL_PROTOCOL.equalsIgnoreCase(url.getProtocol())) {
    URL local = URL.valueOf(url.toFullString())
        .setProtocol(Constants.LOCAL_PROTOCOL)
        .setHost(LOCALHOST)
        .setPort(0);
    ServiceClassHolder.getInstance().pushServiceClass(getServiceClass(ref));
    Exporter<?> exporter = protocol.export(
        proxyFactory.getInvoker(ref, (Class) interfaceClass, local));
    exporters.add(exporter);
    logger.info("Export dubbo service " + interfaceClass.getName() + " to local registry");
  }
}

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

@SuppressWarnings({"unchecked", "rawtypes"})
private void exportLocal(URL url) {
  if (!Constants.LOCAL_PROTOCOL.equalsIgnoreCase(url.getProtocol())) {
    URL local = URL.valueOf(url.toFullString())
        .setProtocol(Constants.LOCAL_PROTOCOL)
        .setHost(LOCALHOST)
        .setPort(0);
    ServiceClassHolder.getInstance().pushServiceClass(getServiceClass(ref));
    Exporter<?> exporter = protocol.export(
        proxyFactory.getInvoker(ref, (Class) interfaceClass, local));
    exporters.add(exporter);
    logger.info("Export dubbo service " + interfaceClass.getName() + " to local registry");
  }
}

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

@SuppressWarnings("unchecked")
protected <T> T doRefer(final Class<T> serviceType, URL url) throws RpcException {
  JsonProxyFactoryBean jsonProxyFactoryBean = new JsonProxyFactoryBean();
  jsonProxyFactoryBean.setServiceUrl(url.setProtocol("http").toIdentityString());
  jsonProxyFactoryBean.setServiceInterface(serviceType);
  jsonProxyFactoryBean.afterPropertiesSet();
  return (T) jsonProxyFactoryBean.getObject();
}

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

URL

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

    更多

    URL类方法

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