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

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

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

Node.getThisUuid介绍

暂无

代码示例

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

  1. @Override
  2. public String getThisUuid() {
  3.   return node.getThisUuid();
  4. }

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

  1. @Override
  2. public String getThisUuid() {
  3.   return node.getThisUuid();
  4. }

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

  1. private void doInvokeLocal(boolean isAsync) {
  2.   if (op.getCallerUuid() == null) {
  3.     op.setCallerUuid(context.node.getThisUuid());
  4.   }
  5.   responseReceived = FALSE;
  6.   op.setOperationResponseHandler(this);
  7.   if (isAsync) {
  8.     context.operationExecutor.execute(op);
  9.   } else {
  10.     context.operationExecutor.runOrExecute(op);
  11.   }
  12. }

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

  1. private boolean isMemberExcludedFromHotRestart() {
  2.   final NodeExtension nodeExtension = node.getNodeExtension();
  3.   return !nodeExtension.isStartCompleted()
  4.       && nodeExtension.getInternalHotRestartService().isMemberExcluded(node.getThisAddress(), node.getThisUuid());
  5. }

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

  1. private boolean shouldResetHotRestartData() {
  2.   final NodeExtension nodeExtension = node.getNodeExtension();
  3.   return !nodeExtension.isStartCompleted()
  4.       && nodeExtension.getInternalHotRestartService().isMemberExcluded(node.getThisAddress(), node.getThisUuid());
  5. }

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

  1. private void doInvokeLocal(boolean isAsync) {
  2.   if (op.getCallerUuid() == null) {
  3.     op.setCallerUuid(context.node.getThisUuid());
  4.   }
  5.   responseReceived = FALSE;
  6.   op.setOperationResponseHandler(this);
  7.   if (isAsync) {
  8.     context.operationExecutor.execute(op);
  9.   } else {
  10.     context.operationExecutor.runOrExecute(op);
  11.   }
  12. }

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

  1. /**
  2.  * Completes the job which is coordinated with the given master context object.
  3.  */
  4. void completeJob(MasterContext masterContext, long completionTime, Throwable error) {
  5.   // the order of operations is important.
  6.   long jobId = masterContext.jobId();
  7.   String coordinator = nodeEngine.getNode().getThisUuid();
  8.   jobRepository.completeJob(jobId, coordinator, completionTime, error);
  9.   if (masterContexts.remove(masterContext.jobId(), masterContext)) {
  10.     logger.fine(masterContext.jobIdString() + " is completed");
  11.   } else {
  12.     MasterContext existing = masterContexts.get(jobId);
  13.     if (existing != null) {
  14.       logger.severe("Different master context found to complete " + masterContext.jobIdString()
  15.           + ", master context execution " + idToString(existing.executionId()));
  16.     } else {
  17.       logger.severe("No master context found to complete " + masterContext.jobIdString());
  18.     }
  19.   }
  20. }

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

  1. String localMemberUuid = node.getThisUuid();
  2. final String clientUuid = endpoint.getUuid();
  3. String ownerUuid = ownershipMappings.get(clientUuid);

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

  1. String localMemberUuid = node.getThisUuid();
  2. final String clientUuid = endpoint.getUuid();
  3. String ownerUuid = ownershipMappings.get(clientUuid);

代码示例来源：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. 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