SpringBootWebFlux-flatMap是链接http调用的正确方法吗？

Question

关于SpringWebFlux的小问题，以及如何“链接”http调用。

通过一个具体的例子，这里是一个非常简单的SpringMVC示例，带有一个rest模板。

RestTemplate restTemplate = new RestTemplate();

        HttpEntity<StepOneRequest> stepOneRequestHttpEntity = new HttpEntity<>(new StepOneRequest("foo", "bar"));
        StepOneResponse stepOneResponse = restTemplate.postForObject("https://step-one-web-service:443/getStepTwoFromFooBar", stepOneRequestHttpEntity, StepOneResponse.class);

        HttpEntity<StepTwoRequest> stepTwoRequestHttpEntity = new HttpEntity<>(new StepTwoRequest(stepOneResponse.getTheDependencyFromStepOne()));
        StepTwoResponse stepTwoResponse = restTemplate.postForObject("https://step-two-web-service:443/getResponseFromStepTwo", stepTwoRequestHttpEntity, StepTwoResponse);

        return ResponseEntity.ok(new MyResponse(stepTwoResponse.getImportantValueFromStepTwo()));
    }

在这个片段中，我们看到了非常简单的内容。仅初始化一个rest模板。

超文本传输协议请求有效载荷对象的构造。

使用所构建的对象来查询第一外部web应用API以获得响应。

重要的是，需要第一个HTTP调用的响应来进行第二个HTTP调用。它们只能是顺序的，它需要第一次调用的结果，才能查询第二个API。

然后，http调用第二个API。

最后，根据第二个API向原始请求者发送响应。

现在，如果将其转换为Webflux：

WebClient webClientStepOne = WebClient.create("https://step-one-web-service:443/getStepTwoFromFooBar");
        WebClient webClientStepTwo = WebClient.create("https://step-two-web-service:443/getResponseFromStepTwo");

        Mono<StepOneResponse> stepOneResponseMono = webClientStepOne.post().body(BodyInserters.fromValue(new StepOneRequest("foo", "bar"))).retrieve().bodyToMono(StepOneResponse.class);

        Mono<StepTwoResponse> stepTwoResponseMono = stepOneResponseMono.flatMap(aStepOneResponse -> webClientStepTwo.post().body(BodyInserters.fromValue(aStepOneResponse.getTheDependencyFromStepOne())).retrieve().bodyToMono(StepTwoResponse.class));

        return stepTwoResponseMono.map(aStepTwoResponse -> ResponseEntity.ok(new MyResponse(aStepTwoResponse.getImportantValueFromStepTwo())));
    }

我有一个大问题。虽然这是正确的（它会产生相同的响应），但这是正确的做法吗？

特别是平面图的线条

Mono<StepTwoResponse> stepTwoResponseMono = stepOneResponseMono.flatMap(aStepOneResponse -> webClientStepTwo.post().body(BodyInserters.fromValue(aStepOneResponse.getTheDependencyFromStepOne())).retrieve().bodyToMono(StepTwoResponse.class));

这似乎很不寻常。这里还有更好的办法吗？

另外，还有一个附带问题，如果我需要链接N个api调用，我们真的需要N个WebClient吗？URL是不同的，不仅仅是路径，还有完整的URL。当rest模板只能使用一个实例时，似乎在这里，如果我需要调用N个外部服务，我需要N个WebClient。

请问这里使用WebClient的正确方法是什么？请问，链接http调用的正确方法是什么？

非常感谢。

Answer 1

我有一个大问题。虽然这是正确的（它会产生相同的响应），但这是正确的做法吗？

基本上，是的，你做得对。唯一不正确的是您的Webclient使用情况和您的风格。

您当然不必为每个URI指定WebClient（您也不应该这样做，因为它们是可重用的）因此，如果您有不同的域和相同的webclient，只需创建一个标准实例：

WebClient wc = WebClient.create();

...然后使用：

webClientStepOne.post()
                .uri("https://blah")

...在链的顶部，为同一实例指定不同的URI。

就风格而言——您会注意到，当代码被拆分为单独的变量并写在长行上时，代码会很快变得笨拙。尽管最初看起来似乎有悖常理，但在反应式领域中普遍接受的最佳实践是在一条语句中完成所有工作，将每个新方法调用的格式设置在单独的行中（使您能够向下阅读，然后查看反应链的执行情况）因此，在您的情况下，它将成为：

return wc.post().uri("https://step-one-web-service:443/getStepTwoFromFooBar")
        .body(BodyInserters.fromValue(new StepOneRequest("foo", "bar")))
        .retrieve()
        .bodyToMono(StepOneResponse.class)
        .flatMap(aStepOneResponse ->
                wc.post().uri("https://step-two-web-service:443/getResponseFromStepTwo")
                        .body(BodyInserters.fromValue(aStepOneResponse.getTheDependencyFromStepOne()))
                        .retrieve()
                        .bodyToMono(StepTwoResponse.class)
        )
        .map(aStepTwoResponse ->
                ResponseEntity.ok(new MyResponse(aStepTwoResponse.getImportantValueFromStepTwo()))
        );

您可以稍微整理一下，例如，通过将内部flatmap调用委托给一个单独的方法，但这实际上取决于首选项。