交换

`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` 完成后，会检查响应体，如果未被消费，则会释放以防止内存和连接泄漏。因此，响应无法在下游进一步解码。需要由提供的函数声明如何解码响应。