Guava Cache 的预加载值

Question

我有一个要求，我们从数据库加载静态数据以在 Java 应用程序中使用。任何缓存机制都应该具有以下功能：

• 从数据库加载所有静态数据（一旦加载，该数据将不会改变）
• 从数据库加载新数据（启动时数据库中存在的数据不会改变，但可以更改）添加新数据）

所有数据的延迟加载不是一个选项，因为应用程序将部署到多个地理位置并且必须与单个数据库通信。当应用程序位于与数据库不同的区域时，延迟加载数据将使对特定元素的第一个请求太慢。

我一直在 Guava 中成功使用 MapMaker API，但我们现在正在升级到最新版本，我似乎无法在 CacheBuilder API 中找到相同的功能；我似乎无法找到一种在启动时加载所有数据的干净方法。

一种方法是从数据库加载所有密钥并通过缓存单独加载这些密钥。这可以工作，但会导致对数据库的 N+1 次调用，这并不是我正在寻找的有效解决方案。

public void loadData(){
    List<String> keys = getAllKeys();
    for(String s : keys)
        cache.get(s);
}

或者另一个解决方案是使用 ConcurrentHashMap 实现并自己处理所有线程和丢失的条目？我并不热衷于这样做，因为 MapMaker 和 CacheBuilder API 免费提供基于密钥的线程锁定，而无需提供额外的测试。我也非常确定 MapMaker/CacheBuilder 实现将具有一些我不知道/没有时间研究的效率。

public Element get(String key){
    Lock lock = getObjectLock(key);
    lock.lock();
    try{
        Element ret = map.get(key)
        if(ret == null){
            ret = getElement(key); // database call
            map.put(key, e);
        }
        return ret;
    }finally {
        lock.unlock();
    } 
}

谁能想到更好的解决方案来满足我的两个要求？

---

功能请求

我不认为预加载缓存是一个不常见的需求，因此如果 CacheBuilder 提供一个配置选项来预加载缓存那就太好了。我认为提供一个在启动时填充缓存的接口（很像 CacheLoader）将是一个理想的解决方案，例如：

CacheBuilder.newBuilder().populate(new CachePopulator<String, Element>(){

    @Override
    public Map<String, Element> populate() throws Exception {
        return getAllElements();
    }

}).build(new CacheLoader<String, Element>(){

    @Override
    public Element load(String key) throws Exception {       
        return getElement(key);
    }

});

此实现将允许缓存预先填充所有相关的 Element 对象，同时保留底层的 CustomConcurrentHashMap对外界不可见。

Answer 1

短期内我只会使用 Cache.asMap().putAll(Map)。

Guava 11.0 发布后，您可以使用 Cache.getAll(Iterable)，这将为所有不存在的元素发出单个批量请求。

Answer 2

我将从数据库加载所有静态数据，并使用 cache.asMap().put(key, value) 将其存储在缓存中（[Guava 10.0.1 允许在缓存上进行写入操作。 asMap() 视图][1])。

当然，如果您的缓存配置为逐出条目，则此静态数据可能会被逐出......

CachePopulator 的想法很有趣。