捕获身份验证异常

Question

我使用以下代码发送XML请求：

RestClient client = RestClientBuilder.builder()
                        .gatewayUrl(URL) 
                        .build();
Mono<AuthorizeResponse> result = client.executeAndReceiveAuthorize(request);
                response = result.block();

 public RestClient(String gatewayUrl, String token, String username, String password, SslContext sslContext) {
        this.token = token;
        this.gatewayUrl = gatewayUrl;
        WebClient.Builder builder = WebClient.builder().baseUrl(gatewayUrl);
        if (sslContext != null) {
            HttpClient httpClient = HttpClient.create().secure(sslContextSpec -> sslContextSpec.sslContext(sslContext));
            ClientHttpConnector httpConnector = new ReactorClientHttpConnector(httpClient);
            builder.clientConnector(httpConnector);
        }
        if (username != null && password != null) {
            builder.filter(basicAuthentication(username, password));
        }
        client = builder.build();
    }

    public Mono<AuthorizeResponse> executeAndReceiveAuthorize(AuthorizeRequest transaction) {
        Mono<AuthorizeRequest> transactionMono = Mono.just(transaction);
        return client.post().uri(checkTrailingSlash(gatewayUrl) + token)
                .header(HttpHeaders.USER_AGENT, "Mozilla/5.0")
                .accept(MediaType.APPLICATION_XML)
                .contentType(MediaType.APPLICATION_XML)
                .body(transactionMono, AuthorizeRequest.class)
                .retrieve()
                .bodyToMono(AuthorizeResponse.class);
    }

但有时我会犯这个错误：

org.springframework.web.reactive.function.client.WebClientResponseException$Unauthorized: 401 Unauthorized
 at java.base/java.lang.Thread.run(Thread.java:834)
2019-08-27 22:05:45,720 ERROR [stderr] (processingTransactionGenesisAuthorizeContainer-1)       Suppressed: java.lang.Exception: #block terminated with an error
 Caused by: java.lang.NullPointerException: null

当我得到错误401时，我如何捕捉和处理异常？如果可能的话，我希望处理response=result.block()；行之后的异常。

Answer 1

首先，在反应代码中显式使用block不是一个好主意。这背后的原因是，它将代码变成阻塞，而这并不是反应流的工作方式。因此，请删除response=result.block()；

现在，如果希望处理特定状态，则可以修改ExecuteAndReceiveAuthorize方法，以使用WebClient的onStatus（谓词 var1，函数 >var2)

public Mono<AuthorizeResponse> executeAndReceiveAuthorize (AuthorizeRequest transaction){

    Mono<AuthorizeRequest> transactionMono = Mono.just(transaction);

    return client.post().uri(checkTrailingSlash(gatewayUrl) + token)
        .header(HttpHeaders.USER_AGENT, "Mozilla/5.0").accept(MediaType.APPLICATION_XML)
        .contentType(MediaType.APPLICATION_XML).body(transactionMono, AuthorizeRequest.class)
        .retrieve().onStatus(status -> status == HttpStatus.UNAUTHORIZED, clientResponse -> Mono
            .error(new SomeCustomAuthorizationException("Some failure exception")))
        .bodyToMono(AuthorizeResponse.class);
}