我正在玩 spring webflux。我创建了一个项目，该项目将侦听 mongo 上限集合并在数据出现时返回数据流。
我@Tailable在我的存储库方法中使用。

我的控制器看起来像这样

@GetMapping("/findall")
  public Flux<Product>> findAll() {
    return productRepository.findAllProducts().;
 }

这工作得很好。我通过 addind a 对此进行了测试doOnNext(...)，每当有新项目添加到我的上限集合中时，doOnNext 中的消费者就会被执行。

现在我希望它显示在浏览器上。我想使用 ReactJs（我对前端完全陌生）。

到目前为止，我找不到任何方法在浏览器中显示通量数据。我可以通过哪些选择来实现这一目标。

我试过这样的 SSE（服务器发送事件）

 componentDidMount() {
   this.eventSource = new EventSource('http://localhost:8080/findall');
   this.eventSource.addEventListener('product', (data) => {
            let json = JSON.parse(data.data)
            this.state.products.push(json.name)
            this.setState ( {
                products : this.state.products
            })
        });
 }

这工作得很好，但要让它工作，我必须像这样更改我的服务器端代码

 @GetMapping("/findall")
  public Flux<ServerSentEvent<Product>> findAll() {
    return productRepository.findAllProducts().map(data -> ServerSentEvent.<Product>builder().event("product").data(data).build());
  }

在我看来，这有点紧耦合，因为 UI 应该知道要收听的事件类型（“产品”）。

有没有其他方法可以处理来自 UI 端的事件流（尤其是reactjs）？