kotlin - 在 WebClient onErrorResume 中反序列化没有对象映射器的错误响应

Question

我想知道是否有更好的方法在调用 onErrorResume 时不涉及使用额外的 ObjectMapper 来在 WebClient 中获取错误响应？

在我的网络客户端中:

import org.springframework.web.reactive.function.client.WebClientResponseException.BadRequest

// ...

.onErrorResume(BadRequest::class.java, badRequestToMyDto())

    private fun badRequestToMyDto(): (BadRequest) -> Mono<out MyDto> =
        { it: BadRequest ->
            val error = objectMapper.readValue<ErrorResponseDto>(it.responseBodyAsByteArray)
            // ...
}

有一个方法 .bodyToMono 所以我想知道是否有类似的东西可以用在 onErrorResume 中。

Answer 1

您可以将 retrieve() 与 onStatus 结合使用，以便在出现“错误”时访问客户端响应。然后，您可以对其调用 bodyToMono 以解码对 java 对象的响应。根据响应主体的内容类型，spring 将使用正确的解码器。例如，如果正文是 json，它将使用 ObjectMapper 进行解码。

WebClient.builder().build()
                .get()
                .uri("localhost:8080")
                .retrieve()
                .onStatus(HttpStatus::isError, clientResponse ->
                        clientResponse.bodyToMono(MyErrorResponse.class)
                                .flatMap(body -> {
                                    // logic
                                })
                )