Webclient重试和Onerrorsume互斥？

Question

我正在尝试针对特定例外进行重试，但是我无法使用以下内容使其起作用：

    return client
        .sendWebhook(request, url)
        .exchangeToMono(
            response -> {
              final HttpStatus status = response.statusCode();
              return response
                  .bodyToMono(String.class)
                  .defaultIfEmpty(StringUtils.EMPTY)
                  .map(
                      body -> {
                        if (status.is2xxSuccessful()) {
                          log.info("HTTP_SUCCESS[{}][{}] body[{}]", functionName, company, body);
                          return ResponseEntity.ok().body(body);
                        } else {
                          log.warn(
                              format(
                                  "HTTP_ERROR[%s][%s] status[%s] body[%s]",
                                  functionName, company, status, body));
                          return status.is4xxClientError()
                              ? ResponseEntity.badRequest().body(body)
                              : ResponseEntity.internalServerError().body(body);
                        }
                      });
            })
        .retryWhen(
            Retry.backoff(1, Duration.ofSeconds(1))
                .filter(
                    err -> {
                      if (err instanceof PrematureCloseException) {
                        log.warn("PrematureCloseException detected retrying.");
                        return true;
                      }
                      return false;
                    }))
        .onErrorResume(
            ex -> {
              log.warn(
                  format(
                      "HTTP_ERROR[%s][%s] errorInternal[%s]",
                      functionName, company, ex.getMessage()));
              return Mono.just(ResponseEntity.internalServerError().body(ex.getMessage()));
            });

似乎重试永远不会被提交过早的closeexception。

Answer 1

解决了，由于rootcause而无法工作

Retry.backoff(3, Duration.ofMillis(500))
        .filter(
            ex -> {
              if (ExceptionUtils.getRootCause(ex) instanceof PrematureCloseException) {
                log.info(
                    "HTTP_RETRY[{}][{}] PrematureClose detected retrying", functionName, company);
                return true;
              }
              return false;
            });