您可以根据RetrySignal中的条件（例如响应中的http头）创建自定义RetrySpec。
以下示例使用Retry-After标头定义自定义回退逻辑。

private static class DynamicRetrySpec extends Retry {
    private final int maxRetries;
    private final Duration defaultBackoff;

    public DynamicRetrySpec(int maxRetries, Duration defaultBackoff) {
        this.maxRetries = maxRetries;
        this.defaultBackoff = defaultBackoff;
    }

    @Override
    public Publisher<?> generateCompanion(Flux<RetrySignal> retrySignals) {
        return retrySignals.flatMap(this::getRetry);
    }

    private Mono<Long> getRetry(Retry.RetrySignal rs) {
        if (rs.failure() instanceof WebClientResponseException.TooManyRequests) {
            if (rs.totalRetries() < maxRetries) {
                Duration delay = getBackOffDelayFromHeaders((WebClientResponseException.TooManyRequests) rs.failure());

                log.info("retry {} with backoff {}sec", rs.totalRetries(), delay.toSeconds());
                return Mono.delay(delay)
                        .thenReturn(rs.totalRetries());
            } else {
                log.info("retries exhausted with error: {}", rs.failure().getMessage());
                throw Exceptions.propagate(rs.failure());
            }
        } else {
            throw Exceptions.propagate(rs.failure());
        }
    }

    private Duration getBackOffDelayFromHeaders(WebClientResponseException.TooManyRequests exceptionResponse) {
        String retryAfter = exceptionResponse.getHeaders().getFirst("Retry-After");
        if (retryAfter != null) {
            return Duration.ofSeconds(Integer.parseInt(retryAfter));
        }
        return defaultBackoff;
    }
}

然后将其用于WebClient

webClient.get()
    .uri("/api")
    .retrieve()
    .toBodilessEntity()
    .retryWhen(new DynamicRetrySpec(3, Duration.ofSeconds(1)));