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

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

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

URL.getProtocol介绍

暂无

代码示例

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

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: com.alibaba/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: linux-china/dubbo3

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: com.alibaba/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: net.jahhan/dubbo-rpc-api

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

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

@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: linux-china/dubbo3

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: linux-china/dubbo3

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: linux-china/dubbo3

@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);
  throw new RejectedExecutionException(msg);
}

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

@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);
  throw new RejectedExecutionException(msg);
}

代码示例来源：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

@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: com.alibaba/dubbo

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

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

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

代码示例来源：origin: com.alibaba/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 new ListenerInvokerWrapper<T>(protocol.refer(type, url),
      Collections.unmodifiableList(
          ExtensionLoader.getExtensionLoader(InvokerListener.class)
              .getActivateExtension(url, Constants.INVOKER_LISTENER_KEY)));
}

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

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: 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: com.alibaba/dubbo-remoting-p2p

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

代码示例来源：origin: com.alibaba/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: com.alibaba/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 new ListenerExporterWrapper<T>(protocol.export(invoker),
      Collections.unmodifiableList(ExtensionLoader.getExtensionLoader(ExporterListener.class)
          .getActivateExtension(invoker.getUrl(), Constants.EXPORTER_LISTENER_KEY)));
}

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

URL

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

    更多

    URL类方法

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