spring-webflux - Webflux 响应式(Reactive) API 的 Spring Cloud Contract

Question

我正在尝试将 Spring Cloud Contract 应用于使用 Spring Webflux 构建的响应式(Reactive) API。基本上能够发送一个 Flux 并从一个 API 接收一个响应 Flux 的样式:

@RequestMapping("/endlessecho")
public Flux<String> endlessEcho(Flux<String> input) {
    return input;
}

但是，我无法在网上或文档中找到关于我是否可以使用 Spring Cloud Contract 执行此操作的信息。

甚至有可能为此写一份契约(Contract)吗？它能够提供线模并生成适当的 JUnit 测试吗？

Answer 1

通过这个提交 (https://github.com/spring-cloud-samples/spring-cloud-contract-samples/commit/f7030148a9337d4c7184f7c8e27c271d9b89681b)，我在 Spring Cloud COnttract Samples 中添加了一个 WebFlux 示例。

像往常一样定义合约就足够了，通过 EXPLICIT testMode 的模式插件设置中的参数。而不是 RestASsuredMockMvc您必须使用标准 RestAssured静态 URI设置使用 WebFlux 的应用程序的 URI 字段.您需要设置整个 Spring 上下文并绑定(bind)到一个端口，仅此而已。

在名为 consumer 的项目中有一个使用 producer-webflux 中的 stub 的测试项目。从 Stub Runner 的角度来看，stub 的启动方式没有变化。