org.apache.dubbo.common.URL.equals()方法的使用及代码示例

x33g5p2x  于2022-02-01 转载在 其他  
字(10.1k)|赞(0)|评价(0)|浏览(83)

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

URL.equals介绍

暂无

代码示例

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

@Override
  public boolean equals(Object obj) {
    if (obj instanceof Holder) {
      Holder h = (Holder) obj;
      return this.url.equals(h.url) && this.notifyListener.equals(h.notifyListener);
    } else {
      return false;
    }
  }
}

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

@Override
  public boolean equals(Object obj) {
    if (obj instanceof Holder) {
      Holder h = (Holder) obj;
      return this.url.equals(h.url) && this.notifyListener.equals(h.notifyListener);
    } else {
      return false;
    }
  }
}

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

public synchronized void doOverrideIfNecessary() {
  final Invoker<?> invoker;
  if (originInvoker instanceof InvokerDelegate) {
    invoker = ((InvokerDelegate<?>) originInvoker).getInvoker();
  } else {
    invoker = originInvoker;
  }
  //The origin invoker
  URL originUrl = RegistryProtocol.this.getProviderUrl(invoker);
  String key = getCacheKey(originInvoker);
  ExporterChangeableWrapper<?> exporter = bounds.get(key);
  if (exporter == null) {
    logger.warn(new IllegalStateException("error state, exporter should not be null"));
    return;
  }
  //The current, may have been merged many times
  URL currentUrl = exporter.getInvoker().getUrl();
  //Merged with this configuration
  URL newUrl = getConfigedInvokerUrl(configurators, originUrl);
  newUrl = getConfigedInvokerUrl(serviceConfigurationListeners.get(originUrl.getServiceKey())
      .getConfigurators(), newUrl);
  newUrl = getConfigedInvokerUrl(providerConfigurationListener.getConfigurators(), newUrl);
  if (!currentUrl.equals(newUrl)) {
    RegistryProtocol.this.reExport(originInvoker, newUrl);
    logger.info("exported provider url changed, origin url: " + originUrl +
        ", old export url: " + currentUrl + ", new export url: " + newUrl);
  }
}

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

public synchronized void doOverrideIfNecessary() {
  final Invoker<?> invoker;
  if (originInvoker instanceof InvokerDelegate) {
    invoker = ((InvokerDelegate<?>) originInvoker).getInvoker();
  } else {
    invoker = originInvoker;
  }
  //The origin invoker
  URL originUrl = RegistryProtocol.this.getProviderUrl(invoker);
  String key = getCacheKey(originInvoker);
  ExporterChangeableWrapper<?> exporter = bounds.get(key);
  if (exporter == null) {
    logger.warn(new IllegalStateException("error state, exporter should not be null"));
    return;
  }
  //The current, may have been merged many times
  URL currentUrl = exporter.getInvoker().getUrl();
  //Merged with this configuration
  URL newUrl = getConfigedInvokerUrl(configurators, originUrl);
  newUrl = getConfigedInvokerUrl(serviceConfigurationListeners.get(originUrl.getServiceKey())
      .getConfigurators(), newUrl);
  newUrl = getConfigedInvokerUrl(providerConfigurationListener.getConfigurators(), newUrl);
  if (!currentUrl.equals(newUrl)) {
    RegistryProtocol.this.reExport(originInvoker, newUrl);
    logger.info("exported provider url changed, origin url: " + originUrl +
        ", old export url: " + currentUrl + ", new export url: " + newUrl);
  }
}

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

