正确使用Qukus缓存与Reactive和Mutiny

Question

我正在尝试将我的项目迁移到具有Hibernate反应模式的Quarkus反应模式，我不知道如何处理缓存。

我原来的方法是这样的

    @Transactional
    @CacheResult(cacheName = "subject-cache")
    public Subject getSubject(@CacheKey String subjectId) throws Exception {
        return subjectRepository.findByIdentifier(subjectId);
    }

主题通过缓存键“subjectId”从缓存中加载（如果可用）。

迁移到兵变会是这样的

    @CacheResult(cacheName = "subject-cache")
    public Uni<Subject> getSubject(@CacheKey String subjectId) {
        return subjectRepository.findByIdentifier(subjectId);
    }

但是，将Uni对象存储在缓存中是不对的。

还有将缓存作为bean注入的选项，但是，回退函数不支持返回Uni：

    @Inject
    @CacheName("subject-cache")
    Cache cache;


  //does not work, cache.get function requires return type Subject, not Uni<Subject>
  public Uni<Subject> getSubject(String subjectId) {
        return cache.get(subjectId, s -> subjectRepository.findByIdentifier(subjectId));
    }

  //This works, needs blocking call to repo, to return response wrapped in new Uni
  public Uni<Subject> getSubject(String subjectId) {
        return cache.get(subjectId, s -> subjectRepository.findByIdentifier(subjectId).await().indefinitely());
    }

@CacheResult注释是否可以与Uni/Multi一起使用，并且所有内容都可以在后台正确处理？

Answer 1

缓存Uni的问题在于，根据Uni的创建方式，多个订阅可能会多次触发某些代码。为了避免这种情况，您必须像这样记住Uni：

@CacheResult(cacheName = "subject-cache")
public Uni<Subject> getSubject(@CacheKey String subjectId) {
    return subjectRepository.findByIdentifier(subjectId)
        .memoize().indefinitely();
}

这将确保对缓存的Uni的每个订阅都将始终返回相同的值（项或失败），而不会重新执行原始Uni流的任何内容。

Answer 2

您在返回Uni的方法上使用CacheResult的示例应该实际可行。该实现将自动“剥离”Uni类型，并仅将主题存储在缓存中。