|
对于最新稳定版本，请使用 Spring Framework 7.0.6！ |
交换
exchangeToMono() 和 exchangeToFlux() 方法（在 Kotlin 中为 awaitExchange { } 和 exchangeToFlow { }）
适用于需要更多控制的高级场景，例如根据响应状态以不同方式解码响应：
-
Java
-
Kotlin
Mono<Person> entityMono = client.get()
.uri("/persons/1")
.accept(MediaType.APPLICATION_JSON)
.exchangeToMono(response -> {
if (response.statusCode().equals(HttpStatus.OK)) {
return response.bodyToMono(Person.class);
}
else {
// Turn to error
return response.createError();
}
});val entity = client.get()
.uri("/persons/1")
.accept(MediaType.APPLICATION_JSON)
.awaitExchange {
if (response.statusCode() == HttpStatus.OK) {
return response.awaitBody<Person>()
}
else {
throw response.createExceptionAndAwait()
}
}使用上述方式时，在返回的 Mono 或 Flux 完成后，会检查响应体；如果未被消费，则会释放它，以防止内存和连接泄漏。
因此，该响应无法在下游进一步解码。如有需要，应由所提供的函数负责声明如何解码响应。