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

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

本文整理了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");
  4.     HazelcastInstance instance1 = Hazelcast.newHazelcastInstance();
  5.     HazelcastInstance instance2 = Hazelcast.newHazelcastInstance();
  7.     IMap<Object, Object> map = instance2.getMap("test-map");
  8.     // initialize partition assignments
  9.     map.size();
  11.     System.out.println("Instance-1 Cluster State: " + instance1.getCluster().getClusterState());
  12.     System.out.println("Instance-2 Cluster State: " + instance2.getCluster().getClusterState());
  14.     instance2.getCluster().changeClusterState(ClusterState.NO_MIGRATION);
  15.     System.out.println("Instance-1 Cluster State: " + instance1.getCluster().getClusterState());
  16.     System.out.println("Instance-2 Cluster State: " + instance2.getCluster().getClusterState());
  18.     // start a new instance
  19.     HazelcastInstance instance3 = Hazelcast.newHazelcastInstance();
  21.     System.out.println("Instance-3 Members: " + instance3.getCluster().getMembers());
  22.     System.out.println("Instance-3 Cluster State: " + instance3.getCluster().getClusterState());
  24.     Hazelcast.shutdownAll();
  25.   }
  26. }

代码示例来源：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();
  4.     IScheduledExecutorService scheduler = instance.getScheduledExecutorService("scheduler");
  5.     IScheduledFuture<String> future = scheduler.scheduleOnMember(new EchoTask("My Task"),
  6.         instance.getCluster().getLocalMember(), 5, TimeUnit.SECONDS);
  8.     Object result = future.get();
  9.     System.out.println("Result: " + result);
  10.     future.dispose();
  12.     Hazelcast.shutdownAll();
  13.   }
  14. }

代码示例来源：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.     
  10.     clusterInstance.getLifecycleService().addLifecycleListener(new LifecycleListener() {
  11.       
  12.       @Override
  13.       public void stateChanged(LifecycleEvent event) {
  14.         if (event.getState() == SHUTTING_DOWN) {
  15.           removeMember(localNodeId);
  16.         }
  17.       }
  18.     });
  19.     // Register a listener for Hazelcast logging events
  20.     LoggingService loggingService = clusterInstance.getLoggingService();
  21.     loggingService.addLogListener(Level.FINEST, this);
  22.     this.collectionsFactory = new ClusterCollectionsFactory(clusterInstance);
  23.     localNodeId = getMemberId(cluster.getLocalMember());
  24.     IMap<MemberId, String> instanceKeyMap = collectionsFactory.getMap(INSTANCE_KEY_MAP);
  25.     instanceKeyMap.put(localNodeId, localInstanceKey);
  26.     IMap<String, Collection<String>> balancerMap = collectionsFactory.getMap(BALANCER_MAP_NAME);
  27.     addBalancerMapEntryListeners(balancerMap);
  28.   }
  29. }

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

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

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

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

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

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

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

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

Cluster

相关文章

    查看更多

    热门标签

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

    最新文章

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