com.hazelcast.instance.Node.getBuildInfo()方法的使用及代码示例

x33g5p2x  于2022-01-25 转载在 其他  
字(13.5k)|赞(0)|评价(0)|浏览(97)

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

Node.getBuildInfo介绍

暂无

代码示例

代码示例来源：origin: hazelcast/hazelcast-jet

protected final BuildInfo getMemberBuildInfo() {
  return node.getBuildInfo();
}

代码示例来源：origin: com.hazelcast/hazelcast-all

protected final BuildInfo getMemberBuildInfo() {
  return node.getBuildInfo();
}

代码示例来源：origin: hazelcast/hazelcast-jet

private String serializationVersionMessage() {
  return "Configured Hazelcast Serialization version: " + node.getBuildInfo().getSerializationVersion();
}

代码示例来源：origin: hazelcast/hazelcast-jet

private String versionAndAddressMessage(@Nonnull String addToName) {
  JetBuildInfo jetBuildInfo = node.getBuildInfo().getJetBuildInfo();
  String build = jetBuildInfo.getBuild();
  String revision = jetBuildInfo.getRevision();
  if (!revision.isEmpty()) {
    build += " - " + revision;
  }
  return "Hazelcast Jet" + addToName + ' ' + jetBuildInfo.getVersion() +
      " (" + build + ") starting at " + node.getThisAddress();
}

代码示例来源：origin: hazelcast/hazelcast-jet

@ManagedAnnotation("build")
@ManagedDescription("The Hazelcast build")
public String getBuild() {
  return managedObject.node.getBuildInfo().getBuild();
}

代码示例来源：origin: hazelcast/hazelcast-jet

@ManagedAnnotation("version")
@ManagedDescription("The Hazelcast version")
public String getVersion() {
  return managedObject.node.getBuildInfo().getVersion();
}

代码示例来源：origin: com.hazelcast/hazelcast-all

@ManagedAnnotation("build")
@ManagedDescription("The Hazelcast build")
public String getBuild() {
  return managedObject.node.getBuildInfo().getBuild();
}

代码示例来源：origin: com.hazelcast/hazelcast-all

@ManagedAnnotation("version")
@ManagedDescription("The Hazelcast version")
public String getVersion() {
  return managedObject.node.getBuildInfo().getVersion();
}

代码示例来源：origin: hazelcast/hazelcast-jet

@Override
public void writeResponse(ManagementCenterService mcs, JsonObject root) throws Exception {
  Runtime runtime = Runtime.getRuntime();
  RuntimeMXBean runtimeMxBean = ManagementFactory.getRuntimeMXBean();
  IPartitionService partitionService = mcs.getHazelcastInstance().node.getPartitionService();
  JsonObject properties = new JsonObject();
  properties.add("hazelcast.cl_version", mcs.getHazelcastInstance().node.getBuildInfo().getVersion());
  properties.add("date.cl_startTime", Long.toString(runtimeMxBean.getStartTime()));
  properties.add("seconds.cl_upTime", Long.toString(runtimeMxBean.getUptime()));
  properties.add("memory.cl_freeMemory", Long.toString(runtime.freeMemory()));
  properties.add("memory.cl_totalMemory", Long.toString(runtime.totalMemory()));
  properties.add("memory.cl_maxMemory", Long.toString(runtime.maxMemory()));
  properties.add("return.hasOngoingMigration", Boolean.toString(partitionService.hasOnGoingMigration()));
  properties.add("data.cl_migrationTasksCount", Long.toString(partitionService.getMigrationQueueSize()));
  root.add("result", properties);
}

代码示例来源：origin: com.hazelcast/hazelcast-all

