我想使用spring webflux中的WebClient
执行以下操作:
致电endpoint1
如果失败并出现预期错误,则
呼叫endpoint2
并
仅重试一次endpoint1
我已经做到了:
webclient.get()
.uri("/endpoint1")
.retrieve()
.bodyToFlux(MyBody.class)
.retry(error -> {
if (error == expectedError) {
webclient.get()
.uri("/endpoint2")
.retrieve().block();
return true;
} else {
false;
});
请求
endpoint2
时无法阻止,因为会出现以下错误:block()/blockFirst()/blockLast() are blocking, which is not supported in thread
(我也不想阻止)。也许我应该使用
retryWhen
,但我不确定如何使用它。 最佳答案
我进行此工作的唯一方法是使用retryWhen
,因为它仅接受reactor.retry.Retry#doOnRetry
而不是Consumer
或Mono
或Flux
,所以我不能使用Publisher
。
摘录如下:
webclient.get()
.uri("/endpoint1")
.retrieve()
.bodyToFlux(MyBody.class)
.retryWhen(errorCurrentAttempt -> errorCurrentAttempt
.flatMap(currentError -> Mono.subscriberContext().map(ctx -> Tuples.of(currentError, ctx)))
.flatMap(tp -> {
Context ctx = tp.getT2();
Throwable error = tp.getT1();
int maxAttempts = 3;
Integer rl = ctx.getOrDefault("retriesLeft", maxAttempts);
if (rl != null && rl > 0 && error == myExpectedError) {
// Call endpoint and retry
return webclient.get()
.uri("/endpoint2")
.retrieve()
.thenReturn(ctx.put("retriesLeft", rl - 1));
} else {
// Finish retries
return Mono.<Object>error(error);
}
}));