我想使用WebClientfrom spring webflux 執行以下操作：稱呼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，但我不確定如何使用它。
1 回答
慕尼黑5688855
TA貢獻1848條經驗 獲得超2個贊
我完成這項工作的唯一方法是retryWhen我無法使用reactor.retry.Retry#doOnRetry，因為它只接受 aConsumer而不是 a Monoor Fluxor 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);
}
}));
添加回答
舉報
0/150
提交
取消