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

URL.getProtocol介绍

暂无

代码示例

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

public static boolean isProvider(URL url) {
  return !OVERRIDE_PROTOCOL.equals(url.getProtocol()) &&
      !ROUTE_PROTOCOL.equals(url.getProtocol()) &&
      PROVIDERS_CATEGORY.equals(url.getParameter(CATEGORY_KEY, PROVIDERS_CATEGORY));
}

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

String getProtocol(URL url) {
  String protocol = url.getParameter(Constants.SIDE_KEY);
  protocol = protocol == null ? url.getProtocol() : protocol;
  return protocol;
}

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

private <T> boolean hasMockProviders(final List<Invoker<T>> invokers) {
  boolean hasMockProvider = false;
  for (Invoker<T> invoker : invokers) {
    if (invoker.getUrl().getProtocol().equals(Constants.MOCK_PROTOCOL)) {
      hasMockProvider = true;
      break;
    }
  }
  return hasMockProvider;
}

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

String getProtocol(URL url) {
  String protocol = url.getParameter(Constants.SIDE_KEY);
  protocol = protocol == null ? url.getProtocol() : protocol;
  return protocol;
}

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

private <T> List<Invoker<T>> getMockedInvokers(final List<Invoker<T>> invokers) {
  if (!hasMockProviders(invokers)) {
    return null;
  }
  List<Invoker<T>> sInvokers = new ArrayList<Invoker<T>>(1);
  for (Invoker<T> invoker : invokers) {
    if (invoker.getUrl().getProtocol().equals(Constants.MOCK_PROTOCOL)) {
      sInvokers.add(invoker);
    }
  }
  return sInvokers;
}

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

private <T> List<Invoker<T>> getMockedInvokers(final List<Invoker<T>> invokers) {
  if (!hasMockProviders(invokers)) {
    return null;
  }
  List<Invoker<T>> sInvokers = new ArrayList<Invoker<T>>(1);
  for (Invoker<T> invoker : invokers) {
    if (invoker.getUrl().getProtocol().equals(Constants.MOCK_PROTOCOL)) {
      sInvokers.add(invoker);
    }
  }
  return sInvokers;
}

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

private boolean isValidCategory(URL url) {
  String category = url.getParameter(CATEGORY_KEY, DEFAULT_CATEGORY);
  if ((ROUTERS_CATEGORY.equals(category) || ROUTE_PROTOCOL.equals(url.getProtocol())) ||
      PROVIDERS_CATEGORY.equals(category) ||
      CONFIGURATORS_CATEGORY.equals(category) || DYNAMIC_CONFIGURATORS_CATEGORY.equals(category) ||
      APP_DYNAMIC_CONFIGURATORS_CATEGORY.equals(category)) {
    return true;
  }
  logger.warn("Unsupported category " + category + " in notified url: " + url + " from registry " +
      getUrl().getAddress() + " to consumer " + NetUtils.getLocalHost());
  return false;
}

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

@Override
public <T> Invoker<T> refer(Class<T> type, URL url) throws RpcException {
  if (Constants.REGISTRY_PROTOCOL.equals(url.getProtocol())) {
    startQosServer(url);
    return protocol.refer(type, url);
  }
  return protocol.refer(type, url);
}

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

@Override
public <T> Invoker<T> refer(Class<T> type, URL url) throws RpcException {
  if (Constants.REGISTRY_PROTOCOL.equals(url.getProtocol())) {
    startQosServer(url);
    return protocol.refer(type, url);
  }
  return protocol.refer(type, url);
}

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

@Override
public <T> Invoker<T> refer(Class<T> type, URL url) throws RpcException {
  if (Constants.REGISTRY_PROTOCOL.equals(url.getProtocol())) {
    return protocol.refer(type, url);
  }
  return buildInvokerChain(protocol.refer(type, url), Constants.REFERENCE_FILTER_KEY, Constants.CONSUMER);
}

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

