Java:从 Play Framework 应用程序使用 Spring WebFlux 应用程序

Question

我对通过 HTTP 从 Play Framework 应用程序使用 Spring WebFlux 应用程序有一些疑问，您能提供一些帮助吗？

微服务A是一个响应式的Spring WebFlux，用Java 8，SpringBoot 2.1.4编写，暴露了这个API:

@Autowired private ReactiveCustomerRepository customerRepository;

@GetMapping("/customers")
public Flux<Customer> getAllCustomers() {
    Flux<Customer> c = customerRepository.findAll().delayElements(Duration.ofMillis(5000));
    return c;
}

我想通过 HTTP 从 Play Framework 微服务 B 以 react 方式使用它。

能否就如何实现这一点提供一些建议或一小段代码？

感谢您的帮助。

Answer 1

您可以尝试使用支持流式传输的不同内容类型 - application/stream+json。 Spring WebFlux 将序列化各个 Flux 元素并通过网络将它们一一发送。查看以下有关它的 SO 线程:Spring WebFlux Flux behavior with non streaming application/json

在 play-ws 端，您应该能够接收此数据作为 Source[T]。