gpt4 book ai didi

java - 如何缓存 Mono 对象

转载 作者:行者123 更新时间:2023-11-30 06:14:14 25 4
gpt4 key购买 nike

我有以下代码:

final T savedEntity = repository.save(entity);
entityCacheService.putIntoCache(entity.getId(), savedEntity);

现在我使我的存储库成为响应式(Reactive)的。我的问题是如何使缓存存储现在为单声道和通量。

final Mono<T> savedEntity = repository.save(entity);
entityCacheService.putIntoCache(entity.getId(), <<What here>>);

我遇到了以下Mono and Flux Caching但这仅用于查找,因为我也是响应式(Reactive)编程的初学者。

最佳答案

针对您的情况,最好的方法是依赖 save 的事实操作返回 Mono<T>发出保存的实体。

因此您可以使用doOnNext每当该实体保存在数据库中时,也将该实体放入缓存中:

final Mono<T> savedEntity = repository.save(entity)
.doOnNext(entity -> entityCacheService.putIntoCache(entity.getId(), entity);

结果Mono<T>每当实体被订阅时,都会保存然后缓存该实体。

关于java - 如何缓存 Mono 对象,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/49586959/

25 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com