Hazelcast 3.6正确关闭节点

Question

我试图找出当我取下一个节点时丢失数据的原因。我有两个节点运行hazelcast 3.6应用程序的开发集群。HZ应用程序配置为有271个分区，我通过远程客户端向集群写入271个唯一密钥。我验证了数据在两个节点之间正确分布，并在另一个节点上存储和备份。

过了一段时间，我停止了对集群的写入，我只从集群中读取数据，然后我关闭了这个集群中的一个节点。在调用实例上的shutdown方法之前，我检查集群是否安全。

Hazelcast.shutdownAll();
for (int i = 0; i < 12; i++) {
    log.info("Verifying whether it is safe to close this instance");
    boolean isSafe = getResultsForAllInstances(hzi -> hzi
            .getPartitionService()
            .forceLocalMemberToBeSafe(10, TimeUnit.SECONDS));
    if (isSafe) {
        log.info("Verifying whether cluster is safe.");
        isSafe = getResultsForAllInstances(hzi -> hzi
                .getPartitionService()
                .isClusterSafe());
        if (isSafe) {
            break;
        }
    }

    Uninterruptibles.sleepUninterruptibly(1, TimeUnit.SECONDS);
}

private boolean getResultsForAllInstances(Function<HazelcastInstance, Boolean> hazelcastInstanceBooleanFunction) {
    return getAllHazelcastInstances().stream()
            .map(hazelcastInstanceBooleanFunction)
            .reduce(true, (old, next) -> old && next);
}

不幸的是，另一个节点正在记录分区丢失和我丢失的数据。

这是我在google group上问过的一个问题，但是没有人回答，所以我仍然不知道这是3.6的一个普遍问题还是我在做一些愚蠢的事情。

我还发现了节点立即终止的情况下的错误报告，但在我的情况下，我尝试优雅地关闭节点，它有时间与其他节点进行通信。所以我在这里错过了什么：]

谢谢

Answer 1

所以看起来数据没有丢失，但是我在关闭一个节点后在客户端有很多连接丢失的错误，处理这些异常的业务逻辑是不正确的。

另一个错误的线索是我在另一个节点上得到的分区丢失事件。我仍然不明白这个机制，我希望在HZ的留档中有更多的解释。

@雷维卡：谢谢你的耐心！：]

Answer 2

您的数据的复制级别是多少？如果希望数据在节点丢失的情况下仍能正常运行，则需要备份。例子。

<hazelcast>
  <map name="default">
    <backup-count>1</backup-count>
  </map>
</hazelcast>

默认备份是1。这意味着每个实体只存储一次，因此只存在于一个节点中。因此，如果上述节点出现故障，您将丢失其所有数据。希望这有帮助：）