如何在 Spring Boot 中收听流式传输 API？

Question

我正在 Spring Boot 中制作一个中间件。有一个 API，它有一个流式传输数据的端点。我必须收听该数据并在中间件中公开一个端点，该端点将流式数据从我的中间件传递到前端。所以，整个过程就是这样，前端会向我的中间件发出请求。我的中间件将打开到流 API 端点的持久连接以及任何数据 API returns，中间件会将其传递给前端。

我的主要问题是我无法弄清楚如何在我的 Spring 启动中间件中完美收听流式传输 API。我们会用什么？网络套接字？网络客户端？以及如何？

有人可以用基本的示例代码给出基本的想法吗？

Answer 1

我得到了答案。我们可以使用 WebClient & Flux 来获取流数据。

要开始直播：

  private final WebClient webClient = WebClient.create();

  public Flux<String> startStreaming() {
    return webClient.get()
            .uri("STREAMING API END POINT")
            .header("Authorization","Bearer "+Key.BearerToken)
            .retrieve()
            .bodyToFlux(String.class); ///String.class or any other custom model class can be used.
}

如何在 Spring Boot 中收听流式传输 API？

How to listen to a streaming API in Spring Boot?

spring

spring-boot

streaming