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

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

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

URL.getServiceKey介绍

暂无

代码示例

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

@Override
public <T> Invoker<T> refer(Class<T> serviceType, URL url) throws RpcException {
  return new InjvmInvoker<T>(serviceType, url, url.getServiceKey(), exporterMap);
}

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

@Override
public <T> Invoker<T> refer(Class<T> serviceType, URL url) throws RpcException {
  return new InjvmInvoker<T>(serviceType, url, url.getServiceKey(), exporterMap);
}

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

public static String getKey(URL url, String methodName, String suffix) {
  return getKey(url.getServiceKey(), methodName, suffix);
}
public static String getKey(Map<String, String> paras, String methodName, String suffix) {

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

public static void registerProvider(Invoker invoker, URL registryUrl, URL providerUrl) {
  ProviderInvokerWrapper wrapperInvoker = new ProviderInvokerWrapper(invoker, registryUrl, providerUrl);
  String serviceUniqueName = providerUrl.getServiceKey();
  Set<ProviderInvokerWrapper> invokers = providerInvokers.get(serviceUniqueName);
  if (invokers == null) {
    providerInvokers.putIfAbsent(serviceUniqueName, new ConcurrentHashSet<ProviderInvokerWrapper>());
    invokers = providerInvokers.get(serviceUniqueName);
  }
  invokers.add(wrapperInvoker);
}

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

public static void registerConsumer(Invoker invoker, URL registryUrl, URL consumerUrl, RegistryDirectory registryDirectory) {
  ConsumerInvokerWrapper wrapperInvoker = new ConsumerInvokerWrapper(invoker, registryUrl, consumerUrl, registryDirectory);
  String serviceUniqueName = consumerUrl.getServiceKey();
  Set<ConsumerInvokerWrapper> invokers = consumerInvokers.get(serviceUniqueName);
  if (invokers == null) {
    consumerInvokers.putIfAbsent(serviceUniqueName, new ConcurrentHashSet<ConsumerInvokerWrapper>());
    invokers = consumerInvokers.get(serviceUniqueName);
  }
  invokers.add(wrapperInvoker);
}

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

public static void registerProvider(Invoker invoker, URL registryUrl, URL providerUrl) {
  ProviderInvokerWrapper wrapperInvoker = new ProviderInvokerWrapper(invoker, registryUrl, providerUrl);
  String serviceUniqueName = providerUrl.getServiceKey();
  Set<ProviderInvokerWrapper> invokers = providerInvokers.get(serviceUniqueName);
  if (invokers == null) {
    providerInvokers.putIfAbsent(serviceUniqueName, new ConcurrentHashSet<ProviderInvokerWrapper>());
    invokers = providerInvokers.get(serviceUniqueName);
  }
  invokers.add(wrapperInvoker);
}

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

public static void registerConsumer(Invoker invoker, URL registryUrl, URL consumerUrl, RegistryDirectory registryDirectory) {
  ConsumerInvokerWrapper wrapperInvoker = new ConsumerInvokerWrapper(invoker, registryUrl, consumerUrl, registryDirectory);
  String serviceUniqueName = consumerUrl.getServiceKey();
  Set<ConsumerInvokerWrapper> invokers = consumerInvokers.get(serviceUniqueName);
  if (invokers == null) {
    consumerInvokers.putIfAbsent(serviceUniqueName, new ConcurrentHashSet<ConsumerInvokerWrapper>());
    invokers = consumerInvokers.get(serviceUniqueName);
  }
  invokers.add(wrapperInvoker);
}

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

@SuppressWarnings("unchecked")
@Override
protected <T> Invoker<T> doSelect(List<Invoker<T>> invokers, URL url, Invocation invocation) {
  String methodName = RpcUtils.getMethodName(invocation);
  String key = invokers.get(0).getUrl().getServiceKey() + "." + methodName;
  int identityHashCode = System.identityHashCode(invokers);
  ConsistentHashSelector<T> selector = (ConsistentHashSelector<T>) selectors.get(key);
  if (selector == null || selector.identityHashCode != identityHashCode) {
    selectors.put(key, new ConsistentHashSelector<T>(invokers, methodName, identityHashCode));
    selector = (ConsistentHashSelector<T>) selectors.get(key);
  }
  return selector.select(invocation);
}

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

@SuppressWarnings("unchecked")
@Override
protected <T> Invoker<T> doSelect(List<Invoker<T>> invokers, URL url, Invocation invocation) {
  String methodName = RpcUtils.getMethodName(invocation);
  String key = invokers.get(0).getUrl().getServiceKey() + "." + methodName;
  int identityHashCode = System.identityHashCode(invokers);
  ConsistentHashSelector<T> selector = (ConsistentHashSelector<T>) selectors.get(key);
  if (selector == null || selector.identityHashCode != identityHashCode) {
    selectors.put(key, new ConsistentHashSelector<T>(invokers, methodName, identityHashCode));
    selector = (ConsistentHashSelector<T>) selectors.get(key);
  }
  return selector.select(invocation);
}

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

@Override
public <T> Exporter<T> export(Invoker<T> invoker) throws RpcException {
  return new InjvmExporter<T>(invoker, invoker.getUrl().getServiceKey(), exporterMap);
}

代码示例来源：origin: net.jahhan/dubbo-cluster

@SuppressWarnings("unchecked")
@Override
protected <T> Invoker<T> doSelect(List<Invoker<T>> invokers, URL url, Invocation invocation) {
  String key = invokers.get(0).getUrl().getServiceKey() + "." + invocation.getMethodName();
  int identityHashCode = System.identityHashCode(invokers);
  ConsistentHashSelector<T> selector = (ConsistentHashSelector<T>) selectors.get(key);
  if (selector == null || selector.identityHashCode != identityHashCode) {
    selectors.put(key, new ConsistentHashSelector<T>(invokers, invocation.getMethodName(), identityHashCode));
    selector = (ConsistentHashSelector<T>) selectors.get(key);
  }
  return selector.select(invocation);
}

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

@SuppressWarnings("unchecked")
@Override
protected <T> Invoker<T> doSelect(List<Invoker<T>> invokers, URL url, Invocation invocation) {
  String key = invokers.get(0).getUrl().getServiceKey() + "." + invocation.getMethodName();
  int identityHashCode = System.identityHashCode(invokers);
  ConsistentHashSelector<T> selector = (ConsistentHashSelector<T>) selectors.get(key);
  if (selector == null || selector.getIdentityHashCode() != identityHashCode) {
    selectors.put(key, new ConsistentHashSelector<T>(invokers, invocation.getMethodName(), identityHashCode));
    selector = (ConsistentHashSelector<T>) selectors.get(key);
  }
  return selector.select(invocation);
}

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

@SuppressWarnings("unchecked")
@Override
protected <T> Invoker<T> doSelect(List<Invoker<T>> invokers, URL url, Invocation invocation) {
  String key = invokers.get(0).getUrl().getServiceKey() + "." + invocation.getMethodName();
  int identityHashCode = System.identityHashCode(invokers);
  ConsistentHashSelector<T> selector = (ConsistentHashSelector<T>) selectors.get(key);
  if (selector == null || selector.getIdentityHashCode() != identityHashCode) {
    selectors.put(key, new ConsistentHashSelector<T>(invokers, invocation.getMethodName(), identityHashCode));
    selector = (ConsistentHashSelector<T>) selectors.get(key);
  }
  return selector.select(invocation);
}

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

public JCache(URL url) {
  String type = url.getParameter("jcache");
  CacheManager cacheManager = type == null || type.length() == 0 ? Caching.getCacheManager() : Caching.getCacheManager(type);
  CacheBuilder<Object, Object> cacheBuilder = cacheManager.createCacheBuilder(url.getServiceKey());
  this.store = cacheBuilder.build();
}

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

public JCache(URL url) {
  String type = url.getParameter("jcache");
  CacheManager cacheManager = type == null || type.length() == 0 ? Caching.getCacheManager() : Caching.getCacheManager(type);
  CacheBuilder<Object, Object> cacheBuilder = cacheManager.createCacheBuilder(url.getServiceKey());
  this.store = cacheBuilder.build();
}

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

protected void checkInvokers(List<Invoker<T>> invokers, Invocation invocation) {
  if (invokers == null || invokers.isEmpty()) {
    throw new RpcException("Failed to invoke the method "
        + invocation.getMethodName() + " in the service " + getInterface().getName()
        + ". No provider available for the service " + directory.getUrl().getServiceKey()
        + " from registry " + directory.getUrl().getAddress()
        + " on the consumer " + NetUtils.getLocalHost()
        + " using the dubbo version " + Version.getVersion()
        + ". Please check if the providers have been started and registered.");
  }
}

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

protected void checkInvokers(List<Invoker<T>> invokers, Invocation invocation) {
  if (invokers == null || invokers.isEmpty()) {
    throw new RpcException("Failed to invoke the method "
        + invocation.getMethodName() + " in the service " + getInterface().getName()
        + ". No provider available for the service " + directory.getUrl().getServiceKey()
        + " from registry " + directory.getUrl().getAddress()
        + " on the consumer " + NetUtils.getLocalHost()
        + " using the dubbo version " + Version.getVersion()
        + ". Please check if the providers have been started and registered.");
  }
}

代码示例来源：origin: net.jahhan/dubbo-cluster

protected void checkInvokers(List<Invoker<T>> invokers, Invocation invocation) {
  if (invokers == null || invokers.size() == 0) {
    throw new JahhanException("Failed to invoke the method " + invocation.getMethodName()
        + " in the service " + getInterface().getName() + ". No provider available for the service "
        + directory.getUrl().getServiceKey() + " from registry " + directory.getUrl().getAddress()
        + " on the consumer " + NetUtils.getLocalHost() + " using the dubbo version " + Version.getVersion()
        + ". Please check if the providers have been started and registered.");
  }
}

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

protected void checkInvokers(List<Invoker<T>> invokers, Invocation invocation) {
  if (invokers == null || invokers.size() == 0) {
    throw new RpcException("Failed to invoke the method "
        + invocation.getMethodName() + " in the service " + getInterface().getName() 
        + ". No provider available for the service " + directory.getUrl().getServiceKey()
        + " from registry " + directory.getUrl().getAddress() 
        + " on the consumer " + NetUtils.getLocalHost()
        + " using the dubbo version " + Version.getVersion()
        + ". Please check if the providers have been started and registered.");
  }
}

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

protected void checkInvokers(List<Invoker<T>> invokers, Invocation invocation) {
  if (invokers == null || invokers.size() == 0) {
    throw new RpcException("Failed to invoke the method "
        + invocation.getMethodName() + " in the service " + getInterface().getName() 
        + ". No provider available for the service " + directory.getUrl().getServiceKey()
        + " from registry " + directory.getUrl().getAddress() 
        + " on the consumer " + NetUtils.getLocalHost()
        + " using the dubbo version " + Version.getVersion()
        + ". Please check if the providers have been started and registered.");
  }
}

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

URL

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

    更多

    URL类方法

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