@Override
public void writeResponse(ManagementCenterService mcs, JsonObject root) throws Exception {
  Runtime runtime = Runtime.getRuntime();
  RuntimeMXBean runtimeMxBean = ManagementFactory.getRuntimeMXBean();
  IPartitionService partitionService = mcs.getHazelcastInstance().node.getPartitionService();
  JsonObject properties = new JsonObject();
  properties.add("hazelcast.cl_version", mcs.getHazelcastInstance().node.getBuildInfo().getVersion());
  properties.add("date.cl_startTime", Long.toString(runtimeMxBean.getStartTime()));
  properties.add("seconds.cl_upTime", Long.toString(runtimeMxBean.getUptime()));
  properties.add("memory.cl_freeMemory", Long.toString(runtime.freeMemory()));
  properties.add("memory.cl_totalMemory", Long.toString(runtime.totalMemory()));
  properties.add("memory.cl_maxMemory", Long.toString(runtime.maxMemory()));
  properties.add("return.hasOngoingMigration", Boolean.toString(partitionService.hasOnGoingMigration()));
  properties.add("data.cl_migrationTasksCount", Long.toString(partitionService.getMigrationQueueSize()));
  root.add("result", properties);
}

代码示例来源：origin: hazelcast/hazelcast-jet

@Override
public void printNodeInfo() {
  BuildInfo buildInfo = node.getBuildInfo();
  String build = buildInfo.getBuild();
  String revision = buildInfo.getRevision();
  if (!revision.isEmpty()) {
    build += " - " + revision;
  }
  systemLogger.info("Hazelcast " + buildInfo.getVersion()
      + " (" + build + ") starting at " + node.getThisAddress());
  systemLogger.info("Copyright (c) 2008-2019, Hazelcast, Inc. All Rights Reserved.");
  systemLogger.fine("Configured Hazelcast Serialization version: " + buildInfo.getSerializationVersion());
}

代码示例来源：origin: com.hazelcast/hazelcast-all

@Override
public void printNodeInfo() {
  BuildInfo buildInfo = node.getBuildInfo();
  String build = buildInfo.getBuild();
  String revision = buildInfo.getRevision();
  if (!revision.isEmpty()) {
    build += " - " + revision;
  }
  systemLogger.info("Hazelcast " + buildInfo.getVersion()
      + " (" + build + ") starting at " + node.getThisAddress());
  systemLogger.info("Copyright (c) 2008-2018, Hazelcast, Inc. All Rights Reserved.");
  systemLogger.fine("Configured Hazelcast Serialization version: " + buildInfo.getSerializationVersion());
}

代码示例来源：origin: hazelcast/hazelcast-jet

private void handleListNodes(HttpPostCommand command) throws UnsupportedEncodingException {
  String res;
  try {
    Node node = textCommandService.getNode();
    ClusterService clusterService = node.getClusterService();
    if (!checkCredentials(command)) {
      res = response(ResponseType.FORBIDDEN);
    } else {
      final String responseTxt = clusterService.getMembers().toString() + "\n"
          + node.getBuildInfo().getVersion() + "\n"
          + System.getProperty("java.version");
      res = response(ResponseType.SUCCESS, "response", responseTxt);
      sendResponse(command, res);
      return;
    }
  } catch (Throwable throwable) {
    logger.warning("Error occurred while listing nodes", throwable);
    res = exceptionResponse(throwable);
  }
  sendResponse(command, res);
}

代码示例来源：origin: com.hazelcast/hazelcast-all

private void handleListNodes(HttpPostCommand command) throws UnsupportedEncodingException {
  String res;
  try {
    Node node = textCommandService.getNode();
    ClusterService clusterService = node.getClusterService();
    if (!checkCredentials(command)) {
      res = response(ResponseType.FORBIDDEN);
    } else {
      final String responseTxt = clusterService.getMembers().toString() + "\n"
          + node.getBuildInfo().getVersion() + "\n"
          + System.getProperty("java.version");
      res = response(ResponseType.SUCCESS, "response", responseTxt);
      sendResponse(command, res);
      return;
    }
  } catch (Throwable throwable) {
    logger.warning("Error occurred while listing nodes", throwable);
    res = exceptionResponse(throwable);
  }
  sendResponse(command, res);
}

代码示例来源：origin: hazelcast/hazelcast-jet

