java - 如何在 Reactive Spring Data 中使用来自其他对象的引用来获取对象？

Question

1. 我是 MongoDB 和 WebFlux 的新手。我正在尝试使用此“帖子” POJO 中的“CommentsIds”（列表 idComments）检索带有“评论”（列表 listComments）的“帖子”：

2. 那是我的 POJO/实体：

@Getter
@Setter
@NoArgsConstructor
@AllArgsConstructor
@Document(collection = "post")
public class Post implements Serializable {

    private static final long serialVersionUID = -6281811500337260230L;

    @EqualsAndHashCode.Include
    @Id
    private String id;
    private Date date;
    private String title;
    private String body;
    private AuthorDto author;
    private Comment comment;
    private List<Comment> listComments = new ArrayList<>();
    private List<String> idComments = new ArrayList<>();
}

3. 这是我的服务（findPostByIdShowComments + findCommentsByPostId）：

    public Mono<Post> findPostByIdShowComments(String id) {
        return postRepo
                .findById(id)
                .switchIfEmpty(postNotFoundException())
                .flatMap(postFound -> {

                    Flux<Comment> commentFlux = commentService
                            .findCommentsByPostId(postFound.getId());

                    Flux<Post> postFlux = commentFlux
                            .flatMap(comment -> {
                                postFound.setListComments(new ArrayList<>());
                                postFound.getListComments()
                                         .add(comment);
                                return Mono.just(postFound);
                            });

                    return Mono.just(postFound);
                });
    }


    public Flux<Comment> findCommentsByPostId(String id) {
        return postRepo
                .findById(id)
                .switchIfEmpty(postNotFoundException())
                .thenMany(commentRepo.findAll())
                .filter(comment1 -> comment1.getIdPost()
                                            .equals(id));

    }

4. 那是我的控制器：

    @GetMapping(FIND_POST_BY_ID_SHOW_COMMENTS)
    @ResponseStatus(OK)
    public Mono<Post> findPostByIdShowComments(@PathVariable String id) {
        return postService.findPostByIdShowComments(id);
    }

5. 结果，我无法获取我的“评论”并将它们加载到 POJO 中，因此，我无法在 Rest Response Json 中显示它们。作为“Json 结果”，我得到：

{
    "id": "5ff0ed93b3268a39dd3bd7b9",
    "date": "2011-11-11T00:00:00.000+00:00",
    "title": "Lake Cliffordside",
    "body": "North Sanfordborough",
    "author": {
        "id": "5ff0ed93b3268a39dd3bd7b6",
        "name": "melissa"
    },
    "comment": null,
    "listComments": [], //TROUBLE: As you can see, The CommentObjects are not coming
    "idComments": [
        "5ff0edb2b3268a39dd3bd7bc",
        "5ff0edbab3268a39dd3bd7bd"
    ]
}

非常感谢你们的帮助。

Answer 1

您没有收到评论的原因是您的commentFlux和postFlux变量只是被声明但从未在执行链中使用。

public Mono<Post> findPostByIdShowComments(String id) {
    return postRepo
            .findById(id)
            .switchIfEmpty(postNotFoundException())
            .flatMap(postFound -> commentService
                    .findCommentsByPostId(postFound.getId())
                    .collectList()
                    // it might be also a good option (and a cleaner operator here) instead of .flatMap(...)
                    //.doOnSuccess(comments -> postFound.setListComments(comments))
                    //.thenReturn(postFound)
                    .flatMap(comments -> {
                        postFound.setListComments(comments);
                        return Mono.just(postFound);
                    })
            );
}

现在我们将评论流及其注入作为主要流程的一部分注入到找到的帖子中。