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

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

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

Node.getState介绍

[英]Returns the node state.
[中]返回节点状态。

代码示例

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

  1. @Override
  2. public boolean isActive() {
  3.   return node.getState() != NodeState.SHUT_DOWN;
  4. }

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

  1. @Override
  2. public boolean isActive() {
  3.   return node.getState() != NodeState.SHUT_DOWN;
  4. }

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

  1. private boolean nodeActive() {
  2.   return nodeEngine.getNode().getState() != NodeState.SHUT_DOWN;
  3. }

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

  1. private boolean nodeActive() {
  2.   return nodeEngine.getNode().getState() != NodeState.SHUT_DOWN;
  3. }

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

  1. private boolean engineActive() {
  2.   NodeState state = context.node.getState();
  3.   if (state == NodeState.ACTIVE) {
  4.     return true;
  5.   }
  6.   boolean allowed = state == NodeState.PASSIVE && (op instanceof AllowedDuringPassiveState);
  7.   if (!allowed) {
  8.     notifyError(new HazelcastInstanceNotActiveException("State: " + state + " Operation: " + op.getClass()));
  9.     remote = false;
  10.   }
  11.   return allowed;
  12. }

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

  1. private boolean engineActive() {
  2.   NodeState state = context.node.getState();
  3.   if (state == NodeState.ACTIVE) {
  4.     return true;
  5.   }
  6.   boolean allowed = state == NodeState.PASSIVE && (op instanceof AllowedDuringPassiveState);
  7.   if (!allowed) {
  8.     notifyError(new HazelcastInstanceNotActiveException("State: " + state + " Operation: " + op.getClass()));
  9.     remote = false;
  10.   }
  11.   return allowed;
  12. }

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

  1. private void handleHealthcheck(HttpHeadCommand command) {
  2.   Node node = textCommandService.getNode();
  3.   NodeState nodeState = node.getState();
  4.   ClusterServiceImpl clusterService = node.getClusterService();
  5.   ClusterState clusterState = clusterService.getClusterState();
  6.   int clusterSize = clusterService.getMembers().size();
  7.   InternalPartitionService partitionService = node.getPartitionService();
  8.   long migrationQueueSize = partitionService.getMigrationQueueSize();
  9.   Map<String, Object> headervals = new LinkedHashMap<String, Object>();
  10.   headervals.put("NodeState", nodeState);
  11.   headervals.put("ClusterState", clusterState);
  12.   headervals.put("MigrationQueueSize", migrationQueueSize);
  13.   headervals.put("ClusterSize", clusterSize);
  14.   command.setResponse(headervals);
  15. }

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

  1. private void handleHealthcheck(HttpHeadCommand command) {
  2.   Node node = textCommandService.getNode();
  3.   NodeState nodeState = node.getState();
  4.   ClusterServiceImpl clusterService = node.getClusterService();
  5.   ClusterState clusterState = clusterService.getClusterState();
  6.   int clusterSize = clusterService.getMembers().size();
  7.   InternalPartitionService partitionService = node.getPartitionService();
  8.   long migrationQueueSize = partitionService.getMigrationQueueSize();
  9.   Map<String, Object> headervals = new LinkedHashMap<String, Object>();
  10.   headervals.put("NodeState", nodeState);
  11.   headervals.put("ClusterState", clusterState);
  12.   headervals.put("MigrationQueueSize", migrationQueueSize);
  13.   headervals.put("ClusterSize", clusterSize);
  14.   command.setResponse(headervals);
  15. }

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

  1. private void sendResponseAfterOperationError(Operation operation, Throwable e) {
  2.   try {
  3.     if (node.getState() != NodeState.SHUT_DOWN) {
  4.       operation.sendResponse(e);
  5.     } else if (operation.executedLocally()) {
  6.       operation.sendResponse(new HazelcastInstanceNotActiveException());
  7.     }
  8.   } catch (Throwable t) {
  9.     logger.warning("While sending op error... op: " + operation + ", error: " + e, t);
  10.   }
  11. }

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

  1. protected void createNodeState(MemberStateImpl memberState) {
  2.   Node node = instance.node;
  3.   ClusterService cluster = instance.node.clusterService;
  4.   NodeStateImpl nodeState = new NodeStateImpl(cluster.getClusterState(), node.getState(),
  5.       cluster.getClusterVersion(), node.getVersion());
  6.   memberState.setNodeState(nodeState);
  7. }

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

  1. protected void createNodeState(MemberStateImpl memberState) {
  2.   Node node = instance.node;
  3.   ClusterService cluster = instance.node.clusterService;
  4.   NodeStateImpl nodeState = new NodeStateImpl(cluster.getClusterState(), node.getState(),
  5.       cluster.getClusterVersion(), node.getVersion());
  6.   memberState.setNodeState(nodeState);
  7. }

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

  1. private void sendResponseAfterOperationError(Operation operation, Throwable e) {
  2.   try {
  3.     if (node.getState() != NodeState.SHUT_DOWN) {
  4.       operation.sendResponse(e);
  5.     } else if (operation.executedLocally()) {
  6.       operation.sendResponse(new HazelcastInstanceNotActiveException());
  7.     }
  8.   } catch (Throwable t) {
  9.     logger.warning("While sending op error... op: " + operation + ", error: " + e, t);
  10.   }
  11. }

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

  1. /** Sends a {@link ShutdownResponseOperation} to the {@code address} or takes a shortcut if shutdown is local. */
  2. private void sendShutdownOperation(Address address) {
  3.   if (node.getThisAddress().equals(address)) {
  4.     assert !node.isRunning() : "Node state: " + node.getState();
  5.     partitionService.onShutdownResponse();
  6.   } else {
  7.     nodeEngine.getOperationService().send(new ShutdownResponseOperation(), address);
  8.   }
  9. }

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

  1. private void checkNodeState(Operation op) {
  2.   NodeState state = node.getState();
  3.   if (state == NodeState.ACTIVE) {
  4.     return;
  5.   }
  6.   Address localAddress = node.getThisAddress();
  7.   if (state == NodeState.SHUT_DOWN) {
  8.     throw new HazelcastInstanceNotActiveException("Member " + localAddress + " is shut down! Operation: " + op);
  9.   }
  10.   if (op instanceof AllowedDuringPassiveState) {
  11.     return;
  12.   }
  13.   // Cluster is in passive state. There is no need to retry.
  14.   if (nodeEngine.getClusterService().getClusterState() == ClusterState.PASSIVE) {
  15.     throw new IllegalStateException("Cluster is in " + ClusterState.PASSIVE + " state! Operation: " + op);
  16.   }
  17.   // Operation has no partition ID, so it's sent to this node in purpose.
  18.   // Operation will fail since node is shutting down or cluster is passive.
  19.   if (op.getPartitionId() < 0) {
  20.     throw new HazelcastInstanceNotActiveException("Member " + localAddress + " is currently passive! Operation: " + op);
  21.   }
  22.   // Custer is not passive but this node is shutting down.
  23.   // Since operation has a partition ID, it must be retried on another node.
  24.   throw new RetryableHazelcastException("Member " + localAddress + " is currently shutting down! Operation: " + op);
  25. }

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

  1. /** Sends a {@link ShutdownResponseOperation} to the {@code address} or takes a shortcut if shutdown is local. */
  2. private void sendShutdownOperation(Address address) {
  3.   if (node.getThisAddress().equals(address)) {
  4.     assert !node.isRunning() : "Node state: " + node.getState();
  5.     partitionService.onShutdownResponse();
  6.   } else {
  7.     nodeEngine.getOperationService().send(new ShutdownResponseOperation(), address);
  8.   }
  9. }

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

  1. @Override
  2. public void run() {
  3.   final ClusterServiceImpl clusterService = getService();
  4.   final ILogger logger = getLogger();
  5.   final ClusterState clusterState = clusterService.getClusterState();
  6.   if (clusterState == ClusterState.PASSIVE) {
  7.     final NodeEngineImpl nodeEngine = (NodeEngineImpl) getNodeEngine();
  8.     if (nodeEngine.isRunning()) {
  9.       logger.info("Shutting down node in cluster passive state. Requested by: " + getCallerAddress());
  10.       new Thread(new Runnable() {
  11.         @Override
  12.         public void run() {
  13.           final Node node = nodeEngine.getNode();
  14.           node.hazelcastInstance.getLifecycleService().shutdown();
  15.         }
  16.       }, createThreadName(nodeEngine.getHazelcastInstance().getName(), ".clusterShutdown")).start();
  17.     } else {
  18.       logger.info("Node is already shutting down. NodeState: " + nodeEngine.getNode().getState());
  19.     }
  20.   } else {
  21.     logger.severe("Can not shut down node because cluster is in " + clusterState + " state. Requested by: "
  22.         + getCallerAddress());
  23.   }
  24. }

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

  1. @Override
  2.   public void run() {
  3.     if (node.isMaster()) {
  4.       MigrationManager migrationManager = partitionService.getMigrationManager();
  5.       boolean migrationAllowed = migrationManager.isMigrationAllowed()
  6.           && !partitionService.isFetchMostRecentPartitionTableTaskRequired();
  7.       if (!migrationAllowed) {
  8.         logger.fine("Not publishing partition runtime state since migration is not allowed.");
  9.         return;
  10.       }
  12.       if (migrationManager.hasOnGoingMigration()) {
  13.         logger.info("Remaining migration tasks in queue => " + partitionService.getMigrationQueueSize());
  14.       }
  16.       if (node.getState() == NodeState.ACTIVE) {
  17.         partitionService.publishPartitionRuntimeState();
  18.       }
  19.     }
  20.   }
  21. }

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

  1. @Override
  2.   public void run() {
  3.     if (node.isMaster()) {
  4.       MigrationManager migrationManager = partitionService.getMigrationManager();
  5.       boolean migrationAllowed = migrationManager.areMigrationTasksAllowed()
  6.           && !partitionService.isFetchMostRecentPartitionTableTaskRequired();
  7.       if (!migrationAllowed) {
  8.         logger.fine("Not publishing partition runtime state since migration is not allowed.");
  9.         return;
  10.       }
  12.       if (migrationManager.hasOnGoingMigration()) {
  13.         logger.info("Remaining migration tasks in queue => " + partitionService.getMigrationQueueSize()
  14.           + ". (" + migrationManager.getStats().formatToString(logger.isFineEnabled()) + ")");
  15.       } else if (node.getState() == NodeState.ACTIVE) {
  16.         if (node.getClusterService().getClusterVersion().isGreaterOrEqual(Versions.V3_12)) {
  17.           partitionService.checkClusterPartitionRuntimeStates();
  18.         } else {
  19.           // RU_COMPAT_3_11
  20.           partitionService.publishPartitionRuntimeState();
  21.         }
  22.       }
  23.     }
  24.   }
  25. }

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

  1. @Override
  2.   public void run(DiagnosticsLogWriter writer) {
  3.     writer.startSection("HazelcastInstance");
  5.     writer.writeKeyValueEntry("thisAddress", nodeEngine.getNode().getThisAddress().toString());
  6.     writer.writeKeyValueEntry("isRunning", nodeEngine.getNode().isRunning());
  7.     writer.writeKeyValueEntry("isLite", nodeEngine.getNode().isLiteMember());
  8.     writer.writeKeyValueEntry("joined", nodeEngine.getNode().getClusterService().isJoined());
  9.     NodeState state = nodeEngine.getNode().getState();
  10.     writer.writeKeyValueEntry("nodeState", state == null ? "null" : state.toString());
  12.     writer.writeKeyValueEntry("clusterId", nodeEngine.getClusterService().getClusterId());
  13.     writer.writeKeyValueEntry("clusterSize", nodeEngine.getClusterService().getSize());
  14.     writer.writeKeyValueEntry("isMaster", nodeEngine.getClusterService().isMaster());
  15.     Address masterAddress = nodeEngine.getClusterService().getMasterAddress();
  16.     writer.writeKeyValueEntry("masterAddress", masterAddress == null ? "null" : masterAddress.toString());
  18.     writer.startSection("Members");
  19.     for (Member member : nodeEngine.getClusterService().getMemberImpls()) {
  20.       writer.writeEntry(member.getAddress().toString());
  21.     }
  22.     writer.endSection();
  24.     writer.endSection();
  25.   }
  26. }

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

  1. @Override
  2.   public void run(DiagnosticsLogWriter writer) {
  3.     writer.startSection("HazelcastInstance");
  5.     writer.writeKeyValueEntry("thisAddress", nodeEngine.getNode().getThisAddress().toString());
  6.     writer.writeKeyValueEntry("isRunning", nodeEngine.getNode().isRunning());
  7.     writer.writeKeyValueEntry("isLite", nodeEngine.getNode().isLiteMember());
  8.     writer.writeKeyValueEntry("joined", nodeEngine.getNode().getClusterService().isJoined());
  9.     NodeState state = nodeEngine.getNode().getState();
  10.     writer.writeKeyValueEntry("nodeState", state == null ? "null" : state.toString());
  12.     writer.writeKeyValueEntry("clusterId", nodeEngine.getClusterService().getClusterId());
  13.     writer.writeKeyValueEntry("clusterSize", nodeEngine.getClusterService().getSize());
  14.     writer.writeKeyValueEntry("isMaster", nodeEngine.getClusterService().isMaster());
  15.     Address masterAddress = nodeEngine.getClusterService().getMasterAddress();
  16.     writer.writeKeyValueEntry("masterAddress", masterAddress == null ? "null" : masterAddress.toString());
  18.     writer.startSection("Members");
  19.     for (Member member : nodeEngine.getClusterService().getMemberImpls()) {
  20.       writer.writeEntry(member.getAddress().toString());
  21.     }
  22.     writer.endSection();
  24.     writer.endSection();
  25.   }
  26. }

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

Node

相关文章

    查看更多

    热门标签

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

    最新文章

    更多

    Node类方法

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