@Override
public void rejectedExecution(Runnable r, ThreadPoolExecutor e) {
  String msg = String.format("Thread pool is EXHAUSTED!" +
          " Thread Name: %s, Pool Size: %d (active: %d, core: %d, max: %d, largest: %d), Task: %d (completed: %d)," +
          " Executor status:(isShutdown:%s, isTerminated:%s, isTerminating:%s), in %s://%s:%d!",
      threadName, e.getPoolSize(), e.getActiveCount(), e.getCorePoolSize(), e.getMaximumPoolSize(), e.getLargestPoolSize(),
      e.getTaskCount(), e.getCompletedTaskCount(), e.isShutdown(), e.isTerminated(), e.isTerminating(),
      url.getProtocol(), url.getIp(), url.getPort());
  logger.warn(msg);
  dumpJStack();
  throw new RejectedExecutionException(msg);
}

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

public static ExchangeGroup lookup(URL group) throws RemotingException {
    ExchangeNetworker networker = ExtensionLoader.getExtensionLoader(ExchangeNetworker.class).getExtension(group.getProtocol());
    return networker.lookup(group);
  }
}

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

public static Group lookup(URL group) throws RemotingException {
    Networker networker = ExtensionLoader.getExtensionLoader(Networker.class).getExtension(group.getProtocol());
    return networker.lookup(group);
  }
}

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

@Override
public <T> Exporter<T> export(Invoker<T> invoker) throws RpcException {
  if (Constants.REGISTRY_PROTOCOL.equals(invoker.getUrl().getProtocol())) {
    return protocol.export(invoker);
  }
  return protocol.export(buildInvokerChain(invoker, Constants.SERVICE_FILTER_KEY, Constants.PROVIDER));
}

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

public static ExchangeGroup lookup(URL group) throws RemotingException {
    ExchangeNetworker networker = ExtensionLoader.getExtensionLoader(ExchangeNetworker.class).getExtension(group.getProtocol());
    return networker.lookup(group);
  }
}

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

MetadataReportService(URL metadataReportURL) {
  if (Constants.METADATA_REPORT_KEY.equals(metadataReportURL.getProtocol())) {
    String protocol = metadataReportURL.getParameter(Constants.METADATA_REPORT_KEY, Constants.DEFAULT_DIRECTORY);
    metadataReportURL = metadataReportURL.setProtocol(protocol).removeParameter(Constants.METADATA_REPORT_KEY);
  }
  this.metadataReportUrl = metadataReportURL;
  metadataReport = metadataReportFactory.getMetadataReport(this.metadataReportUrl);
}

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

@Override
public <T> Exporter<T> export(Invoker<T> invoker) throws RpcException {
  if (Constants.REGISTRY_PROTOCOL.equals(invoker.getUrl().getProtocol())) {
    startQosServer(invoker.getUrl());
    return protocol.export(invoker);
  }
  return protocol.export(invoker);
}

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

@Override
public <T> Exporter<T> export(Invoker<T> invoker) throws RpcException {
  if (Constants.REGISTRY_PROTOCOL.equals(invoker.getUrl().getProtocol())) {
    startQosServer(invoker.getUrl());
    return protocol.export(invoker);
  }
  return protocol.export(invoker);
}

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

private DynamicConfiguration getDynamicConfiguration(URL url) {
  DynamicConfigurationFactory factories = ExtensionLoader
      .getExtensionLoader(DynamicConfigurationFactory.class)
      .getExtension(url.getProtocol());
  DynamicConfiguration configuration = factories.getDynamicConfiguration(url);
  Environment.getInstance().setDynamicConfiguration(configuration);
  return configuration;
}

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

public org.apache.dubbo.common.URL getOriginalURL() {
    return new org.apache.dubbo.common.URL(super.getProtocol(), super.getUsername(), super.getPassword(),
        super.getHost(), super.getPort(), super.getPath(), super.getParameters());
  }
}