所以现在，我返回的响应看起来像
@GetMapping("/integers")
@ResponseStatus(code = HttpStatus.OK)
public Mono<Map<String, Flux<Integer>>> getIntegers() {
Mono<Map<String, Flux<Integer>>> integers =
Mono.just(Map.of("Integers", integerService.getIntegers()));
return integers;
}
这给了我一个回应
{"Integers":{"scanAvailable":true,"prefetch":-1}}
我希望它也可以流式传输该Flux<Integer>部分，但事实并非如此。我将如何在Spring webflux中做到这一点？
Spring WebFlux只能处理一种反应类型，而不能处理嵌套的反应类型（如Mono<Flux<Integer>>）。您的控制器方法可以返回a Mono<Something>，a Flux<Something>，a ResponseEntity<Mono<Something>>，aMono<ResponseEntity<Something>>等等-但永远不会嵌套反应类型。
您在响应中看到的奇怪数据是杰克逊实际上试图序列化反应式类型（因此，您正在查看数据的承诺，而不是数据本身）。
在这种情况下，您可以这样重写方法：
@GetMapping("/integers")
@ResponseStatus(code = HttpStatus.OK)
public Mono<Map<String, Flux<Integer>>> getIntegers() {
Flux<Integer> integers = integerService.getIntegers();
Mono<Map<String, List<Integer>>> result = integers
// this will buffer and collect all integers in a Mono<List<Integer>>
.collectList()
// we can then map that and wrap it into a Map
.map(list -> Collections.singletonMap("Integers", list));
return result;
}
您可以在Spring WebFlux参考文档中阅读有关受支持的返回值的更多信息。
本文收集自互联网，转载请注明来源。
如有侵权，请联系 [email protected] 删除。
我来说两句