public <T> void reExport(final Invoker<T> originInvoker, URL newInvokerUrl) {
  // update local exporter
  ExporterChangeableWrapper exporter = doChangeLocalExport(originInvoker, newInvokerUrl);
  // update registry
  URL registryUrl = getRegistryUrl(originInvoker);
  final URL registeredProviderUrl = getRegisteredProviderUrl(newInvokerUrl, registryUrl);
  //decide if we need to re-publish
  ProviderInvokerWrapper<T> providerInvokerWrapper = ProviderConsumerRegTable.getProviderWrapper(registeredProviderUrl, originInvoker);
  ProviderInvokerWrapper<T> newProviderInvokerWrapper = ProviderConsumerRegTable.registerProvider(originInvoker, registryUrl, registeredProviderUrl);
  /**
   * Only if the new url going to Registry is different with the previous one should we do unregister and register.
   */
  if (providerInvokerWrapper.isReg() && !registeredProviderUrl.equals(providerInvokerWrapper.getProviderUrl())) {
    unregister(registryUrl, providerInvokerWrapper.getProviderUrl());
    register(registryUrl, registeredProviderUrl);
    newProviderInvokerWrapper.setReg(true);
  }
  exporter.setRegisterUrl(registeredProviderUrl);
}

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

public <T> void reExport(final Invoker<T> originInvoker, URL newInvokerUrl) {
  // update local exporter
  ExporterChangeableWrapper exporter = doChangeLocalExport(originInvoker, newInvokerUrl);
  // update registry
  URL registryUrl = getRegistryUrl(originInvoker);
  final URL registeredProviderUrl = getRegisteredProviderUrl(newInvokerUrl, registryUrl);
  //decide if we need to re-publish
  ProviderInvokerWrapper<T> providerInvokerWrapper = ProviderConsumerRegTable.getProviderWrapper(registeredProviderUrl, originInvoker);
  ProviderInvokerWrapper<T> newProviderInvokerWrapper = ProviderConsumerRegTable.registerProvider(originInvoker, registryUrl, registeredProviderUrl);
  /**
   * Only if the new url going to Registry is different with the previous one should we do unregister and register.
   */
  if (providerInvokerWrapper.isReg() && !registeredProviderUrl.equals(providerInvokerWrapper.getProviderUrl())) {
    unregister(registryUrl, providerInvokerWrapper.getProviderUrl());
    register(registryUrl, registeredProviderUrl);
    newProviderInvokerWrapper.setReg(true);
  }
  exporter.setRegisterUrl(registeredProviderUrl);
}

代码示例来源：origin: org.apache.dubbo/dubbo

@Override
  public boolean equals(Object obj) {
    if (obj instanceof Holder) {
      Holder h = (Holder) obj;
      return this.url.equals(h.url) && this.notifyListener.equals(h.notifyListener);
    } else {
      return false;
    }
  }
}

代码示例来源：origin: org.apache.dubbo/dubbo-registry-api

@Override
  public boolean equals(Object obj) {
    if (obj instanceof Holder) {
      Holder h = (Holder) obj;
      return this.url.equals(h.url) && this.notifyListener.equals(h.notifyListener);
    } else {
      return false;
    }
  }
}

代码示例来源：origin: org.apache.dubbo/dubbo-registry-api

public synchronized void doOverrideIfNecessary() {
  final Invoker<?> invoker;
  if (originInvoker instanceof InvokerDelegate) {
    invoker = ((InvokerDelegate<?>) originInvoker).getInvoker();
  } else {
    invoker = originInvoker;
  }
  //The origin invoker
  URL originUrl = RegistryProtocol.this.getProviderUrl(invoker);
  String key = getCacheKey(originInvoker);
  ExporterChangeableWrapper<?> exporter = bounds.get(key);
  if (exporter == null) {
    logger.warn(new IllegalStateException("error state, exporter should not be null"));
    return;
  }
  //The current, may have been merged many times
  URL currentUrl = exporter.getInvoker().getUrl();
  //Merged with this configuration
  URL newUrl = getConfigedInvokerUrl(configurators, originUrl);
  newUrl = getConfigedInvokerUrl(serviceConfigurationListeners.get(originUrl.getServiceKey())
      .getConfigurators(), newUrl);
  newUrl = getConfigedInvokerUrl(providerConfigurationListener.getConfigurators(), newUrl);
  if (!currentUrl.equals(newUrl)) {
    RegistryProtocol.this.reExport(originInvoker, newUrl);
    logger.info("exported provider url changed, origin url: " + originUrl +
        ", old export url: " + currentUrl + ", new export url: " + newUrl);
  }
}

代码示例来源：origin: org.apache.dubbo/dubbo

