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

Question

我正在学习Spring WebFlux,在编写示例应用程序时,我发现了与Reactive类型(Mono/Flux)结合Spring Cache的问题.

考虑以下代码片段(在Kotlin中):

@Repository
interface TaskRepository : ReactiveMongoRepository<Task, String>

@Service
class TaskService(val taskRepository: TaskRepository) {

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

这种有效且安全的缓存方法调用是返回Mono还是Flux？也许还有其他一些原则可以做到这一点？

以下代码使用SimpleCacheResolver,但默认情况下使用Redis失败,因为Mono不是Serializable.为了使它们工作,例如需要使用Kryo序列化器.

Answer 1

哈克方式

目前,没有@Cacheable与Reactor 3的流畅集成.但是,您可以通过添加.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()
}

那个hack缓存和从taskRepository数据返回的共享.反过来,spring cacheable将缓存返回的引用Mono然后,将返回该引用.换句话说,它是一个保存缓存的单声道缓存:).

Reactor Addons Way

有一个除了对反应器3,允许与现代的内存缓存一样流利整合咖啡因,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插件缓存自己的抽象Signal<T>,因此,不要担心并遵循该约定