Scaffeine：如何为默认值设置不同的到期时间

问题描述

Scala 应用程序用例：

我们有一个基于 Scala 的模块，该模块从全局缓存 (Redis) 读取数据并将其保存到本地缓存 (Scaffeine) 中。由于我们希望异步刷新此数据，因此我们使用了 LoadingCache，并将 refreshAfterWrite 持续时间设置为 2 秒的刷新窗口。

问题：

我们需要根据redis（全局缓存）中是否存在键来设置本地缓存中的值时设置不同的到期时间。

例如 如果全局缓存中不存在键，我们希望将相同的键保存在本地缓存中，默认值和刷新窗口设置为 5.minutes。 如果全局缓存中存在键，我们希望将相同的值存储在本地缓存中，具有实际值，并且刷新窗口设置为 30.minute。

示例代码

object LocalCache extends App {

  // data being stored in the cache
  class DataObject(data: String) {
    override def toString: String = {
      "[ 'data': '" + this.data + "' ]"
    }
  }

  // loader helper
  private def loaderHelper(key: Int): Future[DataObject] = { 
    // this method will replace to read the data from Redis Cache
    // for Now,returns different values per key

    if (key == 1) Future.successful(new DataObject("LOADER_HELPER_1"))
    else if (key == 2) Future.successful(new DataObject("LOADER_HELPER_2"))
    else Future.successful(new DataObject("LOADER_HELPER"))
  }

  // async loader
  private def loader(key: Int): DataObject = {
      Try {
        Await.result(loaderHelper(key),1.seconds)
      } match {
        case Success(result) =>
          result
        case Failure(exception: Exception) =>
          val temp: DataObject = new DataObject("LOADER")
          temp
      }
  }

  // initCache
  private def initCache(maximumSize: Int): LoadingCache[Int,DataObject] =
    Scaffeine()
      .recordStats()
      .expireAfterWrite(2.second)
      .maximumSize(maximumSize)
      .build(loader)

  // operations on the cache.
  val cache: LoadingCache[Int,DataObject] = initCache(maximumSize = 500)
  cache.put(1,new DataObject("foo"))
  cache.put(2,new DataObject("hoo"))

  println("sleeping for 3 sec\n")
  Thread.sleep(3000)
  println(cache.getIfPresent(1).toString)
  println(cache.getIfPresent(2).toString)
  println(cache.get(3).toString)

  println("sleeping for 10 sec\n")
  Thread.sleep(10000)
  println("waking up from 10 sec sleep")

  println(cache.get(1).toString)
  println(cache.get(2).toString)
  println(cache.get(3).toString)

  println("\nCache Stats: "+ cache.stats())
}

我看到很多 custom.policy 可用于覆盖 expiryAfter 策略（expiryAfterWrite/Update/Access），但没有找到异步刷新数据的 refreshAterWrite 策略。任何帮助将是可观的。

附注 我是 Scala 的新手，我也在探索 Scaffeine。

解决方法

不幸的是，尚不支持变量刷新。有一个 open issue 来提供该功能。

目前每个条目可以自定义过期时间，但自动刷新已修复。如果您想自己管理手动刷新，LoadingCache.refresh(key) 可能会触发它。例如，您可以定期迭代条目（通过 asMap() 视图）并根据自定义条件手动刷新。

AsyncLoadingCache 可能很有用，而不是在缓存加载器中阻塞未来。缓存将返回飞行中的未来，在值实现之前不会使其过期，并且如果失败将删除它。请注意，synchronous() 视图对于异步缓存访问更多操作非常有用。

通过测试，您可能会发现 Guava 的假代码对 simulate time 很有用。