将两个单声道组合在一起，第二个单声道订阅第一个单声道

Question

我最近一直在学习使用Java中的reactor库和Spring框架进行反应式编程，并且在很大程度上我已经能够掌握它。然而，我发现自己有好几次遇到同样的情况，我想知道我哪里出了问题。

我正在努力解决的问题的要点是，我经常想用mono做一些事情，比如找到一些补充数据，然后将其添加回原始mono中。zip函数在我看来是一个理想的候选函数，但最终我订阅了两次原始mono，这不是我的意图。

这里有一个人为的例子，我一直在试图解决这种情况，因为我无法分享我的公司代码。它假设我们使用的是一个反应式数据库，并设置了一个记录器，Person类是不可变的，但具有

public Mono<Person> getPersonWithFamilyMembers(Integer id){
    log.info("Finding person with id {}", id);

    personRepository.findById(id)
        .switchIfEmpty(Mono.error(NotFoundException::new))
        .doOnNext(person -> log.info("Found person: {}", person))
        .as(this::fetchAndAddFamilyMembers)
        .doOnSuccess(person -> log.info("Successfully found person with family members"));
}

private Mono<Person> fetchAndAddFamilyMembers(Mono<Person> personMono){
    Mono<List<Person>> familyMembersMono = personMono
        .map(Person::getFamilyId)
        .flatMapMany(PersonRepository::findByFamilyId)
        .collectList();

    return personMono.zipWith(familyMembersMono, Person::withFamilyMembers);
}

我在运行这样的代码时看到的输出是：

INFO | Finding person with id 1
INFO | Found person: Person(id=1, familyId=1, familyMembers=[])
INFO | Found person: Person(id=1, familyId=1, familyMembers=[])
INFO | Successfully found person with family members

这确实是有意义的，因为原始人mono已经在两个地方订阅，在那里我将其映射到familyMembersMono中，并且当我将它们压缩在一起时，但是如果可以避免的话，我不想对存储库进行不必要的调用。

有人对处理这种行为的更好方法有什么建议吗？

Answer 1

一般来说，你不会“添加数据”到单声道，而是其中的数据。考虑到这一点，使用4A Map而不是作为：

public Mono<Person> getPersonWithFamilyMembers(Integer id){
    log.info("Finding person with id {}", id);

    return personRepository.findById(id)
        .switchIfEmpty(Mono.error(NotFoundException::new))
        .doOnNext(person -> log.info("Found person: {}", person))
        .flatMap(this::fetchAndAddFamilyMembers)
        .doOnSuccess(person -> log.info("Successfully found person with family members"));
}

private Mono<Person> fetchAndAddFamilyMembers(Person person){ // this accepts Person, not Mono<Person>
    return personRepository.findByFamilyId(person.getFamilyId())
        .collectList()
        .map(person::withFamilyMembers);
}