我怀疑这个问题是否有现成的解决办法。
但是,您可以轻松构建自己的接口,以获取通用缓存对象并将其加载到缓存:
public interface GetCachedOrLoad<T> {
Flux<T> getCachedOrLoad(String key, Flux<T> loader, Class<? extends T> clazz);
}
public class PersistedObjectRepository {
private final GetCachedOrLoad<PersistedObject> getCachedOrLoad;
public PersistedObjectRepository(final GetCachedOrLoad<PersistedObject> getCachedOrLoad) {
this.getCachedOrLoad = getCachedOrLoad;
}
public Flux<PersistedObject> queryPersistedObject(final String key) {
return getCachedOrLoad.getCachedOrLoad(key, queryMongoDB(key), PersistedObject.class);
}
private Flux<PersistedObject> queryMongoDB(String key) {
// use reactivemongo api to retrieve Flux<PersistedObject>
}
}
然后需要创建一个对象
GetCachedOrLoad<T>
并使其可用于依赖注入。
public class RedisCache<T> implements GetCachedOrLoad<T> {
private final Function<String, Flux<String>> getFromCache;
private final BiConsumer<String, String> loadToCache;
private final Gson gson;
public RedisCache(Gson gson, RedisReactiveCommands<String, String> redisCommands) {
this.getFromCache = key -> redisCommands.lrange(key, 0, -1);
this.loadToCache = redisCommands::lpush;
this.gson = gson;
}
@Override
public Flux<T> getCachedOrLoad(final String key, Flux<T> loader, Class<? extends T> clazz) {
final Flux<T> cacheResults = getFromCache.apply(key)
.map(json -> gson.fromJson(json, clazz));
return cacheResults.switchIfEmpty(
loader.doOnNext(value -> loadToCache.accept(key, gson.toJson(value))));
}
}
希望这足够通用:)。
