WebFlux - 如何检查 Mono<ResponseEntity<Flux<MyItem>>> 是否为空以返回 404

Question

我的代码：

public Mono<ResponseEntity<Flux<TreeItem>>> allGroups(
      @PathVariable(value = "email") String email, ServerWebExchange exchange) {

    return Mono.just(
            userGroupService
                .findGroupByEmail(email) //Flux<GroupById>
                .flatMap(getGroups(email)) //Flux<TreeItem>
                .map(TreeItem::getId) //Flux<UUID>
                .collectList() //Mono<List<UUID>>
                .flatMap(getFilteredGroupIdsForUserPrivilege())
                .flatMapMany(Flux::fromIterable) //Flux<UUID>
                .flatMap(getUserTreeGroups(email)))
        .map(ResponseEntity::ok)
        .defaultIfEmpty(ResponseEntity.notFound().build()); --> is not executed at all when no data are returned

当我传递不存在的电子邮件时，我的代码返回带有空数组的响应 200：[]

在这种情况下，我想返回404 error - 为什么最后一行没有执行？

.defaultIfEmpty(ResponseEntity.notFound().build());

getUserTreeGroups 方法：

private Function<UUID, Publisher<? extends TreeItem>> getUserTreeGroups(String email) {
    return filteredGroupId -> userGroupService
        .findUserTreeGroup(filteredGroupId, email);
  }

和方法findUserTreeGroup：

public Mono<GroupTreeItem> findUserTreeGroup(UUID groupId, String email) {
    return groupByIdRepo.findById(groupId)
            .flatMap(group -> findChildData(email, group));
  }

我想向前端返回一个 TreeItem 列表。 老实说 - 我仍然不明白何时使用 Mono<ResponseEntity<Flux<TreeItem>>> 或 Mono<ResponseEntity<List<TreeItem>>>？有什么区别？

更新 应用 Thomas Andolf 的解决方案后：

public Mono<ResponseEntity<Flux<TreeItem>>> userAllTreeGroups(
    @PathVariable(value = "email") String email, ServerWebExchange exchange) {
    return userGroupService
              .findUserGroupByEmail(email) //Flux<GroupById>
              .flatMap(groupById -> userGroupService.findUserTreeGroup(groupById.getId(), email)) //Flux<TreeItem>
              .map(TreeItem::getId) //Flux<UUID>
              .collectList() //Mono<List<UUID>>
              .flatMap(groupIds ->
                  rolePrivilegesService.filterGroupIdsForUserPrivilege(groupIds, GROUP_USER_READ_PRIVILEGE))
              .flatMapMany(Flux::fromIterable) //Flux<UUID>
              .flatMap(filteredGroupId -> userGroupService.findUserTreeGroup(filteredGroupId, email)) //Flux<GroupItem>
              .collectList() //Mono<List<TreeItem>>
              .map(ResponseEntity::ok) //Mono<ResponseEntity<List<TreeItem>>>
              .defaultIfEmpty(ResponseEntity.notFound().build());

但我仍然必须返回 Mono>>。

你认为我的方法应该返回什么？ Mono>> 喜欢在您的解决方案中？？？

Answer 1

在我的第二条评论中，我问了

为什么要将所有内容都放入Mono.just()？

你没有回答，好吧，如果你真的读过它，那将解决它，因为这可能是你的问题。

final List<String> strings = Collections.emptyList();

// You are wrapping a flux in a mono for some strange reason?
final Mono<Flux<String>> wrappedFlux = Mono.just(Flux.fromIterable(strings)
        .flatMap(s -> Mono.just("This never gets run"))
).defaultIfEmpty(Flux.just("This never gets run either, because there is a flux in the mono"));

重写

// Can't test it but something in the lines of the following
return userGroupService
            .findGroupByEmail(email) //Flux<GroupById>
            .flatMap(getGroups(email)) //Flux<TreeItem>
            .map(TreeItem::getId) //Flux<UUID>
            .collectList() //Mono<List<UUID>>
            .flatMap(getFilteredGroupIdsForUserPrivilege())
            .flatMapMany(Flux::fromIterable) //Flux<UUID>
            .flatMap(getUserTreeGroups(email)))
            .collectList()
            .map(ResponseEntity::ok)
            .defaultIfEmpty(ResponseEntity.notFound().build());

Mono<T> 将持有一个未来的计算。当有人订阅它时，它会尝试解析其中的内容，当它的内部状态变为COMPLETED时，它会射出它。

Flux<T> 是同一件事，但适用于许多对象。你可以想如果它和以前一样多Mono<T>s，当有人订阅它时，它会尝试解决Flux<T>中每个项目中的问题，并在状态达到@987654330时立即弹出这些问题@每个人。

在您订阅 Mono<T> or aFlux 之前，什么都不会发生。

如果您订阅时有Mono<Flux<T>>，它会尝试解析其中的任何内容，而其中的内容是Flux<T>，因此会被直接枪杀。

另一方面，Flux<T> 没有人订阅，因此其中没有任何内容得到解决。基本上是死的、空的、没用过的。

你在问我：

所以在您看来，在 Mono 中使用 Flux 毫无意义/毫无意义

我刚刚在上面写了反应式编程如何工作的绝对基础。您正在从没有人订阅的 Mono<T> 发出 Flux<T>。

除非您订阅，否则什么都不会发生。

我建议你从一开始就阅读reactor的文档，这对理解reactive programming的基本概念很有帮助

我不知道你想要达到什么目标，因为我没有你的完整代码库，我不知道你要返回什么。

Answer 2

简单来说，您可以像这样编写您的退货声明

return Mono.just(ResponseEntity.ok(yourService.yourMethod()));