com.hazelcast.core.Cluster类的使用及代码示例

x33g5p2x  于2022-01-18 转载在 其他  
字(10.9k)|赞(0)|评价(0)|浏览(194)

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

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

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

  1. public ClusterAppStateImpl(AppSettings settings, HazelcastMember hzMember, EsConnector esConnector) {
  2. this.hzMember = hzMember;
  3. // Get or create the replicated map
  4. operationalProcesses = (ReplicatedMap) hzMember.getReplicatedMap(OPERATIONAL_PROCESSES);
  5. operationalProcessListenerUUID = operationalProcesses.addEntryListener(new OperationalProcessListener());
  6. nodeDisconnectedListenerUUID = hzMember.getCluster().addMembershipListener(new NodeDisconnectedListener());
  7. if (ClusterSettings.isLocalElasticsearchEnabled(settings)) {
  8. this.healthStateSharing = new HealthStateSharingImpl(hzMember, new SearchNodeHealthProvider(settings.getProps(), this, NetworkUtilsImpl.INSTANCE));
  9. this.healthStateSharing.start();
  10. }
  11. this.esConnector = esConnector;
  12. }

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

  1. @Override
  2. public long getClusterTime() {
  3. return hzInstance.getCluster().getClusterTime();
  4. }

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

  1. public static void main(String[] args) {
  2. System.setProperty("hazelcast.phone.home.enabled", "false");
  3. HazelcastInstance instance1 = Hazelcast.newHazelcastInstance();
  4. HazelcastInstance instance2 = Hazelcast.newHazelcastInstance();
  5. IMap<Object, Object> map = instance2.getMap("test-map");
  6. // initialize partition assignments
  7. map.size();
  8. System.out.println("Instance-1 Cluster State: " + instance1.getCluster().getClusterState());
  9. System.out.println("Instance-2 Cluster State: " + instance2.getCluster().getClusterState());
  10. instance2.getCluster().changeClusterState(ClusterState.NO_MIGRATION);
  11. System.out.println("Instance-1 Cluster State: " + instance1.getCluster().getClusterState());
  12. System.out.println("Instance-2 Cluster State: " + instance2.getCluster().getClusterState());
  13. // start a new instance
  14. HazelcastInstance instance3 = Hazelcast.newHazelcastInstance();
  15. System.out.println("Instance-3 Members: " + instance3.getCluster().getMembers());
  16. System.out.println("Instance-3 Cluster State: " + instance3.getCluster().getClusterState());
  17. Hazelcast.shutdownAll();
  18. }
  19. }

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

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

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

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

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

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

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

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

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

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

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

  1. public static void main(String[] args) {
  2. // Start the Embedded Hazelcast Cluster Member.
  3. HazelcastInstance hz1 = Hazelcast.newHazelcastInstance();
  4. // Start a Second Embedded Hazelcast Cluster Member
  5. HazelcastInstance hz2 = Hazelcast.newHazelcastInstance();
  6. // Get the Distributed Executor Service
  7. IExecutorService ex = hz1.getExecutorService("my-distributed-executor");
  8. // Submit the MessagePrinter Runnable to a random Hazelcast Cluster Member
  9. ex.submit(new MessagePrinter("message to any node"));
  10. // Get the first Hazelcast Cluster Member
  11. Member firstMember = hz1.getCluster().getMembers().iterator().next();
  12. // Submit the MessagePrinter Runnable to the first Hazelcast Cluster Member
  13. ex.executeOnMember(new MessagePrinter("message to very first member of the cluster"), firstMember);
  14. // Submit the MessagePrinter Runnable to all Hazelcast Cluster Members
  15. ex.executeOnAllMembers(new MessagePrinter("message to all members in the cluster"));
  16. // Submit the MessagePrinter Runnable to the Hazelcast Cluster Member owning the key called "key"
  17. ex.executeOnKeyOwner(new MessagePrinter("message to the member that owns the following key"), "key");
  18. // Shutdown this Hazelcast Cluster Member
  19. hz1.shutdown();
  20. // Shutdown this Hazelcast Cluster Member
  21. hz2.shutdown();
  22. }

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

  1. public static void main(String[] args) throws Exception {
  2. HazelcastInstance instance = Hazelcast.newHazelcastInstance();
  3. IScheduledExecutorService scheduler = instance.getScheduledExecutorService("scheduler");
  4. IScheduledFuture<String> future = scheduler.scheduleOnMember(new EchoTask("My Task"),
  5. instance.getCluster().getLocalMember(), 5, TimeUnit.SECONDS);
  6. Object result = future.get();
  7. System.out.println("Result: " + result);
  8. future.dispose();
  9. Hazelcast.shutdownAll();
  10. }
  11. }

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

  1. private void initializeCluster(Config config) {
  2. if (clusterInitialized.compareAndSet(false, true)) {
  3. clusterInstance = Hazelcast.newHazelcastInstance(config);
  4. if (clusterInstance == null) {
  5. throw new RuntimeException("Unable to initialize the cluster");
  6. }
  7. Cluster cluster = clusterInstance.getCluster();
  8. cluster.addMembershipListener(this.membershipListener);
  9. clusterInstance.getLifecycleService().addLifecycleListener(new LifecycleListener() {
  10. @Override
  11. public void stateChanged(LifecycleEvent event) {
  12. if (event.getState() == SHUTTING_DOWN) {
  13. removeMember(localNodeId);
  14. }
  15. }
  16. });
  17. // Register a listener for Hazelcast logging events
  18. LoggingService loggingService = clusterInstance.getLoggingService();
  19. loggingService.addLogListener(Level.FINEST, this);
  20. this.collectionsFactory = new ClusterCollectionsFactory(clusterInstance);
  21. localNodeId = getMemberId(cluster.getLocalMember());
  22. IMap<MemberId, String> instanceKeyMap = collectionsFactory.getMap(INSTANCE_KEY_MAP);
  23. instanceKeyMap.put(localNodeId, localInstanceKey);
  24. IMap<String, Collection<String>> balancerMap = collectionsFactory.getMap(BALANCER_MAP_NAME);
  25. addBalancerMapEntryListeners(balancerMap);
  26. }
  27. }

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

  1. public static void main(String[] args) {
  2. final HazelcastInstance instance1 = Hazelcast.newHazelcastInstance();
  3. final HazelcastInstance instance2 = Hazelcast.newHazelcastInstance();
  4. System.out.println("Instance-1 members: " + instance1.getCluster().getMembers());
  5. System.out.println("Instance-2 members: " + instance2.getCluster().getMembers());
  6. // shutdown cluster
  7. instance2.getCluster().shutdown();
  8. System.out.println("Instance-1: Is running?: " + instance1.getLifecycleService().isRunning());
  9. System.out.println("Instance-2: Is running?: " + instance2.getLifecycleService().isRunning());
  10. }
  11. }

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

  1. public static void main(String[] args) {
  2. HazelcastInstance hz = Hazelcast.newHazelcastInstance();
  3. IExecutorService executorService = hz.getExecutorService("executor");
  4. for (Member member : hz.getCluster().getMembers()) {
  5. EchoTask task = new EchoTask(member.getSocketAddress().toString());
  6. executorService.executeOnMember(task, member);
  7. }
  8. }
  9. }

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

  1. public static void main(String[] args) {
  2. HazelcastInstance node1 = Hazelcast.newHazelcastInstance();
  3. HazelcastInstance node2 = Hazelcast.newHazelcastInstance();
  4. Member member2 = node2.getCluster().getLocalMember();
  5. boolean member2Safe = node1.getPartitionService().isMemberSafe(member2);
  6. System.out.printf("# Is member2 safe for shutdown\t: %s\n", member2Safe);
  7. }
  8. }

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

  1. @Override
  2. public void stop()
  3. {
  4. log.info( String.format( "HazelcastCoreTopologyService stopping and unbinding from %s",
  5. config.get( CoreEdgeClusterSettings.discovery_listen_address ) ) );
  6. try
  7. {
  8. hazelcastInstance.getCluster().removeMembershipListener( membershipRegistrationId );
  9. hazelcastInstance.getMap( EDGE_SERVER_BOLT_ADDRESS_MAP_NAME ).removeEntryListener( mapRegistrationId );
  10. hazelcastInstance.getLifecycleService().terminate();
  11. }
  12. catch ( Throwable e )
  13. {
  14. log.warn( "Failed to stop Hazelcast", e );
  15. }
  16. finally
  17. {
  18. jobHandle.cancel( true );
  19. }
  20. }

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

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

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

  1. @Prepare
  2. public void prepare() {
  3. Set<Member> memberSet = targetInstance.getCluster().getMembers();
  4. memberAddresses = new Address[memberSet.size()];
  5. int i = 0;
  6. for (Member member : memberSet) {
  7. memberAddresses[i++] = new Address(member.getSocketAddress());
  8. }
  9. }

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

  1. public TopologyManagement(HazelcastInstance hzInstance) {
  2. //super(hzInstance);
  3. this.hzInstance = hzInstance;
  4. hzInstance.getCluster().addMembershipListener(this);
  5. }

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

  1. /**
  2. * Return the name of the current Hazelcast instance.
  3. */
  4. @Override
  5. public String call() throws Exception {
  6. String uuid = hazelcastInstance.getCluster().getLocalMember().getUuid();
  7. log.info("call() runs on {}", uuid);
  8. return uuid;
  9. }

相关文章