如何使用Google Guava自动刷新缓存？

Question

我正在使用Google Guava库进行缓存.对于自动缓存刷新,我们可以执行以下操作:

cache = CacheBuilder.newBuilder()               
                    .refreshAfterWrite(15, TimeUnit.MINUTES)
                    .maximumSize(100)
                    .build(....);

但是,当第一个条目的陈旧请求发生时,将执行自动刷新.

有没有办法自动刷新它,即使没有缓存数据的请求？就像每15分钟一样,缓存数据应该从Db中提取并加载它,无论是否有人调用缓存数据.

此外,Guava的缓存到期时间适用于整个缓存.是否可以基于密钥使缓存值失效？像密钥"NOT_SO_FREQ_CHANGE_DATA"的缓存数据每1小时到期一次,密钥"FREQ_CHANGING_DATA"的数据应该每15分钟到期一次？

Answer 1

Guava无法批量刷新缓存,但您可以自行安排定期刷新:

LoadingCache<K, V> cache = CacheBuilder.newBuilder()
        .refreshAfterWrite(15, TimeUnit.MINUTES)
        .maximumSize(100)
        .build(new MyCacheLoader());

for (K key : cache.asMap().keySet()) {
    cache.refresh(key);
}

但在这种情况下,您可能希望覆盖该CacheLoader.reload(K, V)方法,MyCacheLoader以便它以异步方式执行.

至于第二个问题,不,你不能在番石榴中设置每个条目的到期日.

Answer 2

带并行流的JAVA 8版本:

Executors
        .newSingleThreadScheduledExecutor()
        .scheduleWithFixedDelay(() -> configurationCache
                .asMap()
                .keySet()
                .parallelStream()
                .forEach((key) -> configurationCache.refresh(key)),
            0,
            1, TimeUnit.SECONDS);

Answer 3

第一个问题.使用计划执行程序启动定期刷新.

第二个问题.如果您可以从缓存密钥或先前缓存的值推断出到期策略,则可以按不同的时间间隔刷新数据.

基于此:https: //code.google.com/p/guava-libraries/wiki/CachesExplained#Refresh

LoadingCache<Key, Graph> graphs = CacheBuilder.newBuilder()
   .refreshAfterWrite(1, TimeUnit.MINUTES)
   .build(
       new CacheLoader<Key, Graph>() {
         public Graph load(Key key) { // no checked exception
           return getGraphFromDatabase(key);
         }

         public ListenableFuture<Graph> reload(final Key key, Graph prevGraph) {
           if (!needsRefresh(key,prevGraph)) {
             return Futures.immediateFuture(prevGraph);
           } else {
             // asynchronous!
             ListenableFutureTask<Graph> task = ListenableFutureTask.create(new Callable<Graph>() {
               public Graph call() {
                 return getGraphFromDatabase(key);
               }
             });
             executor.execute(task);
             return task;
           }
         }
       });

ScheduledExecutorService ses = Executors.newSingleThreadScheduledExecutor();
ses.scheduleWithFixedDelay(
    new Runnable() {
        public void run() {
            for (Key key : graphs.asMap().keySet()) {
                graphs.refresh(key);
            }
        }
    }, 0, UPDATE_INTERVAL, TimeUnit.MINUTES);