我正在使用 spring boot 2.x 并使用 webclient 進(jìn)行兩個(gè)異步調(diào)用，我在一個(gè)調(diào)用中得到正確的響應(yīng)，而另一個(gè)調(diào)用遇到一些異常。我想使用 zip 方法將兩個(gè)響應(yīng)壓縮在一起，但是在使用帶 zip 的塊時(shí)，它會拋出異常和控制流以捕獲塊。我希望兩個(gè)響應(yīng)都被壓縮，其中一個(gè)或兩個(gè)都存在異常。請指導(dǎo)我如何做到這一點(diǎn)。Mono<BookResponse> bookResponseMono =webClient.get() .uri("/getBooking/" + bookingId).headers(headers->headers.addAll(args) .retrieve() .bodyToMono(BookResponse.class);// with proper responceMono<Address> addressResponseMono =webClient.get() .uri("/getAddress/" + bookingId) .headers(headers->headers.addAll(args)) .retrieve() .bodyToMono(Address.class);// encounter readtimeout exceptionTuple2<BookResponse, Address> resp = bookResponseMono.zipWith(addressResponseMono).block();// throws exception but 我想壓縮兩個(gè)響應(yīng)以及異常。
1 回答
當(dāng)年話下
TA貢獻(xiàn)1890條經(jīng)驗(yàn) 獲得超9個(gè)贊
onErrorResume為我解決上述問題。
bookResponseMono = webClient.get()
.uri("/getBooking/" + bookingId)
.headers(headers->headers.addAll(args))
.retrieve()
.bodyToMono(String.class)
.onErrorResume(err -> {
BookResponse bookResponse = new BookResponse();
bookResponse.setError(setError(err));
return Mono.just(setError(err));
});
addressResponseMono = webClient.get()
.uri("/getAddress/" + bookingId)
.headers(headers -> headers.addAll(args))
.retrieve()
.bodyToMono(String.class)
.onErrorResume(err -> {
Address address = new Address();
address.setError(setError(err));
return Mono.just(setError(err));
});
最后拉上拉鏈
bookAndAddressResponse = bookResponseMono
.zipWith(addressResponseMono, BookAndAddressResponse::new)
.block();
添加回答
舉報(bào)
0/150
提交
取消