提问者:小点点

JavaSpring WebFlusion-WebClient. onStatus((HttpStatus::isError)返回以进行错误处理


请JavaSpring WebClient。

我是客户端应用程序,调用服务器。我不是服务器,我也不控制服务器端的任何东西。众所周知,服务器非常不稳定,我在服务器端无能为力。

因此,我在客户端构建了一个代码来处理错误。我的目标很简单,当服务器用正确的东西响应时,200,那很好,但是其他任何东西,任何错误,不管是什么错误,我都想返回一个默认值。因此,我去尝试了一下:

 public static String sendPayloadToFlakyServerWithDefaultIfError() {
        final WebClient           webClient                 = WebClient.create().mutate().defaultHeader(HttpHeaders.CONTENT_TYPE, MediaType.APPLICATION_JSON_VALUE, HttpHeaders.ACCEPT, MediaType.APPLICATION_JSON_VALUE).clientConnector(new ReactorClientHttpConnector(HttpClient.create().wiretap(true).protocol(HttpProtocol.H2))).build();
        final Map<String, String> payload                   = Map.of("somekeyone", "somevalueone", "somekeytwo", "somevaluetwo");
        final String response = webClient.post().uri("https://the-very-flaky-server/api/someendpoint").body(BodyInserters.fromValue(payload)).retrieve()
                .onStatus((HttpStatus::isError),
                        (it -> {
                            System.out.println("there is an error with the flaky server indeed...  " + it.statusCode().getReasonPhrase());
                            return ??? //return "something bad happened on the flaky server side";
                        })
                )
                .bodyToMono(String.class).block();
        System.out.println("the response from flaky server is " + response);
        return response;
    }

我希望,与. onStatus((HttpStatus::isError),我可以只是返回,无论什么是服务器错误,一个默认值。

不幸的是,这需要某种Mono of Throwable。请问如何实现这一点?

也许onState((HttpStatus::isError)不是解决这个问题的正确方法?

我有点迷路了,只想返回(而不仅仅是打印)默认消息。

谢谢你们


共1个答案

匿名用户

您可以简单地使用onErrorBack运算符,如下所示:

final String response = webClient.post()
        .uri("https://...")
        .body(BodyInserters.fromValue(payload))
        .retrieve()
        .bodyToMono(String.class)
        .onErrorReturn(e -> "default");
        .block();