在 Hazelcast 中找出 MapLoader 何时完成（急切）加载

Question

我使用 MapLoader 将数据从数据存储区初始加载到 Hazelcast (InitialLoadMode = EAGER)。我需要从在此加载过程开始时为加载而创建的物化视图中加载此数据，并且在加载完成后，我需要删除此物化视图。

有什么方法可以告诉 Hazelcast 在我开始使用 MapLoader 加载数据之前触发我的代码创建此视图？

在初始加载完成后，Hazelcast 有什么方法可以通知？我查看了听众，但我只看到了那些关于单一价值的人。

我想出的唯一方法是在 MapLoader.loadAllKeys() 中创建物化视图（它保证它只会执行一次，并且它会在任何人可以从地图中获取某些东西之前执行，因此在任何人之前可以无意中调用加载过程），然后在其他地方调用 getMap("") （我使用 EAGER），当它完成时，删除实体。

有更好的方法吗？

Answer 1

如果您需要完全控制初始化过程，那么您可能需要在不使用 MapLoader 的情况下手动填充地图：

public class MapWrapper {

    private Lock lock = hazelcastInstance.getLock("map-lock");
    private IAtomicLong mapIsLoaded = ...;
    ICountDownLatch latch = hazelcastInstance.getCountDownLatch("map-loaded");

    public MapWrapper() {
        latch.trySetCount(1);
    }

    public void initialize() {
        lock.lock();
        // Loading:
        try {
            // Skip loading if map already loaded (ensure only once for cluster)
            if(mapIsLoaded.get() == 1) {
                return;
            }
            mapIsLoaded.set(0);
            // Here code to load your map, clean database:
            initializeDatabase();
            loadMap();
            cleanDatabase();
        } finally {
            latch.countdown();
            mapIsLoaded.set(1);
            lock.unlock();
        }
    }

    public Map getMap() {
        // Blocking until loading is completed:
        latch.await();
        return hazelcastInstance.getMap(...);
    }
}