com.alibaba.dubbo.common.Version类的使用及代码示例

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

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

Version介绍

[英]Version
[中]版本

代码示例

代码示例来源：origin: alibaba/dubbo-spring-boot-starter

private String buildBannerText() {
  StringBuilder bannerTextBuilder = new StringBuilder();
  bannerTextBuilder.append(DubboSpringBootStarterConstants.LINE_SEPARATOR).append(DubboLogo.dubbo)
    .append(" :: Dubbo ::        (v").append(Version.getVersion()).append(")")
    .append(DubboSpringBootStarterConstants.LINE_SEPARATOR);
  return bannerTextBuilder.toString();
 }
}

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

Map<Object, Object> attributes = new HashMap<Object, Object>();
map.put(Constants.SIDE_KEY, Constants.CONSUMER_SIDE);
map.put(Constants.DUBBO_VERSION_KEY, Version.getProtocolVersion());
map.put(Constants.TIMESTAMP_KEY, String.valueOf(System.currentTimeMillis()));
if (ConfigUtils.getPid() > 0) {
  String revision = Version.getVersion(interfaceClass, version);
  if (revision != null && revision.length() > 0) {
    map.put("revision", revision);

代码示例来源：origin: stackoverflow.com

public void incrementVersion() {
   Version lastUpdate = (Version) em.createQuery("SELECT max (c.version) FROM X c")          .setMaxResults(1).getResultList();
   int ver = lastUpdate.getVersion() + 1;
   lastUpdate.setVersion(ver);
   em.persist(lastUpdate);
 }

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

appendParameters(map, config);
map.put("path", RegistryService.class.getName());
map.put("dubbo", Version.getProtocolVersion());
map.put(Constants.TIMESTAMP_KEY, String.valueOf(System.currentTimeMillis()));
if (ConfigUtils.getPid() > 0) {

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

private ExchangeServer createServer(URL url) {
  // 默认开启server关闭时发送readonly事件
  url = url.addParameterIfAbsent(Constants.CHANNEL_READONLYEVENT_SENT_KEY, Boolean.TRUE.toString());
  // 默认开启heartbeat
  url = url.addParameterIfAbsent(Constants.HEARTBEAT_KEY, String.valueOf(Constants.DEFAULT_HEARTBEAT));
  String str = url.getParameter(Constants.SERVER_KEY, Constants.DEFAULT_REMOTING_SERVER);
  if (str != null && str.length() > 0 && !ExtensionExtendUtil.hasExtension(Transporter.class, str))
    throw new JahhanException("Unsupported server type: " + str + ", url: " + url);
  url = url.addParameter(Constants.CODEC_KEY,
      Version.isCompatibleVersion() ? COMPATIBLE_CODEC_NAME : DubboCodec.NAME);
  ExchangeServer server;
  try {
    server = Exchangers.bind(url, requestHandler);
  } catch (RemotingException e) {
    throw new JahhanException("Fail to start server(url: " + url + ") " + e.getMessage(), e);
  }
  str = url.getParameter(Constants.CLIENT_KEY);
  if (str != null && str.length() > 0) {
    Set<String> supportedTypes = ExtensionExtendUtil.getSupportedExtensions(Transporter.class);
    if (!supportedTypes.contains(str)) {
      throw new JahhanException("Unsupported client type: " + str);
    }
  }
  return server;
}

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

public static void checkDuplicate(Class<?> cls) {
  checkDuplicate(cls, false);
}

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

@Override
  protected void encodeResponseData(Channel channel, ObjectOutput out, Object data, String version) throws IOException {
    Result result = (Result) data;
    // currently, the version value in Response records the version of Request
    boolean attach = Version.isSupportResponseAttatchment(version);
    Throwable th = result.getException();
    if (th == null) {
      Object ret = result.getValue();
      if (ret == null) {
        out.writeByte(attach ? RESPONSE_NULL_VALUE_WITH_ATTACHMENTS : RESPONSE_NULL_VALUE);
      } else {
        out.writeByte(attach ? RESPONSE_VALUE_WITH_ATTACHMENTS : RESPONSE_VALUE);
        out.writeObject(ret);
      }
    } else {
      out.writeByte(attach ? RESPONSE_WITH_EXCEPTION_WITH_ATTACHMENTS : RESPONSE_WITH_EXCEPTION);
      out.writeObject(th);
    }

    if (attach) {
      // returns current version of Response to consumer side.
      result.getAttachments().put(Constants.DUBBO_VERSION_KEY, Version.getProtocolVersion());
      out.writeObject(result.getAttachments());
    }
  }
}

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

Map<Object, Object> attributes = new HashMap<Object, Object>();
map.put(Constants.SIDE_KEY, Constants.CONSUMER_SIDE);
map.put(Constants.DUBBO_VERSION_KEY, Version.getProtocolVersion());
map.put(Constants.TIMESTAMP_KEY, String.valueOf(System.currentTimeMillis()));
if (ConfigUtils.getPid() > 0) {
  String revision = Version.getVersion(interfaceClass, version);
  if (revision != null && revision.length() > 0) {
    map.put("revision", revision);

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

appendParameters(map, config);
map.put("path", RegistryService.class.getName());
map.put("dubbo", Version.getProtocolVersion());
map.put(Constants.TIMESTAMP_KEY, String.valueOf(System.currentTimeMillis()));
if (ConfigUtils.getPid() > 0) {

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

private ExchangeServer createServer(URL url) {
  //默认开启server关闭时发送readonly事件
  url = url.addParameterIfAbsent(Constants.CHANNEL_READONLYEVENT_SENT_KEY, Boolean.TRUE.toString());
  //默认开启heartbeat
  url = url.addParameterIfAbsent(Constants.HEARTBEAT_KEY, String.valueOf(Constants.DEFAULT_HEARTBEAT));
  String str = url.getParameter(Constants.SERVER_KEY, Constants.DEFAULT_REMOTING_SERVER);
  if (str != null && str.length() > 0 && ! ExtensionLoader.getExtensionLoader(Transporter.class).hasExtension(str))
    throw new RpcException("Unsupported server type: " + str + ", url: " + url);
  url = url.addParameter(Constants.CODEC_KEY, Version.isCompatibleVersion() ? COMPATIBLE_CODEC_NAME : DubboCodec.NAME);
  ExchangeServer server;
  try {
    server = Exchangers.bind(url, requestHandler);
  } catch (RemotingException e) {
    throw new RpcException("Fail to start server(url: " + url + ") " + e.getMessage(), e);
  }
  str = url.getParameter(Constants.CLIENT_KEY);
  if (str != null && str.length() > 0) {
    Set<String> supportedTypes = ExtensionLoader.getExtensionLoader(Transporter.class).getSupportedExtensions();
    if (!supportedTypes.contains(str)) {
      throw new RpcException("Unsupported client type: " + str);
    }
  }
  return server;
}

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

public static void checkDuplicate(Class<?> cls) {
  checkDuplicate(cls, false);
}

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

@ReadOperation
public Map<String, Object> invoke() {
  Map<String, Object> metaData = new LinkedHashMap<>();
  metaData.put("timestamp", System.currentTimeMillis());
  Map<String, String> versions = new LinkedHashMap<>();
  versions.put("dubbo-spring-boot", Version.getVersion(DubboUtils.class, "1.0.0"));
  versions.put("dubbo", Version.getVersion());
  Map<String, String> urls = new LinkedHashMap<>();
  urls.put("dubbo", DUBBO_GITHUB_URL);
  urls.put("mailing-list", DUBBO_MAILING_LIST);
  urls.put("github", DUBBO_SPRING_BOOT_GITHUB_URL);
  urls.put("issues", DUBBO_SPRING_BOOT_ISSUES_URL);
  urls.put("git", DUBBO_SPRING_BOOT_GIT_URL);
  metaData.put("versions", versions);
  metaData.put("urls", urls);
  return metaData;
}

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

map.put(Constants.DUBBO_VERSION_KEY, Version.getProtocolVersion());
map.put(Constants.TIMESTAMP_KEY, String.valueOf(System.currentTimeMillis()));
if (ConfigUtils.getPid() > 0) {
  map.put(Constants.METHODS_KEY, Constants.ANY_VALUE);
} else {
  String revision = Version.getVersion(interfaceClass, version);
  if (revision != null && revision.length() > 0) {
    map.put("revision", revision);

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

Map<String, String> map = new HashMap<String, String>();
map.put(Constants.INTERFACE_KEY, MonitorService.class.getName());
map.put("dubbo", Version.getProtocolVersion());
map.put(Constants.TIMESTAMP_KEY, String.valueOf(System.currentTimeMillis()));
if (ConfigUtils.getPid() > 0) {

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

private ExchangeServer createServer(URL url) {
  //默认开启server关闭时发送readonly事件
  url = url.addParameterIfAbsent(Constants.CHANNEL_READONLYEVENT_SENT_KEY, Boolean.TRUE.toString());
  //默认开启heartbeat
  url = url.addParameterIfAbsent(Constants.HEARTBEAT_KEY, String.valueOf(Constants.DEFAULT_HEARTBEAT));
  String str = url.getParameter(Constants.SERVER_KEY, Constants.DEFAULT_REMOTING_SERVER);
  if (str != null && str.length() > 0 && ! ExtensionLoader.getExtensionLoader(Transporter.class).hasExtension(str))
    throw new RpcException("Unsupported server type: " + str + ", url: " + url);
  url = url.addParameter(Constants.CODEC_KEY, Version.isCompatibleVersion() ? COMPATIBLE_CODEC_NAME : DubboCodec.NAME);
  ExchangeServer server;
  try {
    server = Exchangers.bind(url, requestHandler);
  } catch (RemotingException e) {
    throw new RpcException("Fail to start server(url: " + url + ") " + e.getMessage(), e);
  }
  str = url.getParameter(Constants.CLIENT_KEY);
  if (str != null && str.length() > 0) {
    Set<String> supportedTypes = ExtensionLoader.getExtensionLoader(Transporter.class).getSupportedExtensions();
    if (!supportedTypes.contains(str)) {
      throw new RpcException("Unsupported client type: " + str);
    }
  }
  return server;
}

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

public static void checkDuplicate(Class<?> cls) {
  checkDuplicate(cls, false);
}

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

String buildBannerText() {
  StringBuilder bannerTextBuilder = new StringBuilder();
  bannerTextBuilder
      .append(LINE_SEPARATOR)
      .append(LINE_SEPARATOR)
      .append(" :: Dubbo Spring Boot (v").append(Version.getVersion(getClass(), "1.0.0")).append(") : ")
      .append(DUBBO_SPRING_BOOT_GITHUB_URL)
      .append(LINE_SEPARATOR)
      .append(" :: Dubbo (v").append(Version.getVersion()).append(") : ")
      .append(DUBBO_GITHUB_URL)
      .append(LINE_SEPARATOR)
      .append(" :: Discuss group : ")
      .append(DUBBO_MAILING_LIST)
      .append(LINE_SEPARATOR)
  ;
  return bannerTextBuilder.toString();
}

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

map.put(Constants.DUBBO_VERSION_KEY, Version.getProtocolVersion());
map.put(Constants.TIMESTAMP_KEY, String.valueOf(System.currentTimeMillis()));
if (ConfigUtils.getPid() > 0) {
  map.put(Constants.METHODS_KEY, Constants.ANY_VALUE);
} else {
  String revision = Version.getVersion(interfaceClass, version);
  if (revision != null && revision.length() > 0) {
    map.put("revision", revision);

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

Map<String, String> map = new HashMap<String, String>();
map.put(Constants.INTERFACE_KEY, MonitorService.class.getName());
map.put("dubbo", Version.getProtocolVersion());
map.put(Constants.TIMESTAMP_KEY, String.valueOf(System.currentTimeMillis()));
if (ConfigUtils.getPid() > 0) {

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

private ExchangeServer createServer(URL url) {
  //默认开启server关闭时发送readonly事件
  url = url.addParameterIfAbsent(Constants.CHANNEL_READONLYEVENT_SENT_KEY, Boolean.TRUE.toString());
  //默认开启heartbeat
  url = url.addParameterIfAbsent(Constants.HEARTBEAT_KEY, String.valueOf(Constants.DEFAULT_HEARTBEAT));
  String str = url.getParameter(Constants.SERVER_KEY, Constants.DEFAULT_REMOTING_SERVER);
  if (str != null && str.length() > 0 && ! ExtensionLoader.getExtensionLoader(Transporter.class).hasExtension(str))
    throw new RpcException("Unsupported server type: " + str + ", url: " + url);
  url = url.addParameter(Constants.CODEC_KEY, Version.isCompatibleVersion() ? COMPATIBLE_CODEC_NAME : DubboCodec.NAME);
  ExchangeServer server;
  try {
    server = Exchangers.bind(url, requestHandler);
  } catch (RemotingException e) {
    throw new RpcException("Fail to start server(url: " + url + ") " + e.getMessage(), e);
  }
  str = url.getParameter(Constants.CLIENT_KEY);
  if (str != null && str.length() > 0) {
    Set<String> supportedTypes = ExtensionLoader.getExtensionLoader(Transporter.class).getSupportedExtensions();
    if (!supportedTypes.contains(str)) {
      throw new RpcException("Unsupported client type: " + str);
    }
  }
  return server;
}

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

version

相关文章

    查看更多

    热门标签

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

    最新文章

    更多
    • 蜀ICP备2022004421号-2 NULL123 https://www.null123.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com