Spring Webflux和@Cacheable-缓存Mono/Flux类型结果的正确方法

Question

我正在学习Spring WebFlux，在编写示例应用程序的过程中，我发现了一个与Spring Cache结合的反应类型（Mono/Flux）相关的问题。

考虑以下代码段（Kotlin格式）：

@Repository
interface TaskRepository : ReactiveMongoRepository<Task, String>

@Service
class TaskService(val taskRepository: TaskRepository) {

    @Cacheable("tasks")
    fun get(id: String): Mono<Task> = taskRepository.findById(id)
}

下面的代码用于SimpleCacheResolver，但默认情况下，由于Mono不可序列化，在Redis中失败。为了使它们工作，例如，需要使用Kryo串行化器。

Answer 1

目前，@cacheable还没有与Reactor3进行流畅的集成。但是，您可以通过将.cache()运算符添加到返回的mono中来绕过该操作

@Repository
interface TaskRepository : ReactiveMongoRepository<Task, String>

@Service
class TaskService(val taskRepository: TaskRepository) {

    @Cacheable("tasks")
    fun get(id: String): Mono<Task> = taskRepository.findById(id).cache()
}

该黑客缓存和共享从taskrepository数据返回。反过来，spring cacheable将缓存返回的mono的引用，然后返回该引用。换句话说，它是mono的一个缓存，它持有缓存：）。

Reactor 3还增加了一个功能，它允许与现代内存缓存（如caffeine、jcache等）进行流畅的集成。使用该技术，您将能够轻松地缓存您的数据：

@Repository
interface TaskRepository : ReactiveMongoRepository<Task, String>

@Service
class TaskService(val taskRepository: TaskRepository) {

    @Autowire
    CacheManager manager;


    fun get(id: String): Mono<Task> = CacheMono.lookup(reader(), id)
                                               .onCacheMissResume(() -> taskRepository.findById(id))
                                               .andWriteWith(writer());

    fun reader(): CacheMono.MonoCacheReader<String, Task> = key -> Mono.<Signal<Task>>justOrEmpty((Signal) manager.getCache("tasks").get(key).get())
    fun writer(): CacheMono.MonoCacheWriter<String, Task> = (key, value) -> Mono.fromRunnable(() -> manager.getCache("tasks").put(key, value));
} 

注意：Reactor添加缓存自己的抽象，它是信号 ，因此，不必担心这一点和遵循该约定