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

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

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

Version.getVersion介绍

暂无

代码示例

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

private String appendContextMessage(String msg) {
  return " [DUBBO] " + msg + ", dubbo version: " + Version.getVersion() + ", current host: " + NetUtils.getLocalHost();
}

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

private String appendContextMessage(String msg) {
  return " [DUBBO] " + msg + ", dubbo version: " + Version.getVersion() + ", current host: " + NetUtils.getLocalHost();
}

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

static void appendRuntimeParameters(Map<String, String> map) {
  map.put(Constants.DUBBO_VERSION_KEY, Version.getProtocolVersion());
  map.put(Constants.RELEASE_KEY, Version.getVersion());
  map.put(Constants.TIMESTAMP_KEY, String.valueOf(System.currentTimeMillis()));
  if (ConfigUtils.getPid() > 0) {
    map.put(Constants.PID_KEY, String.valueOf(ConfigUtils.getPid()));
  }
}

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

static void appendRuntimeParameters(Map<String, String> map) {
  map.put(Constants.DUBBO_VERSION_KEY, Version.getProtocolVersion());
  map.put(Constants.RELEASE_KEY, Version.getVersion());
  map.put(Constants.TIMESTAMP_KEY, String.valueOf(System.currentTimeMillis()));
  if (ConfigUtils.getPid() > 0) {
    map.put(Constants.PID_KEY, String.valueOf(ConfigUtils.getPid()));
  }
}

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

protected void checkWhetherDestroyed() {
  if (destroyed.get()) {
    throw new RpcException("Rpc cluster invoker for " + getInterface() + " on consumer " + NetUtils.getLocalHost()
        + " use dubbo version " + Version.getVersion()
        + " is now destroyed! Can not invoke any more.");
  }
}

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

protected void checkWhetherDestroyed() {
  if (destroyed.get()) {
    throw new RpcException("Rpc cluster invoker for " + getInterface() + " on consumer " + NetUtils.getLocalHost()
        + " use dubbo version " + Version.getVersion()
        + " is now destroyed! Can not invoke any more.");
  }
}

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

protected void connect() throws RemotingException {
  connectLock.lock();
  try {
    if (isConnected()) {
      return;
    }
    doConnect();
    if (!isConnected()) {
      throw new RemotingException(this, "Failed connect to server " + getRemoteAddress() + " from " + getClass().getSimpleName() + " "
          + NetUtils.getLocalHost() + " using dubbo version " + Version.getVersion()
          + ", cause: Connect wait timeout: " + getConnectTimeout() + "ms.");
    } else {
      if (logger.isInfoEnabled()) {
        logger.info("Successed connect to server " + getRemoteAddress() + " from " + getClass().getSimpleName() + " "
            + NetUtils.getLocalHost() + " using dubbo version " + Version.getVersion()
            + ", channel is " + this.getChannel());
      }
    }
  } catch (RemotingException e) {
    throw e;
  } catch (Throwable e) {
    throw new RemotingException(this, "Failed connect to server " + getRemoteAddress() + " from " + getClass().getSimpleName() + " "
        + NetUtils.getLocalHost() + " using dubbo version " + Version.getVersion()
        + ", cause: " + e.getMessage(), e);
  } finally {
    connectLock.unlock();
  }
}

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

protected void connect() throws RemotingException {
  connectLock.lock();
  try {
    if (isConnected()) {
      return;
    }
    doConnect();
    if (!isConnected()) {
      throw new RemotingException(this, "Failed connect to server " + getRemoteAddress() + " from " + getClass().getSimpleName() + " "
          + NetUtils.getLocalHost() + " using dubbo version " + Version.getVersion()
          + ", cause: Connect wait timeout: " + getConnectTimeout() + "ms.");
    } else {
      if (logger.isInfoEnabled()) {
        logger.info("Successed connect to server " + getRemoteAddress() + " from " + getClass().getSimpleName() + " "
            + NetUtils.getLocalHost() + " using dubbo version " + Version.getVersion()
            + ", channel is " + this.getChannel());
      }
    }
  } catch (RemotingException e) {
    throw e;
  } catch (Throwable e) {
    throw new RemotingException(this, "Failed connect to server " + getRemoteAddress() + " from " + getClass().getSimpleName() + " "
        + NetUtils.getLocalHost() + " using dubbo version " + Version.getVersion()
        + ", cause: " + e.getMessage(), e);
  } finally {
    connectLock.unlock();
  }
}

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

