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

Question

我有一个无功/异步调用的场景。我正在使用sping-boot-starter-webflow并使用webClient进行外部HTTP调用。我的场景是，我必须打电话给call A（），然后检查它的响应响应。如果它的响应是确定比退出并返回响应。否则，创建第二个请求请求B使用响应A和打一个调用到calB（）。然后检查其响应响应。如果它是确定的，然后返回响应，否则doRetry on call A（）。

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

您只需要在平面图中执行一些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);
}