/**
 * Send a {@link WhoisMasterOp} to designated address.
 *
 * @param toAddress the address to which the operation will be sent.
 * @return {@code true} if the operation was sent, otherwise {@code false}.
 */
public boolean sendMasterQuestion(Address toAddress) {
  checkNotNull(toAddress, "No endpoint is specified!");
  BuildInfo buildInfo = node.getBuildInfo();
  final Address thisAddress = node.getThisAddress();
  JoinMessage joinMessage = new JoinMessage(Packet.VERSION, buildInfo.getBuildNumber(), node.getVersion(),
      thisAddress, clusterService.getThisUuid(), node.isLiteMember(), node.createConfigCheck());
  return nodeEngine.getOperationService().send(new WhoisMasterOp(joinMessage), toAddress);
}

代码示例来源：origin: com.hazelcast/hazelcast-all

/**
 * Send a {@link WhoisMasterOp} to designated address.
 *
 * @param toAddress the address to which the operation will be sent.
 * @return {@code true} if the operation was sent, otherwise {@code false}.
 */
public boolean sendMasterQuestion(Address toAddress) {
  checkNotNull(toAddress, "No endpoint is specified!");
  BuildInfo buildInfo = node.getBuildInfo();
  final Address thisAddress = node.getThisAddress();
  JoinMessage joinMessage = new JoinMessage(Packet.VERSION, buildInfo.getBuildNumber(), node.getVersion(),
      thisAddress, clusterService.getThisUuid(), node.isLiteMember(), node.createConfigCheck());
  return nodeEngine.getOperationService().send(new WhoisMasterOp(joinMessage), toAddress);
}

代码示例来源：origin: hazelcast/hazelcast-jet

public PhoneHomeParameterCreator createParameters(Node hazelcastNode) {
  ClusterServiceImpl clusterService = hazelcastNode.getClusterService();
  int clusterSize = clusterService.getMembers().size();
  Long clusterUpTime = clusterService.getClusterClock().getClusterUpTime();
  RuntimeMXBean runtimeMxBean = ManagementFactory.getRuntimeMXBean();
  JetBuildInfo jetBuildInfo = hazelcastNode.getBuildInfo().getJetBuildInfo();
  PhoneHomeParameterCreator parameterCreator = new PhoneHomeParameterCreator()
      .addParam("version", buildInfo.getVersion())
      .addParam("m", hazelcastNode.getThisUuid())
      .addParam("p", getDownloadId())
      .addParam("c", clusterService.getClusterId())
      .addParam("crsz", convertToLetter(clusterSize))
      .addParam("cssz", convertToLetter(hazelcastNode.clientEngine.getClientEndpointCount()))
      .addParam("cuptm", Long.toString(clusterUpTime))
      .addParam("nuptm", Long.toString(runtimeMxBean.getUptime()))
      .addParam("jvmn", runtimeMxBean.getVmName())
      .addParam("jvmv", System.getProperty("java.version"))
      .addParam("jetv", jetBuildInfo == null ? "" : jetBuildInfo.getVersion());
  addClientInfo(hazelcastNode, parameterCreator);
  addOSInfo(parameterCreator);
  boolean isManagementCenterConfigEnabled = hazelcastNode.config.getManagementCenterConfig().isEnabled();
  if (isManagementCenterConfigEnabled) {
    addManCenterInfo(hazelcastNode, clusterSize, parameterCreator);
  } else {
    parameterCreator.addParam("mclicense", "MC_NOT_CONFIGURED");
    parameterCreator.addParam("mcver", "MC_NOT_CONFIGURED");
  }
  return parameterCreator;
}

代码示例来源：origin: com.hazelcast/hazelcast-all