@Override
  public Result doInvoke(Invocation invocation, List<Invoker<T>> invokers, LoadBalance loadbalance) throws RpcException {
    checkInvokers(invokers, invocation);
    Invoker<T> invoker = select(loadbalance, invocation, invokers, null);
    try {
      return invoker.invoke(invocation);
    } catch (Throwable e) {
      if (e instanceof RpcException && ((RpcException) e).isBiz()) { // biz exception.
        throw (RpcException) e;
      }
      throw new RpcException(e instanceof RpcException ? ((RpcException) e).getCode() : 0,
          "Failfast invoke providers " + invoker.getUrl() + " " + loadbalance.getClass().getSimpleName()
              + " select from all providers " + invokers + " for service " + getInterface().getName()
              + " method " + invocation.getMethodName() + " on consumer " + NetUtils.getLocalHost()
              + " use dubbo version " + Version.getVersion()
              + ", but no luck to perform the invocation. Last error is: " + e.getMessage(),
          e.getCause() != null ? e.getCause() : e);
    }
  }
}

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

@Override
  public Result doInvoke(Invocation invocation, List<Invoker<T>> invokers, LoadBalance loadbalance) throws RpcException {
    checkInvokers(invokers, invocation);
    Invoker<T> invoker = select(loadbalance, invocation, invokers, null);
    try {
      return invoker.invoke(invocation);
    } catch (Throwable e) {
      if (e instanceof RpcException && ((RpcException) e).isBiz()) { // biz exception.
        throw (RpcException) e;
      }
      throw new RpcException(e instanceof RpcException ? ((RpcException) e).getCode() : 0,
          "Failfast invoke providers " + invoker.getUrl() + " " + loadbalance.getClass().getSimpleName()
              + " select from all providers " + invokers + " for service " + getInterface().getName()
              + " method " + invocation.getMethodName() + " on consumer " + NetUtils.getLocalHost()
              + " use dubbo version " + Version.getVersion()
              + ", but no luck to perform the invocation. Last error is: " + e.getMessage(),
          e.getCause() != null ? e.getCause() : e);
    }
  }
}

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

protected final void connect() {
  try {
    // Check whether or not it is connected
    if (isAvailable()) {
      return;
    }
    if (logger.isInfoEnabled()) {
      logger.info("Reconnect to registry " + getUrl());
    }
    clientLock.lock();
    try {
      // Double check whether or not it is connected
      if (isAvailable()) {
        return;
      }
      recover();
    } finally {
      clientLock.unlock();
    }
  } catch (Throwable t) { // Ignore all the exceptions and wait for the next retry
    if (getUrl().getParameter(Constants.CHECK_KEY, true)) {
      if (t instanceof RuntimeException) {
        throw (RuntimeException) t;
      }
      throw new RuntimeException(t.getMessage(), t);
    }
    logger.error("Failed to connect to registry " + getUrl().getAddress() + " from provider/consumer " + NetUtils.getLocalHost() + " use dubbo " + Version.getVersion() + ", cause: " + t.getMessage(), t);
  }
}

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

protected void checkInvokers(List<Invoker<T>> invokers, Invocation invocation) {
  if (CollectionUtils.isEmpty(invokers)) {
    throw new RpcException(RpcException.NO_INVOKER_AVAILABLE_AFTER_FILTER, "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: apache/incubator-dubbo

protected void checkInvokers(List<Invoker<T>> invokers, Invocation invocation) {
  if (CollectionUtils.isEmpty(invokers)) {
    throw new RpcException(RpcException.NO_INVOKER_AVAILABLE_AFTER_FILTER, "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: apache/incubator-dubbo

protected final void connect() {
  try {
    // Check whether or not it is connected
    if (isAvailable()) {
      return;
    }
    if (logger.isInfoEnabled()) {
      logger.info("Reconnect to registry " + getUrl());
    }
    clientLock.lock();
    try {
      // Double check whether or not it is connected
      if (isAvailable()) {
        return;
      }
      recover();
    } finally {
      clientLock.unlock();
    }
  } catch (Throwable t) { // Ignore all the exceptions and wait for the next retry
    if (getUrl().getParameter(Constants.CHECK_KEY, true)) {
      if (t instanceof RuntimeException) {
        throw (RuntimeException) t;
      }
      throw new RuntimeException(t.getMessage(), t);
    }
    logger.error("Failed to connect to registry " + getUrl().getAddress() + " from provider/consumer " + NetUtils.getLocalHost() + " use dubbo " + Version.getVersion() + ", cause: " + t.getMessage(), t);
  }
}

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

LOGGER.error("Failed to create stub implementation class " + stub + " in consumer " + NetUtils.getLocalHost() + " use dubbo version " + Version.getVersion() + ", cause: " + t.getMessage(), t);

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

LOGGER.error("Failed to create stub implementation class " + stub + " in consumer " + NetUtils.getLocalHost() + " use dubbo version " + Version.getVersion() + ", cause: " + t.getMessage(), t);

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

NetUtils.getLocalHost() + " use dubbo version " + Version.getVersion() +
", please check status of providers(disabled, not registered or in blacklist).");

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

NetUtils.getLocalHost() + " use dubbo version " + Version.getVersion() +
", please check status of providers(disabled, not registered or in blacklist).");

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

+ ", dubbo version is " + Version.getVersion() + ", this invoker should not be used any longer");

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

+ ", dubbo version is " + Version.getVersion() + ", this invoker should not be used any longer");

相关文章