Как вызвать WebClientResponseException при использовании exchange () с Spring WebClient - PullRequest
Новая
       37

Как вызвать WebClientResponseException при использовании exchange () с Spring WebClient

0 голосов
/ 30 апреля 2019

При использовании метода retrieve () Spring WebClient в сочетании с обработкой ошибок bodyToMono по умолчанию (если ответ имеет код состояния 4xx или 5xx, Mono будет содержать исключение WebClientException).В случаях ошибок результирующее исключение WebClientException очень полезно, поскольку оно содержит запрос И ответ, что очень удобно, например, для ведения журнала.Кроме того, я могу очень хорошо реагировать на ошибки. 

/*
 * Easy to use retrieve() with default error handling:
 * By default, if the response has status code 4xx or 5xx, the Mono will contain a WebClientException - AWESOME!
 */
public Optional<MyType> getMyType() {
    try {
        MyType result = client
                .get()
                .uri("/myType")
                .retrieve().bodyToMono(MyType.class).block();

        return Optional.ofNullable(result);
    } catch (NotFound e) {
        return Optional.empty();
    }
}

Однако иногда мне нужно знать точный код состояния ответа, чтобы реагировать на него при дальнейшей обработке этого ответа.Единственный метод, который также может получить код состояния, - это вызвать метод exchange () вместо метода retrieve ().К сожалению, в этом случае обработка ошибок по умолчанию не применяется.Кажется, причина этого заключается в том, что вызов bodyToMono () в ClientResponse имеет семантику, отличную от вызова его в ResponseSpec.

Я не могу вызвать уже реализованные методы из Spring, чтобы «инициировать» обработку ошибок, потому что все приятноеметоды закрыты как закрытые в WebClient.

Даже если бы я попытался «вручную» создать исключение WebClientResponseException, я не могу получить доступ к запросу на передачу в исключение. 

public String updateMyType() {
    ClientResponse response = client
            .put()
            .uri("/myType")
            .header(CONTENT_TYPE, APPLICATION_JSON_VALUE)
            .body(fromObject(new MyType()))
            .exchange()
            .block();

    if (response.statusCode().equals(HttpStatus.CREATED)) {
        return "OK";
    } else if (response.statusCode().equals(HttpStatus.NO_CONTENT)) {
        return "updated";
    } else {
        byte[] bodyBytes = null; // already implemented by Sping but not accessible
        Charset charset = null; // already implemented by Sping but not accessible
        HttpRequest request = null; // where should I get this from?
        throw WebClientResponseException.create(response.statusCode().value(),
                response.statusCode().getReasonPhrase(),
                response.headers().asHttpHeaders(),
                bodyBytes,
                charset,
                request);
    }
}

Что такоелучший способ «подражать» тому же поведению, что и для метода retrieve ()?

...