我在Spring中制作了一个中间件。有一个API,它有一个流数据的端点。我必须侦听这些数据&在中间件中公开一个端点,该端点将流数据从中间件传递到前端。所以,整个过程都是这样的,当前端向我的中间件发出请求时。我的中间件将打开到流API端点的持久连接&无论数据API返回什么,中间件都会将它传递给前端。
我的主要问题是,我无法理解如何在Spring中间件中完美地侦听流API。我们要用什么?WebSocket?WebClient?&怎么做?
有人能用基本的示例代码给出一个基本的想法吗?
发布于 2020-09-27 10:36:46
我知道答案了。我们可以使用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.
}https://stackoverflow.com/questions/64084922
复制相似问题