public synchronized void doOverrideIfNecessary() {
  final Invoker<?> invoker;
  if (originInvoker instanceof InvokerDelegate) {
    invoker = ((InvokerDelegate<?>) originInvoker).getInvoker();
  } else {
    invoker = originInvoker;
  }
  //The origin invoker
  URL originUrl = RegistryProtocol.this.getProviderUrl(invoker);
  String key = getCacheKey(originInvoker);
  ExporterChangeableWrapper<?> exporter = bounds.get(key);
  if (exporter == null) {
    logger.warn(new IllegalStateException("error state, exporter should not be null"));
    return;
  }
  //The current, may have been merged many times
  URL currentUrl = exporter.getInvoker().getUrl();
  //Merged with this configuration
  URL newUrl = getConfigedInvokerUrl(configurators, originUrl);
  newUrl = getConfigedInvokerUrl(serviceConfigurationListeners.get(originUrl.getServiceKey())
      .getConfigurators(), newUrl);
  newUrl = getConfigedInvokerUrl(providerConfigurationListener.getConfigurators(), newUrl);
  if (!currentUrl.equals(newUrl)) {
    RegistryProtocol.this.reExport(originInvoker, newUrl);
    logger.info("exported provider url changed, origin url: " + originUrl +
        ", old export url: " + currentUrl + ", new export url: " + newUrl);
  }
}

代码示例来源：origin: org.apache.dubbo/dubbo-registry-api

public <T> void reExport(final Invoker<T> originInvoker, URL newInvokerUrl) {
  // update local exporter
  ExporterChangeableWrapper exporter = doChangeLocalExport(originInvoker, newInvokerUrl);
  // update registry
  URL registryUrl = getRegistryUrl(originInvoker);
  final URL registeredProviderUrl = getRegisteredProviderUrl(newInvokerUrl, registryUrl);
  //decide if we need to re-publish
  ProviderInvokerWrapper<T> providerInvokerWrapper = ProviderConsumerRegTable.getProviderWrapper(registeredProviderUrl, originInvoker);
  ProviderInvokerWrapper<T> newProviderInvokerWrapper = ProviderConsumerRegTable.registerProvider(originInvoker, registryUrl, registeredProviderUrl);
  /**
   * Only if the new url going to Registry is different with the previous one should we do unregister and register.
   */
  if (providerInvokerWrapper.isReg() && !registeredProviderUrl.equals(providerInvokerWrapper.getProviderUrl())) {
    unregister(registryUrl, providerInvokerWrapper.getProviderUrl());
    register(registryUrl, registeredProviderUrl);
    newProviderInvokerWrapper.setReg(true);
  }
  exporter.setRegisterUrl(registeredProviderUrl);
}

代码示例来源：origin: org.apache.dubbo/dubbo

public <T> void reExport(final Invoker<T> originInvoker, URL newInvokerUrl) {
  // update local exporter
  ExporterChangeableWrapper exporter = doChangeLocalExport(originInvoker, newInvokerUrl);
  // update registry
  URL registryUrl = getRegistryUrl(originInvoker);
  final URL registeredProviderUrl = getRegisteredProviderUrl(newInvokerUrl, registryUrl);
  //decide if we need to re-publish
  ProviderInvokerWrapper<T> providerInvokerWrapper = ProviderConsumerRegTable.getProviderWrapper(registeredProviderUrl, originInvoker);
  ProviderInvokerWrapper<T> newProviderInvokerWrapper = ProviderConsumerRegTable.registerProvider(originInvoker, registryUrl, registeredProviderUrl);
  /**
   * Only if the new url going to Registry is different with the previous one should we do unregister and register.
   */
  if (providerInvokerWrapper.isReg() && !registeredProviderUrl.equals(providerInvokerWrapper.getProviderUrl())) {
    unregister(registryUrl, providerInvokerWrapper.getProviderUrl());
    register(registryUrl, registeredProviderUrl);
    newProviderInvokerWrapper.setReg(true);
  }
  exporter.setRegisterUrl(registeredProviderUrl);
}

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

URL

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

    更多

    URL类方法

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