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

Cluster介绍

[英]Hazelcast cluster interface. It provides access to the members in the cluster and one can register for changes in the cluster members.

All the methods on the Cluster are thread-safe.
[中]Hazelcast群集接口。它提供对集群中成员的访问，并且可以注册集群成员中的更改。
集群上的所有方法都是线程安全的。

代码示例

代码示例来源：origin: SonarSource/sonarqube

@Override
public Set<String> getMemberUuids() {
 return hzInstance.getCluster().getMembers().stream().map(Member::getUuid).collect(Collectors.toSet());
}

代码示例来源：origin: SonarSource/sonarqube

public ClusterAppStateImpl(AppSettings settings, HazelcastMember hzMember, EsConnector esConnector) {
 this.hzMember = hzMember;
 // Get or create the replicated map
 operationalProcesses = (ReplicatedMap) hzMember.getReplicatedMap(OPERATIONAL_PROCESSES);
 operationalProcessListenerUUID = operationalProcesses.addEntryListener(new OperationalProcessListener());
 nodeDisconnectedListenerUUID = hzMember.getCluster().addMembershipListener(new NodeDisconnectedListener());
 if (ClusterSettings.isLocalElasticsearchEnabled(settings)) {
  this.healthStateSharing = new HealthStateSharingImpl(hzMember, new SearchNodeHealthProvider(settings.getProps(), this, NetworkUtilsImpl.INSTANCE));
  this.healthStateSharing.start();
 }
 this.esConnector = esConnector;
}

代码示例来源：origin: SonarSource/sonarqube

@Override
public long getClusterTime() {
 return hzInstance.getCluster().getClusterTime();
}

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

public static void main(String[] args) {
    System.setProperty("hazelcast.phone.home.enabled", "false");

    HazelcastInstance instance1 = Hazelcast.newHazelcastInstance();
    HazelcastInstance instance2 = Hazelcast.newHazelcastInstance();

    IMap<Object, Object> map = instance2.getMap("test-map");
    // initialize partition assignments
    map.size();

    System.out.println("Instance-1 Cluster State: " + instance1.getCluster().getClusterState());
    System.out.println("Instance-2 Cluster State: " + instance2.getCluster().getClusterState());

    instance2.getCluster().changeClusterState(ClusterState.NO_MIGRATION);
    System.out.println("Instance-1 Cluster State: " + instance1.getCluster().getClusterState());
    System.out.println("Instance-2 Cluster State: " + instance2.getCluster().getClusterState());

    // start a new instance
    HazelcastInstance instance3 = Hazelcast.newHazelcastInstance();

    System.out.println("Instance-3 Members: " + instance3.getCluster().getMembers());
    System.out.println("Instance-3 Cluster State: " + instance3.getCluster().getClusterState());

    Hazelcast.shutdownAll();
  }
}

代码示例来源：origin: io.vertx/vertx-hazelcast

