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

Node.getClusterService介绍

暂无

代码示例

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

@Override
public Cluster getCluster() {
  return node.getClusterService();
}

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

private void checkMemberListVersion(int memberListVersion) {
  int thisMemberListVersion = node.getClusterService().getMemberListVersion();
  if (memberListVersion != thisMemberListVersion) {
    throw new IllegalStateException(
        "Can not lock cluster state! Member list versions are not matching!"
            + " Expected version: " + memberListVersion
            + ", Current version: " + thisMemberListVersion);
  }
}

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

private static boolean isFirstMember(Node node) {
  Iterator<Member> iterator = node.getClusterService().getMembers().iterator();
  return (iterator.hasNext() && iterator.next().localMember());
}

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

private void checkMemberListChange(int initialMemberListVersion) {
  int currentMemberListVersion = node.getClusterService().getMembershipManager().getMemberListVersion();
  if (initialMemberListVersion != currentMemberListVersion) {
    throw new IllegalStateException("Cluster members changed during state change! "
        + "Initial version: " + initialMemberListVersion + ", Current version: " + currentMemberListVersion);
  }
}

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

private void checkMemberListVersion(int memberListVersion) {
  // RU_COMPAT_V3_10
  if (clusterVersion.isGreaterOrEqual(Versions.V3_11)) {
    int thisMemberListVersion = node.getClusterService().getMemberListVersion();
    if (memberListVersion != thisMemberListVersion) {
      throw new IllegalStateException(
          "Can not lock cluster state! Member list versions are not matching!"
              + " Expected version: " + memberListVersion
              + ", Current version: " + thisMemberListVersion);
    }
  }
}

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

private void checkMemberListChange(int initialMemberListVersion) {
  int currentMemberListVersion = node.getClusterService().getMembershipManager().getMemberListVersion();
  if (initialMemberListVersion != currentMemberListVersion) {
    throw new IllegalStateException("Cluster members changed during state change! "
        + "Initial version: " + initialMemberListVersion + ", Current version: " + currentMemberListVersion);
  }
}

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

/**
 * Returns whether migrations are allowed by current cluster state.
 */
private boolean isMigrationAllowedByClusterState() {
  ClusterState clusterState = node.getClusterService().getClusterState();
  return clusterState.isMigrationAllowed();
}

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

@Override
public void onSuccessfulConnection(Address address) {
  if (!node.getClusterService().isJoined()) {
    node.getJoiner().unblacklist(address);
  }
}

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

private Collection<MemberGroup> createMemberGroups(final Set<Member> excludedMembers) {
  MemberSelector exclude = new MemberSelector() {
    @Override
    public boolean select(Member member) {
      return !excludedMembers.contains(member);
    }
  };
  final MemberSelector selector = MemberSelectors.and(DATA_MEMBER_SELECTOR, exclude);
  final Collection<Member> members = node.getClusterService().getMembers(selector);
  return memberGroupFactory.createMemberGroups(members);
}

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

private Version getClusterOrNodeVersion() {
  if (node.getClusterService() != null && !node.getClusterService().getClusterVersion().isUnknown()) {
    return node.getClusterService().getClusterVersion();
  } else {
    String overriddenClusterVersion = node.getProperties().getString(GroupProperty.INIT_CLUSTER_VERSION);
    return (overriddenClusterVersion != null) ? MemberVersion.of(overriddenClusterVersion).asVersion()
        : node.getVersion().asVersion();
  }
}

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

private void handleGetClusterVersion(HttpGetCommand command) {
  String res = "{\"status\":\"${STATUS}\",\"version\":\"${VERSION}\"}";
  Node node = textCommandService.getNode();
  ClusterService clusterService = node.getClusterService();
  res = res.replace("${STATUS}", "success");
  res = res.replace("${VERSION}", clusterService.getClusterVersion().toString());
  command.setResponse(HttpCommand.CONTENT_TYPE_JSON, stringToBytes(res));
}

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

public AbstractJoiner(Node node) {
  this.node = node;
  this.logger = node.loggingService.getLogger(getClass());
  this.config = node.config;
  this.clusterService = node.getClusterService();
  this.clusterJoinManager = clusterService.getClusterJoinManager();
  this.mergeNextRunDelayMs = node.getProperties().getMillis(GroupProperty.MERGE_NEXT_RUN_DELAY_SECONDS);
}

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

