使用不同的URL重试Webflux Webclient

Question

我正在使用webclient进行rest调用，我需要的是，如果主URL第n次失败，那么在次URL上进行下一次重试。请在下面找到我正在使用的逻辑的示例代码。但是似乎我们不能在client创建后更改URL，即使我更改了URL，它也不会生效，仍然会将请求激发到初始URL。

ClientHttpConnector connector;//initiate
WebClient webClient = WebClient.builder().clientConnector(connector).build();
WebClient.RequestBodyUriSpec client = webClient.post();

client.uri("http://primaryUrl/").body(BodyInserters.fromObject("hi")).retrieve().bodyToMono(String.class).retryWhen(Retry.anyOf(Exception.class)
                    .exponentialBackoff(Duration.ofSeconds(2), Duration.ofSeconds(10)).doOnRetry(x ->
                    {
                        if (x.iteration() == 2) {
                            client.uri("http://fail_over_url/");//this does not work
                        }
                    })
                    .retryMax(2)).subscribe(WebClientTest::logCompletion, WebClientTest::handleError);

有没有办法在重试周期中间更改URL？

Answer 1

但似乎我们不能更改URL一旦他的客户机被创建

你不能-它是不变的。

即使我更改了URL也不会生效

实际上并没有更改URL。看看URI()方法-它返回一个带有URI集的新实例。由于您没有对这个新实例执行任何操作，因此没有发生任何事情（正如所预期的那样）

我可能建议的路径是创建一个单独的方法来形成并返回基本的WebClient发布服务器：

private Mono<String> fromUrl(String url) {
    return WebClient.builder().clientConnector(connector).build()
            .post()
            .body(BodyInserters.fromValue("hi"))
            .uri(url)
            .retrieve()
            .bodyToMono(String.class);
}

...然后执行以下操作：

fromUrl("https://httpstat.us/400").retryWhen(Retry.backoff(2, Duration.ofSeconds(1)))
        .onErrorResume(t -> Exceptions.isRetryExhausted(t), t -> fromUrl("https://httpstat.us/500").retryWhen(Retry.backoff(5, Duration.ofSeconds(1))))
        .onErrorResume(t -> Exceptions.isRetryExhausted(t), t -> fromUrl("https://httpstat.us/200").retryWhen(Retry.backoff(7, Duration.ofSeconds(1))))

...它将尝试/4003次，然后尝试/5005次，然后再尝试/200最多7次（但除非它已关闭，否则第一次尝试时当然会返回。）

请注意，上面的示例使用了最新版本的reactor-core，它内置了重试功能，而不是reactor Addons中的重试功能。将其转换为反应堆附加功能应该相当简单。

这并不是严格地在相同的重试周期中更改URL，而是将请求与每个请求的可配置重试链接在一起。这样，您就可以在不同的URL上设置不同的重试策略，如果您不一定希望重试从上一个点“继续”，这是有利的（例如，对于一个新的URL将回退设置为一秒是有意义的）