java - 榛卡斯特 map : remove entries owned by the node that goes down

Question

我使用 IMap 对象在集群节点之间共享一些信息。 这些信息与节点相关，并且由共享映射中的同一节点插入，因此如果该节点从集群中删除，则这些信息没有意义。

我知道存在一个 MemberShipListener 并且我可以捕获事件 memberRemoved 但我不知道如何删除已删除成员拥有的条目。所以我想知道是否存在可以自动完成此操作的方法。

Answer 1

没有自动的方法，至少我不知道，但是您可以构建一个小的解决方法。为此，您需要保留第二个数据结构(MultiMap)来保存有关成员的唯一 ID 及其分配的键的信息。下面显示了一些伪代码:

class MapWrapper<K, V> {
  MultiMap<String, K> metadata = hazelcastInstance.getMultiMap("metadata");

  Cluster cluster = hazelcastInstance.getCluster();
  Member localMember = cluster.getLocalMember();
  String uuid = localMember.getUuid();

  IMap<K, V> realMap = hazelcastInstance.getMap("...");

  public void putWrapper(K key, V value) {
    realMap.put(key, value);
    metadata.put(uuid, key);
  }
}

您可以使用 MembershipListerner 并首先通过向集群询问所有成员并获取结果集中的第一个成员来测试当前节点是否是“领导者”(集群中最老的成员)。

Cluster cluster = hazelcastInstance.getCluster();
Member leader = cluster.getMembers().iterator().next();
if (cluster.getLocalMember().equals(leader)) { ... }

现在，既然您知道此操作只会发生一次(仅在领导者上)，只需使用元数据来删除元素，如下所示:

void memberRemoved(MembershipEvent membershipEvent) {
  if (isLeader()) {
    Member removedMember = membershipEvent.getMember();
    Collection<K> keys = metadata.remove(removedMember.getUuid());
    realMap.removeAll(keys);
  }
}

可能不是您正在寻找的好解决方案，但到目前为止我没有看到另一种方法来处理您的用例。我期待其他解决方案:)