Spring WebFlux：Handler类如何正确返回Flux响应？

问题描述 #

我想用Spring WebFlux实现CRUD，同时编写传统Controller和Handler-Route模式的代码。我知道Mono处理0/1个数据，Flux处理0到N个数据。需求是从数据库获取员工列表并以Flux形式返回。

传统Controller实现正常：

@RequestMapping(value = { "/findAll"}, method = RequestMethod.GET)
public Flux<Employee> findAll() {
    return employeeService.findAll();
}

但用Handlers和Routes实现时出现类型不匹配错误：

// Route
@Bean
public RouterFunction<ServerResponse> route3(EmploeeHandler emploeeHandler) {
    System.out.println("findAll2");
    return RouterFunctions.route(GET("/findAll2").and(accept(MediaType.APPLICATION_JSON)),
            emploeeHandler::findAll2);
}

// Handler
public Flux<ServerResponse> findAll2(ServerRequest request) {
    return ServerResponse.ok().contentType(MediaType.APPLICATION_JSON)
    .body(employeeService.findAll(), Employee.class);
            
}

错误信息：Type mismatch: cannot convert from Mono<ServerResponse> to Flux<ServerResponse>

改成返回Mono<ServerResponse>能解决问题，但我担心大量员工数据的场景，想保留Flux，请问哪里理解错了？

核心误解 #

你混淆了两个关键概念：

• 响应体的数据流类型：从数据库获取的员工列表是Flux<Employee>，这确实是用来处理大量数据的流式输出，不会一次性加载所有数据到内存。
• HTTP响应对象的类型：ServerResponse.ok().body(...)返回的是Mono<ServerResponse>，因为整个HTTP响应是一个单一的对象（包含状态码、响应头、响应体），不管响应体里是Flux还是Mono，整个响应只需要被发送一次，所以用Mono包裹。

正确实现 #

Handler的返回类型必须是Mono<ServerResponse>，这完全不影响响应体用Flux流式输出大量数据。修改后的Handler代码：

public Mono<ServerResponse> findAll2(ServerRequest request) {
    return ServerResponse.ok()
            .contentType(MediaType.APPLICATION_JSON)
            .body(employeeService.findAll(), Employee.class);
}

这里body()方法接收Flux<Employee>作为参数时，Spring WebFlux会自动以流式的方式把数据输出到响应体中，不会一次性加载所有员工数据，完全满足大量数据的场景需求。

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