如何制作Mono/Flux链并在sping-webflux中实现Retry

Question

我有一个反应/异步调用的场景。我使用spring-boot-starter-webflux和webclient进行外部HTTP调用。我的场景是，我必须调用callA((，然后检查其响应ResponseA。如果其ResponseA正常，则退出并返回ResponseA。否则，使用ResponseA创建第二个请求requestB，并调用callB((。然后检查其响应ResponseB。如果可以，则返回ResponseA，否则在callA((上执行重试。

public Mono<ResponseA> callA(Request1 requestA) {
// calling service-A using webclient
}
public Flux<ResponseB> callB(Request2 requestB) { 
// calling service-B using webclient but to create requestB, I need ResponseA.
}

Answer 1

您只需要在flatMap中执行一些if语句。可能会把它分成一些更好的函数名等等。没有订阅，就没有阻塞。

callA(createNewRequest()).flatMap(response1 -> {
// Validate response
if(!isValidResponse(response)) {
// if failed validation, create new request and do a new call
var request = buildRequest(response);
return callB(request).flatMap(response2 -> {
// validate second response
if(!isValidResponse(response2)) {
// failed validation return the first response.
return Mono.just(response1)
}
// otherwise recursively call again
return callA(createNewRequest()); // Warning this can be an infinite loop
}
}
// Validation passed
return Mono.just(response);
}