0

我的实现非常简单,但它没有做应该做的事情。我正在使用这个缓存库:https ://github.com/ben-manes/caffeine

当我部署应用程序时:

Calls Controller Endpoint -> First time loads data to cache (works fine) -> Wait 10 seconds -> refresh data to cache -> wait 10 seconds -> ... over and over

第一次加载完美。问题是 10 秒后,数据的重新加载没有运行。

控制器

   MyData myData = MyData.getInstance();
   Map<String, List<String>> tableOne = myData.cache.get("tableOne");

MyData 类

public LoadingCache<String, Map<String, List<String>>> cache;

public static MyData getInstance() {
    if (instance == null) {
        synchronized (MyData.class) {
            if (instance == null) {
                instance = new MyData();
            }
        }
    }
    return instance;
}

 private MyData() {
    this.cache = Caffeine.newBuilder()
            .refreshAfterWrite(10, TimeUnit.SECONDS)
            .build(key -> MyData.getInstance().loadData(key));
}

private Map<String, List<String>> loadData(String key) {
       // Loads Data. This is only called once and never again!
}

任何线索为什么refreshAfterWrite不每 10 秒运行一次?

谢谢

4

1 回答 1

0

自上次写入后条目老化超过该阈值后,读取时触发刷新。

当对条目的第一个陈旧请求发生时,将执行自动刷新。触发刷新的请求将对 CacheLoader.reload 进行异步调用并立即返回旧值。

然后可以将其与过期相结合,以便重新加载热门条目,而不活动的条目将过期。在这种情况下,刷新避免了调用者定期阻止重新加载条目的惩罚,因为这种延迟是隐藏的,同时也确保它不会变得太陈旧。

定期重新加载缓存最好由您自己的线程提供服务。例如使用ScheduledExecutorService可以批量重新加载所有内容。

于 2020-05-20T21:12:05.563 回答