如果使用咖啡因和春季使用咖啡因，请使用旧/陈旧的缓存值

Question

如果缓存刷新失败，我需要使用旧/陈旧的高速缓存值。 我已经浏览了Internet上的许多示例，并决定尝试使用咖啡因缓存来实现此要求（更具体地使用RefReshafterWrite功能）。我能够使用咖啡因来缓存数据，但是当缓存刷新（REST API失败）失败时，无法获得旧/陈旧的值。 我已经使用了SimpleCacheManager（org.springframework.cache.support.simplecachemanager）和caffeinecache。

**simpleCacheManager bean code** :

    <bean id="simpleCacheManager" class="org.springframework.cache.support.SimpleCacheManager">
        <property name="caches" ref="caffeineCaches" />
    </bean>

**caffeine cache** :

    @Bean
    public Collection<? extends org.springframework.cache.Cache> caffeineCaches(){
        Collection<CaffeineCache> caffeineCaches = new ArrayList<>();
        caffeineCaches.add(new CaffeineCache("pbdBankRegistry",
                Caffeine.newBuilder()
                        .refreshAfterWrite(2, TimeUnit.MINUTES)
                        .initialCapacity(1)
                        .maximumSize(2)
                        .recordStats()
                        .build(new CustomCacheLoader()),false));
        return caffeineCaches;
    }


  **CacheLoader Code :**

    public class CustomCacheLoader implements CacheLoader<Object, Object> {
    @Nullable
    @Override
    public Object load(Object o) throws Exception {
        return null;
    }

    @Override
    public Map loadAll(Set keys) throws Exception {
        return CacheLoader.super.loadAll(keys);
    }

    @Override
    public CompletableFuture asyncLoad(Object key, Executor executor) throws Exception {
        return CacheLoader.super.asyncLoad(key, executor);
    }

    @Override
    public CompletableFuture<? extends Map> asyncLoadAll(Set keys, Executor executor) throws Exception {
        return CacheLoader.super.asyncLoadAll(keys, executor);
    }

    @Nullable
    @Override
    public Object reload(Object key, Object oldValue) throws Exception {
        return CacheLoader.super.reload(key, oldValue);
    }

    @Override
    public CompletableFuture asyncReload(Object key, Object oldValue, Executor executor) throws Exception {
        return CacheLoader.super.asyncReload(key, oldValue, executor);
    }

我认为我必须从重新加载方法或咖啡因的构建方法中调用我的API。但是我不确定。我是新的缓存，因此需要您的帮助来实现此代码。

注意：我的应用程序是春季4.3.3.Release版本。

Answer 1

在类似情况下，类似下面的事情对我有用：与 .build 提供函数。 /wiki/refresh“ rel =“ nofollow noreferrer”> https://github.com/ben-manes/caffeine/wiki/wiki/refresh ，通过实现 cacheloader 的对象，覆盖 load 和 Reload 方法。

/**
 * @see https://www.javadoc.io/doc/com.github.ben-manes.caffeine/caffeine/latest/com.github.benmanes.caffeine/com/github/benmanes/caffeine/cache/CacheLoader.html#reload(K,V)
 */ 
class CacheLoader_keepOldIf<K,V> implements CacheLoader<K,V> {
  private Function<K,V> loadFn;
  private Function<V,Boolean> testNewFn;
  CacheLoader_keepOldIf(
    Function<V,Boolean> testNewFn, 
    Function<K,V> loadFn
  ){
    this.loadFn = loadFn;
    this.testNewFn = testNewFn; 
  }
  @Override
  public @Nullable V reload(K key, V oldValue) throws Exception {
    V newValue = loadFn.apply(key);
    return testNewFn.apply(newValue) ? oldValue : newValue;
  } 
  @Override
  public @Nullable V load(K key) throws Exception {
    return loadFn.apply(key);
  }
} 

LoadingCache<String, Object> myCache = Caffeine.newBuilder()
    .refreshAfterWrite(5, TimeUnit.SECONDS) 
    .build(new CacheLoader_keepOldIf<String,Object>(
        newValue -> newValue==null, 
        key -> someExpensiveCallReturningNullOnFailure()
    ))
;

该代码似乎是毫无必要的冗长，只是为了覆盖 reload 方法：其中一些无疑是我的错，有些可能是Java。但是它完成了工作：如果我的数据库呼叫失败，则返回null，并且使用了先前的缓存值。大概也可以在 load 方法中指定默认值，以防第一个填充缓存失败的调用。

（根据Ben Manes对问题的评论，我认为问题中 load 的覆盖物应返回某物而不是null以解决原始问题）。