交换

ChatGPT-4o 中英对照 Exchange

exchangeToMono() 和 exchangeToFlux() 方法（或者在 Kotlin 中的 awaitExchange { } 和 exchangeToFlow { }）在需要更多控制的高级用例中非常有用，例如根据响应状态以不同方式解码响应：

Java

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();
            }
        });

java

Kotlin

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()
        }
  }

kotlin

使用上述方法时，在返回的 Mono 或 Flux 完成后，会检查响应体，如果未被消费则会释放，以防止内存和连接泄漏。因此，响应不能在下游进一步解码。如果需要解码响应，则由提供的函数声明如何解码。