public PhoneHomeParameterCreator createParameters(Node hazelcastNode) {
  ClusterServiceImpl clusterService = hazelcastNode.getClusterService();
  int clusterSize = clusterService.getMembers().size();
  Long clusterUpTime = clusterService.getClusterClock().getClusterUpTime();
  RuntimeMXBean runtimeMxBean = ManagementFactory.getRuntimeMXBean();
  JetBuildInfo jetBuildInfo = hazelcastNode.getBuildInfo().getJetBuildInfo();
  PhoneHomeParameterCreator parameterCreator = new PhoneHomeParameterCreator()
      .addParam("version", buildInfo.getVersion())
      .addParam("m", hazelcastNode.getThisUuid())
      .addParam("p", getDownloadId())
      .addParam("c", clusterService.getClusterId())
      .addParam("crsz", convertToLetter(clusterSize))
      .addParam("cssz", convertToLetter(hazelcastNode.clientEngine.getClientEndpointCount()))
      .addParam("cuptm", Long.toString(clusterUpTime))
      .addParam("nuptm", Long.toString(runtimeMxBean.getUptime()))
      .addParam("jvmn", runtimeMxBean.getVmName())
      .addParam("jvmv", System.getProperty("java.version"))
      .addParam("jetv", jetBuildInfo == null ? "" : jetBuildInfo.getVersion());
  addClientInfo(hazelcastNode, parameterCreator);
  addOSInfo(parameterCreator);
  boolean isManagementCenterConfigEnabled = hazelcastNode.config.getManagementCenterConfig().isEnabled();
  if (isManagementCenterConfigEnabled) {
    addManCenterInfo(hazelcastNode, clusterSize, parameterCreator);
  } else {
    parameterCreator.addParam("mclicense", "MC_NOT_CONFIGURED");
    parameterCreator.addParam("mcver", "MC_NOT_CONFIGURED");
  }
  return parameterCreator;
}

代码示例来源：origin: hazelcast/hazelcast-jet

private void handleActiveAndJoined(JoinMessage joinMessage) {
  if (!(joinMessage instanceof JoinRequest)) {
    logDroppedMessage(joinMessage);
    return;
  }
  ClusterServiceImpl clusterService = node.getClusterService();
  Address masterAddress = clusterService.getMasterAddress();
  if (clusterService.isMaster()) {
    JoinMessage response = new JoinMessage(Packet.VERSION, node.getBuildInfo().getBuildNumber(), node.getVersion(),
        node.getThisAddress(), node.getThisUuid(), node.isLiteMember(), node.createConfigCheck());
    node.multicastService.send(response);
  } else if (joinMessage.getAddress().equals(masterAddress)) {
    MemberImpl master = node.getClusterService().getMember(masterAddress);
    if (master != null && !master.getUuid().equals(joinMessage.getUuid())) {
      String message = "New join request has been received from current master. Suspecting " + masterAddress;
      logger.warning(message);
      // I just make a local suspicion. Probably other nodes will eventually suspect as well.
      clusterService.suspectMember(master, message, false);
    }
  }
}

代码示例来源：origin: com.hazelcast/hazelcast-all

private void handleActiveAndJoined(JoinMessage joinMessage) {
  if (!(joinMessage instanceof JoinRequest)) {
    logDroppedMessage(joinMessage);
    return;
  }
  ClusterServiceImpl clusterService = node.getClusterService();
  Address masterAddress = clusterService.getMasterAddress();
  if (clusterService.isMaster()) {
    JoinMessage response = new JoinMessage(Packet.VERSION, node.getBuildInfo().getBuildNumber(), node.getVersion(),
        node.getThisAddress(), node.getThisUuid(), node.isLiteMember(), node.createConfigCheck());
    node.multicastService.send(response);
  } else if (joinMessage.getAddress().equals(masterAddress)) {
    MemberImpl master = node.getClusterService().getMember(masterAddress);
    if (master != null && !master.getUuid().equals(joinMessage.getUuid())) {
      String message = "New join request has been received from current master. Suspecting " + masterAddress;
      logger.warning(message);
      // I just make a local suspicion. Probably other nodes will eventually suspect as well.
      clusterService.suspectMember(master, message, false);
    }
  }
}

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

Node

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

    更多

    Node类方法

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