java - Caffeine java 缓存 - 如果refreshAfterWrite过期，如何首先加载新值，然后返回新值而不是旧值

Question

我尝试使用咖啡因缓存并遇到问题:

假设缓存为空，我查询一个值，它使用加载程序并将新值加载到缓存中，2天后我查询相同的值，并得到旧值首先，然后在单独的线程上启动刷新，如果可以加载，则加载新值。

Caffeine.newBuilder()
        .refreshAfterWrite(5, TimeUnit.MINUTES)
        .expireAfterWrite(3, TimeUnit.DAYS)
        .build(loader);

我想要存档的是 - 尝试先刷新并在可能的情况下先返回新值，如果出现问题才返回旧值。我怎样才能存档这个？如何实现简单、面向 future 、整洁的实现，而不需要解决方法？那太棒了!

编辑:此解决方案可以正常工作吗？

boolean needsSyncRefresh = cache.policy().expireAfterWrite()
                .flatMap(stringBigDecimalExpiration -> stringBigDecimalExpiration.ageOf(key))
                .filter(age -> age.toMinutes() < 0 || age.toMinutes() > REFRESH_AFTER_MINUTES)
                .isPresent();

V value = cache.get(key);

if (needsSyncRefresh) {
    return cache.asMap().computeIfPresent(key, (k, oldValue) -> {
        if (oldValue.equals(value)) {
            try {
                return loader(key);
            } catch (Exception e) {
                //handle error
            }
        }
        return oldValue;
    });
}
return value;

Answer 1

我认为这里没有必要使用CacheWriter。相反，检查元数据以确定是否需要刷新。

最简单的可能是运行提前触发刷新的计划任务。例如，

var policy = cache.policy().expireAfterWrite().get();
for (var key : cache.asMap().keySet()) {
  boolean refresh = policy.ageOf(key)
      .filter(age -> age.toDays() >= 2)
      .isPresent();
  if (refresh) {
    cache.refresh(key);
  }
}

一个稍微复杂的版本在检索时通过检查检索到的值是否过时并执行新的计算来完成此操作，例如

V value = cache.get(key, this::loadValue);

var policy = cache.policy().expireAfterWrite().get();
boolean refresh = policy.ageOf(key)
    .filter(age -> age.toDays() >= 2)
    .isAbsent();
if (!refresh) {
  return value;
}
return cache.asMap().compute((key, oldValue) -> {
  if ((oldValue != null) && (oldValue != value)) {
    return oldValue; // reloaded by another thread
  }
  try {
    return loadValue(key);
  } catch (Exception e) {
    logger.error("Failed to load {}", key, e);
    return oldValue;
  }
});