private Version getClusterOrNodeVersion() {
  if (node.getClusterService() != null && !node.getClusterService().getClusterVersion().isUnknown()) {
    return node.getClusterService().getClusterVersion();
  } else {
    String overriddenClusterVersion = node.getProperties().getString(GroupProperty.INIT_CLUSTER_VERSION);
    return (overriddenClusterVersion != null) ? MemberVersion.of(overriddenClusterVersion).asVersion()
        : node.getVersion().asVersion();
  }
}

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

private void handleGetClusterVersion(HttpGetCommand command) {
  String res = "{\"status\":\"${STATUS}\",\"version\":\"${VERSION}\"}";
  Node node = textCommandService.getNode();
  ClusterService clusterService = node.getClusterService();
  res = res.replace("${STATUS}", "success");
  res = res.replace("${VERSION}", clusterService.getClusterVersion().toString());
  command.setResponse(HttpCommand.CONTENT_TYPE_JSON, stringToBytes(res));
}

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

public AbstractJoiner(Node node) {
  this.node = node;
  this.logger = node.loggingService.getLogger(getClass());
  this.config = node.config;
  this.clusterService = node.getClusterService();
  this.clusterJoinManager = clusterService.getClusterJoinManager();
  this.mergeNextRunDelayMs = node.getProperties().getMillis(GroupProperty.MERGE_NEXT_RUN_DELAY_SECONDS);
}

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

private void resetState() {
  // reset node and membership state from now on this node won't be joined and won't have a master address
  node.reset();
  node.getClusterService().reset();
  // stop the connection-manager:
  // - all socket connections will be closed
  // - connection listening thread will stop
  // - no new connection will be established
  node.connectionManager.stop();
  // clear waiting operations in queue and notify invocations to retry
  node.nodeEngine.reset();
}

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

private URL newGetTaskUrl() throws IOException {
  GroupConfig groupConfig = instance.getConfig().getGroupConfig();
  Address localAddress = instance.node.getClusterService().getLocalMember().getAddress();
  String urlString = cleanupUrl(managementCenterUrl) + "getTask.do?member=" + localAddress.getHost()
      + ":" + localAddress.getPort() + "&cluster=" + encode(groupConfig.getName(), "UTF-8");
  return new URL(urlString);
}

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

private URL newGetTaskUrl() throws IOException {
  GroupConfig groupConfig = instance.getConfig().getGroupConfig();
  Address localAddress = instance.node.getClusterService().getLocalMember().getAddress();
  String urlString = cleanupUrl(managementCenterUrl) + "getTask.do?member=" + localAddress.getHost()
      + ":" + localAddress.getPort() + "&cluster=" + encode(groupConfig.getName(), "UTF-8");
  return new URL(urlString);
}

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

@Override
public void run() {
  final NodeEngineImpl nodeEngine = (NodeEngineImpl) getNodeEngine();
  final Node node = nodeEngine.getNode();
  if (node.getClusterService().isJoined()) {
    throw new IllegalStateException("Node is already joined but received a termination message! "
      + "Reason: " + failReasonMsg);
  }
  final ILogger logger = nodeEngine.getLogger("com.hazelcast.security");
  logger.severe("Node could not join cluster. Before join check failed node is going to shutdown now!");
  logger.severe("Reason of failure for node join: " + failReasonMsg);
  node.shutdown(true);
}

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

private void registerCoreServices() {
  logger.finest("Registering core services...");
  Node node = nodeEngine.getNode();
  registerService(ClusterServiceImpl.SERVICE_NAME, node.getClusterService());
  registerService(InternalPartitionService.SERVICE_NAME, node.getPartitionService());
  registerService(ProxyServiceImpl.SERVICE_NAME, nodeEngine.getProxyService());
  registerService(TransactionManagerServiceImpl.SERVICE_NAME, nodeEngine.getTransactionManagerService());
  registerService(ClientEngineImpl.SERVICE_NAME, node.clientEngine);
  registerService(QuorumServiceImpl.SERVICE_NAME, nodeEngine.getQuorumService());
  registerService(WanReplicationService.SERVICE_NAME, nodeEngine.getWanReplicationService());
  registerService(EventServiceImpl.SERVICE_NAME, nodeEngine.getEventService());
}