@Test
public void testThatExternalHZInstanceCanBeShutdown() {
 HazelcastInstance instance = Hazelcast.newHazelcastInstance(createConfig());
 String nodeID = instance.getCluster().getLocalMember().getUuid();
 instance.getCluster().addMembershipListener(new MembershipListener() {
  @Override
  public void memberAdded(MembershipEvent membershipEvent) {
 Map<Object, Object> map = instance.getMap("mymap1");
 Map<Object, Object> anotherMap = instance.getMap("mymap2");
 assertEquals(map.get("news"), "hello");

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

public static void main(String[] args) {
  System.setProperty("hazelcast.jmx", "true");
  Hazelcast.newHazelcastInstance();
  Hazelcast.newHazelcastInstance();
  Hazelcast.newHazelcastInstance();
  HazelcastInstance hz = Hazelcast.newHazelcastInstance();
  System.out.println("Hazelcast cluster was started. Number of members: " + hz.getCluster().getMembers().size());
  IMap<String, String> map = hz.getMap("cities");
  map.put("where to live", "Brno");
  map.put("where to have a joy", "Paris");
  map.put("where to go next", "London");
  System.out.println("Entries were added to 'cities' IMap, current size is: " + map.size());
  // time-to-live is set on the 'cities' map, let's do some statistics over the time
  for (int i = 0; i < 15; i++) {
    sleepSeconds(2);
    printMapStatistics();
  }
  Hazelcast.shutdownAll();
}

代码示例来源：origin: org.deeplearning4j/deeplearning4j-scaleout-akka

h = Hazelcast.newHazelcastInstance(config);
  h.getCluster().addMembershipListener(new MembershipListener() {
jobs = h.getList(JOBS);
workers = h.getList(WORKERS);

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

hazelcastInstance = Hazelcast.newHazelcastInstance(config);
hazelcastInstance.getClientService().addClientListener(myClientListener);
String uuid = hazelcastInstance.getCluster().getLocalMember().getUuid();
log.info("Server {} is ready", uuid);
countDownLatch.countDown();
if (hazelcastInstance.getLifecycleService().isRunning()) {
  hazelcastInstance.shutdown();

代码示例来源：origin: lumongo/lumongo

hazelcastInstance = Hazelcast.newHazelcastInstance(cfg);
self = hazelcastInstance.getCluster().getLocalMember();
hazelcastInstance.getCluster().addMembershipListener(this);
hazelcastInstance.getLifecycleService().addLifecycleListener(this);
Set<Member> members = hazelcastInstance.getCluster().getMembers();

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

public static void main(String[] args) {
  // Start the Embedded Hazelcast Cluster Member.
  HazelcastInstance hz1 = Hazelcast.newHazelcastInstance();
  // Start a Second Embedded Hazelcast Cluster Member
  HazelcastInstance hz2 = Hazelcast.newHazelcastInstance();
  // Get the Distributed Executor Service
  IExecutorService ex = hz1.getExecutorService("my-distributed-executor");
  // Submit the MessagePrinter Runnable to a random Hazelcast Cluster Member
  ex.submit(new MessagePrinter("message to any node"));
  // Get the first Hazelcast Cluster Member
  Member firstMember = hz1.getCluster().getMembers().iterator().next();
  // Submit the MessagePrinter Runnable to the first Hazelcast Cluster Member
  ex.executeOnMember(new MessagePrinter("message to very first member of the cluster"), firstMember);
  // Submit the MessagePrinter Runnable to all Hazelcast Cluster Members
  ex.executeOnAllMembers(new MessagePrinter("message to all members in the cluster"));
  // Submit the MessagePrinter Runnable to the Hazelcast Cluster Member owning the key called "key"
  ex.executeOnKeyOwner(new MessagePrinter("message to the member that owns the following key"), "key");
  // Shutdown this Hazelcast Cluster Member
  hz1.shutdown();
  // Shutdown this Hazelcast Cluster Member
  hz2.shutdown();
}

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

public static void main(String[] args) throws Exception {
    HazelcastInstance instance = Hazelcast.newHazelcastInstance();

    IScheduledExecutorService scheduler = instance.getScheduledExecutorService("scheduler");
    IScheduledFuture<String> future = scheduler.scheduleOnMember(new EchoTask("My Task"),
        instance.getCluster().getLocalMember(), 5, TimeUnit.SECONDS);

    Object result = future.get();
    System.out.println("Result: " + result);
    future.dispose();

    Hazelcast.shutdownAll();
  }
}

代码示例来源：origin: kaazing/gateway

private void initializeCluster(Config config) {
  if (clusterInitialized.compareAndSet(false, true)) {
    clusterInstance = Hazelcast.newHazelcastInstance(config);
    if (clusterInstance == null) {
      throw new RuntimeException("Unable to initialize the cluster");
    }
    Cluster cluster = clusterInstance.getCluster();
    cluster.addMembershipListener(this.membershipListener);
    
    clusterInstance.getLifecycleService().addLifecycleListener(new LifecycleListener() {
      
      @Override
      public void stateChanged(LifecycleEvent event) {
        if (event.getState() == SHUTTING_DOWN) {
          removeMember(localNodeId);
        }
      }
    });
    // Register a listener for Hazelcast logging events
    LoggingService loggingService = clusterInstance.getLoggingService();
    loggingService.addLogListener(Level.FINEST, this);
    this.collectionsFactory = new ClusterCollectionsFactory(clusterInstance);
    localNodeId = getMemberId(cluster.getLocalMember());
    IMap<MemberId, String> instanceKeyMap = collectionsFactory.getMap(INSTANCE_KEY_MAP);
    instanceKeyMap.put(localNodeId, localInstanceKey);
    IMap<String, Collection<String>> balancerMap = collectionsFactory.getMap(BALANCER_MAP_NAME);
    addBalancerMapEntryListeners(balancerMap);
  }
}

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

public static void main(String[] args) {
    final HazelcastInstance instance1 = Hazelcast.newHazelcastInstance();
    final HazelcastInstance instance2 = Hazelcast.newHazelcastInstance();

    System.out.println("Instance-1 members: " + instance1.getCluster().getMembers());
    System.out.println("Instance-2 members: " + instance2.getCluster().getMembers());

    // shutdown cluster
    instance2.getCluster().shutdown();

    System.out.println("Instance-1: Is running?: " + instance1.getLifecycleService().isRunning());
    System.out.println("Instance-2: Is running?: " + instance2.getLifecycleService().isRunning());
  }
}

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

public static void main(String[] args) {
    HazelcastInstance hz = Hazelcast.newHazelcastInstance();
    IExecutorService executorService = hz.getExecutorService("executor");

    for (Member member : hz.getCluster().getMembers()) {
      EchoTask task = new EchoTask(member.getSocketAddress().toString());
      executorService.executeOnMember(task, member);
    }
  }
}

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

public static void main(String[] args) {
    HazelcastInstance node1 = Hazelcast.newHazelcastInstance();
    HazelcastInstance node2 = Hazelcast.newHazelcastInstance();

    Member member2 = node2.getCluster().getLocalMember();

    boolean member2Safe = node1.getPartitionService().isMemberSafe(member2);

    System.out.printf("# Is member2 safe for shutdown\t: %s\n", member2Safe);
  }
}

代码示例来源：origin: org.neo4j/neo4j-core-edge

@Override
public void stop()
{
  log.info( String.format( "HazelcastCoreTopologyService stopping and unbinding from %s",
      config.get( CoreEdgeClusterSettings.discovery_listen_address ) ) );
  try
  {
    hazelcastInstance.getCluster().removeMembershipListener( membershipRegistrationId );
    hazelcastInstance.getMap( EDGE_SERVER_BOLT_ADDRESS_MAP_NAME ).removeEntryListener( mapRegistrationId );
    hazelcastInstance.getLifecycleService().terminate();
  }
  catch ( Throwable e )
  {
    log.warn( "Failed to stop Hazelcast", e );
  }
  finally
  {
    jobHandle.cancel( true );
  }
}

代码示例来源：origin: org.wso2.carbon.event-processing/org.wso2.carbon.event.processor.core

public void setHzaelCastInstance(HazelcastInstance hazelcastInstance){
  this.hazelcastInstance = hazelcastInstance;
  this.roleToMembershipMap = hazelcastInstance.getMap(STORM_ROLE_TO_MEMBERSHIP_HZ_MAP);
  myHazelcastId = hazelcastInstance.getCluster().getLocalMember().getUuid();
}

代码示例来源：origin: com.hazelcast.simulator/tests-hz37

@Prepare
public void prepare() {
  Set<Member> memberSet = targetInstance.getCluster().getMembers();
  memberAddresses = new Address[memberSet.size()];
  int i = 0;
  for (Member member : memberSet) {
    memberAddresses[i++] = new Address(member.getSocketAddress());
  }
}

代码示例来源：origin: dsukhoroslov/bagri

public TopologyManagement(HazelcastInstance hzInstance) {
  //super(hzInstance);
  this.hzInstance = hzInstance;
  hzInstance.getCluster().addMembershipListener(this);
}

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

/**
 * Return the name of the current Hazelcast instance.
 */
@Override
public String call() throws Exception {
  String uuid = hazelcastInstance.getCluster().getLocalMember().getUuid();
  log.info("call() runs on {}", uuid);
  return uuid;
}