项目反应器条件流的最佳实践

Question

我正在使用spring webflux和project reactor构建一个有2层的API：控制器和服务。我的API所有的3个endpoint都发送并返回一个用Mono包装的请求/响应。在服务层中，我有两个类：第一个类调用几个带有单响应的webclients，第二个类是这些调用的类集成。我一直在努力构建单端调用的“管道”，因为业务流要求我需要调用WebClient1，执行一些验证，使用它的响应并调用WebClient2，执行验证调用WebClient3，如果在WebClient4中通过其他调用，则调用WebClient3，等等...我已经尝试过flatmap了，但对我来说，用这样的Mono创建条件流是不自然的：

业务流程图

正如您在图表中所看到的，对于我来说，实现反应式web客户机调用的条件流并不是一个简单的方法。有一个最佳实践来做这个whitout调用一个嵌套调用的flatmaps，和地图，并与良好的可读性我的代码？

Answer 1

您可以将条件语句放置到FlatMap并使用switchIfEmpty返回其他Publisher。一个简短的例子：

myService.executeWc1() // returns Mono
        .flatMap(result -> myService.executeWc2(result))
        .flatMap(result -> validator.validate(result))
        .handle((result, sink) -> {
            if (result) { // validation is passed
                sink.success(true);
            }
            sink.success();
        })
        .flatMap(result -> myService.doSomeWork()
                .flatMap(r -> myService.executeWc3())
                .flatMap(r -> myService.doSomeWorkAgain())
                .flatMap(r -> myService.executeWc4()))
        .switchIfEmpty(myService.executeWc4())

诸如此类...