我正在使用 spring boot 2.x 并使用 webclient 進行兩個異步調用，我在一個調用中得到正確的響應，而另一個調用遇到一些異常。我想使用 zip 方法將兩個響應壓縮在一起，但是在使用帶 zip 的塊時，它會拋出異常和控制流以捕獲塊。我希望兩個響應都被壓縮，其中一個或兩個都存在異常。請指導我如何做到這一點。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 我想壓縮兩個響應以及異常。
1 回答
當年話下
TA貢獻1890條經驗 獲得超9個贊
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();
添加回答
舉報
0/150
提交
取消