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

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

本文整理了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

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

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

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

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

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

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

  1. private String versionAndAddressMessage(@Nonnull String addToName) {
  2.   JetBuildInfo jetBuildInfo = node.getBuildInfo().getJetBuildInfo();
  3.   String build = jetBuildInfo.getBuild();
  4.   String revision = jetBuildInfo.getRevision();
  5.   if (!revision.isEmpty()) {
  6.     build += " - " + revision;
  7.   }
  8.   return "Hazelcast Jet" + addToName + ' ' + jetBuildInfo.getVersion() +
  9.       " (" + build + ") starting at " + node.getThisAddress();
  10. }

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

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

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

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

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

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

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

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

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

  1. @Override
  2. public void writeResponse(ManagementCenterService mcs, JsonObject root) throws Exception {
  3.   Runtime runtime = Runtime.getRuntime();
  4.   RuntimeMXBean runtimeMxBean = ManagementFactory.getRuntimeMXBean();
  5.   IPartitionService partitionService = mcs.getHazelcastInstance().node.getPartitionService();
  6.   JsonObject properties = new JsonObject();
  7.   properties.add("hazelcast.cl_version", mcs.getHazelcastInstance().node.getBuildInfo().getVersion());
  8.   properties.add("date.cl_startTime", Long.toString(runtimeMxBean.getStartTime()));
  9.   properties.add("seconds.cl_upTime", Long.toString(runtimeMxBean.getUptime()));
  10.   properties.add("memory.cl_freeMemory", Long.toString(runtime.freeMemory()));
  11.   properties.add("memory.cl_totalMemory", Long.toString(runtime.totalMemory()));
  12.   properties.add("memory.cl_maxMemory", Long.toString(runtime.maxMemory()));
  13.   properties.add("return.hasOngoingMigration", Boolean.toString(partitionService.hasOnGoingMigration()));
  14.   properties.add("data.cl_migrationTasksCount", Long.toString(partitionService.getMigrationQueueSize()));
  15.   root.add("result", properties);
  16. }

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

  1. @Override
  2. public void writeResponse(ManagementCenterService mcs, JsonObject root) throws Exception {
  3.   Runtime runtime = Runtime.getRuntime();
  4.   RuntimeMXBean runtimeMxBean = ManagementFactory.getRuntimeMXBean();
  5.   IPartitionService partitionService = mcs.getHazelcastInstance().node.getPartitionService();
  6.   JsonObject properties = new JsonObject();
  7.   properties.add("hazelcast.cl_version", mcs.getHazelcastInstance().node.getBuildInfo().getVersion());
  8.   properties.add("date.cl_startTime", Long.toString(runtimeMxBean.getStartTime()));
  9.   properties.add("seconds.cl_upTime", Long.toString(runtimeMxBean.getUptime()));
  10.   properties.add("memory.cl_freeMemory", Long.toString(runtime.freeMemory()));
  11.   properties.add("memory.cl_totalMemory", Long.toString(runtime.totalMemory()));
  12.   properties.add("memory.cl_maxMemory", Long.toString(runtime.maxMemory()));
  13.   properties.add("return.hasOngoingMigration", Boolean.toString(partitionService.hasOnGoingMigration()));
  14.   properties.add("data.cl_migrationTasksCount", Long.toString(partitionService.getMigrationQueueSize()));
  15.   root.add("result", properties);
  16. }

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

  1. @Override
  2. public void printNodeInfo() {
  3.   BuildInfo buildInfo = node.getBuildInfo();
  4.   String build = buildInfo.getBuild();
  5.   String revision = buildInfo.getRevision();
  6.   if (!revision.isEmpty()) {
  7.     build += " - " + revision;
  8.   }
  9.   systemLogger.info("Hazelcast " + buildInfo.getVersion()
  10.       + " (" + build + ") starting at " + node.getThisAddress());
  11.   systemLogger.info("Copyright (c) 2008-2019, Hazelcast, Inc. All Rights Reserved.");
  12.   systemLogger.fine("Configured Hazelcast Serialization version: " + buildInfo.getSerializationVersion());
  13. }

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

  1. @Override
  2. public void printNodeInfo() {
  3.   BuildInfo buildInfo = node.getBuildInfo();
  4.   String build = buildInfo.getBuild();
  5.   String revision = buildInfo.getRevision();
  6.   if (!revision.isEmpty()) {
  7.     build += " - " + revision;
  8.   }
  9.   systemLogger.info("Hazelcast " + buildInfo.getVersion()
  10.       + " (" + build + ") starting at " + node.getThisAddress());
  11.   systemLogger.info("Copyright (c) 2008-2018, Hazelcast, Inc. All Rights Reserved.");
  12.   systemLogger.fine("Configured Hazelcast Serialization version: " + buildInfo.getSerializationVersion());
  13. }

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

  1. private void handleListNodes(HttpPostCommand command) throws UnsupportedEncodingException {
  2.   String res;
  3.   try {
  4.     Node node = textCommandService.getNode();
  5.     ClusterService clusterService = node.getClusterService();
  6.     if (!checkCredentials(command)) {
  7.       res = response(ResponseType.FORBIDDEN);
  8.     } else {
  9.       final String responseTxt = clusterService.getMembers().toString() + "\n"
  10.           + node.getBuildInfo().getVersion() + "\n"
  11.           + System.getProperty("java.version");
  12.       res = response(ResponseType.SUCCESS, "response", responseTxt);
  13.       sendResponse(command, res);
  14.       return;
  15.     }
  16.   } catch (Throwable throwable) {
  17.     logger.warning("Error occurred while listing nodes", throwable);
  18.     res = exceptionResponse(throwable);
  19.   }
  20.   sendResponse(command, res);
  21. }

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

  1. private void handleListNodes(HttpPostCommand command) throws UnsupportedEncodingException {
  2.   String res;
  3.   try {
  4.     Node node = textCommandService.getNode();
  5.     ClusterService clusterService = node.getClusterService();
  6.     if (!checkCredentials(command)) {
  7.       res = response(ResponseType.FORBIDDEN);
  8.     } else {
  9.       final String responseTxt = clusterService.getMembers().toString() + "\n"
  10.           + node.getBuildInfo().getVersion() + "\n"
  11.           + System.getProperty("java.version");
  12.       res = response(ResponseType.SUCCESS, "response", responseTxt);
  13.       sendResponse(command, res);
  14.       return;
  15.     }
  16.   } catch (Throwable throwable) {
  17.     logger.warning("Error occurred while listing nodes", throwable);
  18.     res = exceptionResponse(throwable);
  19.   }
  20.   sendResponse(command, res);
  21. }

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

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

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

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

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

  1. public PhoneHomeParameterCreator createParameters(Node hazelcastNode) {
  2.   ClusterServiceImpl clusterService = hazelcastNode.getClusterService();
  3.   int clusterSize = clusterService.getMembers().size();
  4.   Long clusterUpTime = clusterService.getClusterClock().getClusterUpTime();
  5.   RuntimeMXBean runtimeMxBean = ManagementFactory.getRuntimeMXBean();
  6.   JetBuildInfo jetBuildInfo = hazelcastNode.getBuildInfo().getJetBuildInfo();
  7.   PhoneHomeParameterCreator parameterCreator = new PhoneHomeParameterCreator()
  8.       .addParam("version", buildInfo.getVersion())
  9.       .addParam("m", hazelcastNode.getThisUuid())
  10.       .addParam("p", getDownloadId())
  11.       .addParam("c", clusterService.getClusterId())
  12.       .addParam("crsz", convertToLetter(clusterSize))
  13.       .addParam("cssz", convertToLetter(hazelcastNode.clientEngine.getClientEndpointCount()))
  14.       .addParam("cuptm", Long.toString(clusterUpTime))
  15.       .addParam("nuptm", Long.toString(runtimeMxBean.getUptime()))
  16.       .addParam("jvmn", runtimeMxBean.getVmName())
  17.       .addParam("jvmv", System.getProperty("java.version"))
  18.       .addParam("jetv", jetBuildInfo == null ? "" : jetBuildInfo.getVersion());
  19.   addClientInfo(hazelcastNode, parameterCreator);
  20.   addOSInfo(parameterCreator);
  21.   boolean isManagementCenterConfigEnabled = hazelcastNode.config.getManagementCenterConfig().isEnabled();
  22.   if (isManagementCenterConfigEnabled) {
  23.     addManCenterInfo(hazelcastNode, clusterSize, parameterCreator);
  24.   } else {
  25.     parameterCreator.addParam("mclicense", "MC_NOT_CONFIGURED");
  26.     parameterCreator.addParam("mcver", "MC_NOT_CONFIGURED");
  27.   }
  28.   return parameterCreator;
  29. }

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

  1. public PhoneHomeParameterCreator createParameters(Node hazelcastNode) {
  2.   ClusterServiceImpl clusterService = hazelcastNode.getClusterService();
  3.   int clusterSize = clusterService.getMembers().size();
  4.   Long clusterUpTime = clusterService.getClusterClock().getClusterUpTime();
  5.   RuntimeMXBean runtimeMxBean = ManagementFactory.getRuntimeMXBean();
  6.   JetBuildInfo jetBuildInfo = hazelcastNode.getBuildInfo().getJetBuildInfo();
  7.   PhoneHomeParameterCreator parameterCreator = new PhoneHomeParameterCreator()
  8.       .addParam("version", buildInfo.getVersion())
  9.       .addParam("m", hazelcastNode.getThisUuid())
  10.       .addParam("p", getDownloadId())
  11.       .addParam("c", clusterService.getClusterId())
  12.       .addParam("crsz", convertToLetter(clusterSize))
  13.       .addParam("cssz", convertToLetter(hazelcastNode.clientEngine.getClientEndpointCount()))
  14.       .addParam("cuptm", Long.toString(clusterUpTime))
  15.       .addParam("nuptm", Long.toString(runtimeMxBean.getUptime()))
  16.       .addParam("jvmn", runtimeMxBean.getVmName())
  17.       .addParam("jvmv", System.getProperty("java.version"))
  18.       .addParam("jetv", jetBuildInfo == null ? "" : jetBuildInfo.getVersion());
  19.   addClientInfo(hazelcastNode, parameterCreator);
  20.   addOSInfo(parameterCreator);
  21.   boolean isManagementCenterConfigEnabled = hazelcastNode.config.getManagementCenterConfig().isEnabled();
  22.   if (isManagementCenterConfigEnabled) {
  23.     addManCenterInfo(hazelcastNode, clusterSize, parameterCreator);
  24.   } else {
  25.     parameterCreator.addParam("mclicense", "MC_NOT_CONFIGURED");
  26.     parameterCreator.addParam("mcver", "MC_NOT_CONFIGURED");
  27.   }
  28.   return parameterCreator;
  29. }

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

  1. private void handleActiveAndJoined(JoinMessage joinMessage) {
  2.   if (!(joinMessage instanceof JoinRequest)) {
  3.     logDroppedMessage(joinMessage);
  4.     return;
  5.   }
  6.   ClusterServiceImpl clusterService = node.getClusterService();
  7.   Address masterAddress = clusterService.getMasterAddress();
  8.   if (clusterService.isMaster()) {
  9.     JoinMessage response = new JoinMessage(Packet.VERSION, node.getBuildInfo().getBuildNumber(), node.getVersion(),
  10.         node.getThisAddress(), node.getThisUuid(), node.isLiteMember(), node.createConfigCheck());
  11.     node.multicastService.send(response);
  12.   } else if (joinMessage.getAddress().equals(masterAddress)) {
  13.     MemberImpl master = node.getClusterService().getMember(masterAddress);
  14.     if (master != null && !master.getUuid().equals(joinMessage.getUuid())) {
  15.       String message = "New join request has been received from current master. Suspecting " + masterAddress;
  16.       logger.warning(message);
  17.       // I just make a local suspicion. Probably other nodes will eventually suspect as well.
  18.       clusterService.suspectMember(master, message, false);
  19.     }
  20.   }
  21. }

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

  1. private void handleActiveAndJoined(JoinMessage joinMessage) {
  2.   if (!(joinMessage instanceof JoinRequest)) {
  3.     logDroppedMessage(joinMessage);
  4.     return;
  5.   }
  6.   ClusterServiceImpl clusterService = node.getClusterService();
  7.   Address masterAddress = clusterService.getMasterAddress();
  8.   if (clusterService.isMaster()) {
  9.     JoinMessage response = new JoinMessage(Packet.VERSION, node.getBuildInfo().getBuildNumber(), node.getVersion(),
  10.         node.getThisAddress(), node.getThisUuid(), node.isLiteMember(), node.createConfigCheck());
  11.     node.multicastService.send(response);
  12.   } else if (joinMessage.getAddress().equals(masterAddress)) {
  13.     MemberImpl master = node.getClusterService().getMember(masterAddress);
  14.     if (master != null && !master.getUuid().equals(joinMessage.getUuid())) {
  15.       String message = "New join request has been received from current master. Suspecting " + masterAddress;
  16.       logger.warning(message);
  17.       // I just make a local suspicion. Probably other nodes will eventually suspect as well.
  18.       clusterService.suspectMember(master, message, false);
  19.     }
  20.   }
  21. }

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

Node

相关文章

    查看更多

    热门标签

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

    最新文章

    更多

    Node类方法

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