如何停止和关闭整个hazelcast群集？

Question

如何停止并关闭hazelcast集群？我从测试中观察到，每当一个节点ist被HazelcastInstance#关闭（）停止时，集群都会尝试重新平衡或备份数据。我如何首先“停止”集群，然后将其关闭？（或者我的观察是错误的？）

Answer 1

测试时，我经常使用Hazelcast.shutdownAll（）

这将杀死所有实例。

Answer 2

回答永远不会太迟：）

如果希望在关机期间不触发迁移事件，可以将群集状态更改为被动：

hazelcastInstance.getCluster().changeClusterState(PASSIVE);

我建议在以下情况下进行此操作：

if (partitionService.isClusterSafe()) {
    hazelcastInstance.getCluster().changeClusterState(PASSIVE);
    hazelcastInstance.getCluster().shutdown(); 
    // or send exit command to each node, as in mrck answer - remember that then action must be an AllowedDuringPassiveState
}

在被动和冻结状态下，Hazelcast不会进行迁移，因此，关闭集群时不会出现错误。如果块有助于确保，那么更改状态和关闭是安全的，以防止数据丢失

Answer 3

您可以使用isClusterSafe，如下例所示：

public class ShutdownCluster {

public static void main(String[] args) throws Exception {

    HazelcastInstance member1 = Hazelcast.newHazelcastInstance();
    HazelcastInstance member2 = Hazelcast.newHazelcastInstance();
    HazelcastInstance member3 = Hazelcast.newHazelcastInstance();

    if(member1.getPartitionService().isClusterSafe()) {
        IExecutorService executorService = member1.getExecutorService(ShutdownCluster.class.getName());
        executorService.executeOnAllMembers(new ShutdownMember());
    }
}

private static class ShutdownMember implements Runnable, HazelcastInstanceAware, Serializable {

    private HazelcastInstance node;

    @Override
    public void run() {
        node.getLifecycleService().shutdown();
    }

    @Override
    public void setHazelcastInstance(HazelcastInstance node) {
        this.node = node;
    }
}
}