Java Spring Webflux - WebClient .onStatus((HttpStatus::isError) 到 return 用于错误处理

Question

小 Java Spring WebClient 请。

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

因此，我正在客户端构建代码来处理错误。我的目标很简单，当服务器响应正确时，一个 200，那很好，但是任何其他任何错误，不管错误是什么，我想 return 默认值。因此，我去试试这个：

 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)，我可以return，不管服务器错误是什么，一个默认值.

不幸的是，这需要某种可抛出的单声道。请问如何实现？

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

我有点迷茫，只想 return（不只是打印）默认消息。

谢谢

Answer 1

您可以像这样简单地使用 onErrorReturn 运算符：

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

Java Spring Webflux - WebClient .onStatus((HttpStatus::isError) 到 return 用于错误处理

Java Spring Webflux - WebClient .onStatus((HttpStatus::isError) to return for error handling

java

spring-webclient