Spring响应式端点返回多对象时，哪种响应类型更合适？

先看你给出的两个响应式端点代码：

单个对象返回示例：

@GetMapping(value = "/to-do/{toDoId}", produces = {
            MediaType.APPLICATION_JSON_VALUE, MediaType.APPLICATION_XML_VALUE, MediaType.TEXT_XML_VALUE})
    public Mono<ResponseEntity<ToDo>> getToDo(@Valid @PathVariable Long toDoId) {
        return repository.findById(toDoId)
                .map(ResponseEntity::ok);
    }

多个对象返回的实验方案：

@GetMapping(value = "/to-do", produces = {
            MediaType.APPLICATION_JSON_VALUE, MediaType.APPLICATION_XML_VALUE, MediaType.TEXT_XML_VALUE})
    public ResponseEntity<Flux<ToDo>> getToDos() {
        return ResponseEntity.ok().body(
                repository.findAll()
        );
    }

疑问解答 #

1. ResponseEntity<Flux>格式的响应是否会阻塞？

不会阻塞。Spring WebFlux会自动处理Flux的订阅与流式传输逻辑：它会先返回HTTP 200的响应头，再把Flux中的元素逐个流式输出到响应体中。repository.findAll()返回的Flux是冷发布者，只有当Spring内部完成订阅后才会触发数据查询，全程不会阻塞线程。

2. 是否更适合返回Flux<ResponseEntity>？

不适合。Flux<ResponseEntity<ToDo>>意味着每个ToDo对象都会对应一个独立的HTTP响应，这不符合RESTful接口批量返回资源的常规设计——通常我们期望一个请求返回一个包含所有资源的完整响应体。这种返回方式会导致客户端收到多个HTTP响应，仅适用于服务器推送事件（SSE）这类特殊场景，普通批量查询接口完全没必要这么做。

3. 若要返回Flux<ResponseEntity>，如何实现？是否需要调用subscribe？

如果确实有特殊场景需要这么做，直接将repository.findAll()的每个元素包装成ResponseEntity即可，不需要手动调用subscribe()——Spring WebFlux会自动处理订阅逻辑：

@GetMapping(value = "/to-do/stream", produces = MediaType.TEXT_EVENT_STREAM_VALUE)
public Flux<ResponseEntity<ToDo>> streamToDos() {
    return repository.findAll()
            .map(ResponseEntity::ok);
}

注意要指定produces = MediaType.TEXT_EVENT_STREAM_VALUE，因为这种返回方式对应SSE场景，需要客户端以流式方式接收多个响应。但普通批量查询场景下，直接返回Flux<ToDo>会更简洁，Spring WebFlux会自动将其包装成HTTP 200响应并流式输出：

@GetMapping(value = "/to-do", produces = {
            MediaType.APPLICATION_JSON_VALUE, MediaType.APPLICATION_XML_VALUE, MediaType.TEXT_XML_VALUE})
public Flux<ToDo> getToDos() {
    return repository.findAll();
}

内容的提问来源于stack exchange，提问作者Sam Fisher