我創(chuàng)建了一個(gè) Spring webflux webclient。我想根據(jù)我的響應(yīng)重復(fù)相同的操作。例如：如果數(shù)據(jù)仍然為空，我想重試獲取數(shù)據(jù)。怎么做 ？Flux<Data> data = webClient.get() .uri("/api/users?page=" + page) .retrieve() .flatMap(o -> { o.subscribe(data -> { if(data == null) { // WHAT TO DO HERE, TO REPEAT THE SAME CALL ? o.retry(); } }); return o; }) .bodyToFlux(Data.class);
1 回答
慕森王
TA貢獻(xiàn)1777條經(jīng)驗(yàn) 獲得超3個(gè)贊
您可以使用retry(Predicate<? super Throwable> retryMatcher)，它將根據(jù)可拋出條件重試該操作。
在下面的代碼中，如果從客戶端接收到的數(shù)據(jù)為空，我將返回 Mono.error，然后根據(jù)重試中的錯(cuò)誤條件再次執(zhí)行上述操作。
您還可以限制重試次數(shù)，
retry(long numRetries, Predicate<? super Throwable> retryMatcher)
final Flux<Data> flux = WebClient.create().get().uri("uri").exchange().flatMap(data -> {
if (data == null)
return Mono.error(new RuntimeException());
return Mono.just(data);
}).retry(throwable -> throwable instanceof RuntimeException)
.flatMap(response -> response.bodyToMono(Data.class)).flux();
添加回答
舉報(bào)
0/150
提交
取消