咖啡因加载缓存-驱逐与自定义到期策略

Question

使用咖啡因2.8.1和Java8。我已经创建了加载缓存

我已经指定了一个CacheLoader来通过调用keyExistsOnServer（key）方法来计算值，该方法调用外部服务来获取值。

我指定了一个自定义过期策略，如果在缓存中创建/更新条目时将该值设置为false，我希望在10分钟内从缓存中逐出该条目。并尽可能长地保存它。最大值如果值为真。

  private RemovalListener<String, Boolean> removeListener =
      (key, value, cause) ->
          logger.info(
              "Entry for Key={} with value={} was removed ({}) from cache", key, value, cause);
  private LoadingCache<String, Boolean> cache =
      Caffeine.newBuilder()
          .expireAfter(
              new Expiry<String, Boolean>() {
                private static final long EXPIRATION_TEN_MINS_IN_NANOSECONDS = 600000000000L;

                @Override
                public long expireAfterCreate(String key, Boolean value, long currentTime) {
                  // If value is false that means key does not exist, so set expiration to 10 mins
                  return value ? Long.MAX_VALUE : EXPIRATION_TEN_MINS_IN_NANOSECONDS;
                }

                @Override
                public long expireAfterUpdate(
                    String key, Boolean value, long currentTime, long currentDuration) {
                  // If value is changed from true to false then set expiration to 10 mins
                  return value ? Long.MAX_VALUE : EXPIRATION_TEN_MINS_IN_NANOSECONDS;
                }

                @Override
                public long expireAfterRead(
                    String key, Boolean value, long currentTime, long currentDuration) {
                  // Don't modify expiration time after read
                  return currentDuration;
                }
              })
          .recordStats()
          .removalListener(removeListener)
          .build(key -> keyExistsOnServer(key));

问题#1：基于我想要实现的目标，我的过期策略看起来是否正确？

问题#2:

我没有看到按照逐出策略调用RemovalListener。这可能是由于github问题中所述的清理任务的累积。

然而，我的代码的正确性取决于这样一个事实：一个条目的过期时间（如果false值为10分钟）已经过去，并且如果我们调用缓存。get（key）则不应从缓存返回过期值，而是调用CacheLoader即keyExistsOnServer（key）方法来获取值。有人能断言这就是它的表现吗？

以下是@路易斯·乏色曼在github问题上所说的话，但我不清楚这是否澄清了它：

实际上，get调用本身发现条目已过期，并将其添加到要清理的条目队列中

问题#3：如果CacheLoader抛出RuntimeException会发生什么情况，这是调用缓存时的keyExistsOnServer（key）方法。获取（密钥）？

问题#4：cache.asMap（）是否包含过期但由于权责发生而未被清除的条目？

问题5：当我在expireAfterRead（）方法中记录currentDuration时，它似乎与经过的时间不一致。i、 e.如果将其设置为60000000000（10分钟），并将值更新为false我预计5分钟后应为300000000000，但事实并非如此。为什么会这样？

Answer 1

问题#1：基于我想要实现的目标，我的过期策略看起来是否正确？

是的，这看起来不错。您可以将常量设为Duration，或者使用TimeUnit进行计算，只是为了让它看起来更漂亮。

问题#2：我看不到拆迁监听者按照拆迁政策被叫来。

当缓存上发生足够多的活动时，就会发生这种情况。您可以指定一个Scheduler，它将根据下一个条目设置为过期的时间唤醒并为您调用cache.cleanUp。对于Java9个用户，Java提供了一个内置的调度线程，您可以通过在构建缓存时添加Caffeine.scheduler（Scheduler.systemScheduler）来利用它。

一旦一个条目的过期时间过去，如果我们调用缓存。get（key），则它不应从缓存返回过期值，而是调用CacheLoader。

正确。缓存将在查找时验证条目，如果过期，则重新加载。它永远不会返回过期的条目。

问题#3：如果CacheLoader抛出运行时异常，该异常是调用缓存时的keyExistsOnServer（key）方法。拿到钥匙了吗？

映射将不会建立，异常将传播到调用方。下一次调用get（key）将重试，可能再次失败。这是你的选择，如何适应这一点。通常不是这样是一个好答案，或者有时缓存失败是一个更好的答案。

问题#4：cache.asMap（）是否包含过期但由于权责发生而未被清除的条目？

缓存将保存条目，但通过查找或迭代等方式抑制它们可见。唯一的外部指示是size（），因为该计数器在删除过期条目之前不会更新。

问题5：当我在expireAfterRead（）方法中记录currentDuration时，它似乎与经过的时间不一致。i、 e.如果将其设置为60000000000（10分钟），并将值更新为false，我预计5分钟后应为300000000000，但事实并非如此。为什么会这样？

请打开单元测试问题，我们可以进行诊断。