如何将 @Cacheable 与 Kotlin 挂起功能一起使用

Question

我正在 Kotlin 和 Spring Boot 项目中工作，我正在尝试使用 Caffeine 进行缓存。我有一个具有暂停功能的服务，可以进行 http 调用。这是我的配置：

@Bean
open fun caffeineConfig(): @NonNull Caffeine<Any, Any> {
   return Caffeine.newBuilder().expireAfterWrite(60, TimeUnit.SECONDS)
}

@Bean
open fun cacheManager(caffeine: Caffeine<Any, Any>): CacheManager {
    val caffeineCacheManager = CaffeineCacheManager()
    caffeineCacheManager.getCache("test")
    caffeineCacheManager.setCaffeine(caffeine)
    return caffeineCacheManager
}

这是我想要缓存的函数：

@Cacheable(value = ["test"])
open suspend fun getString(id: String): String {
    return client.getString(id)
}

但似乎缓存不起作用，因为我可以从日志中看到每次调用服务函数时都会调用客户端。不适@Cacheable用于暂停功能？或者我还缺少其他东西吗？

Answer 1

的文档@Cacheable说：

每次调用建议的方法时，都会应用缓存行为，检查是否已经为给定的参数调用了该方法。合理的默认值只是使用方法参数来计算密钥，但可以通过 key() 属性提供 SpEL 表达式，或者自定义 KeyGenerator 实现可以替换默认值（请参阅 keyGenerator()）。

修饰符在生成的代码中suspend插入一个参数，该参数接受来自调用者的输入。Continuation<String>这可能意味着每个调用都有自己的延续，并且缓存将其检测为唯一的调用。

但是，由于返回值也会根据延续而变化，因此您不能让缓存忽略延续参数。更好的方法是不使用suspend函数，而是返回Deferred消费者可以共享的：

@Cacheable(value = ["test"])
open fun getString(id: String): Deferred<String> {
    return someScope.async {
        client.getString(id)
    }
}

// Consumer side
getString(id).await()

这应该与标准缓存机制一起使用，因为Deferred它是一个普通对象并且不需要特殊参数。