不是流TEXT_EVENT_STREAM_VALUE

Question

我对反应式编程和spring webflux还不熟悉，我想试试MediaType。TEXT\u EVENT\u STREAM\u VALUE，因此我有以下代码：

@GetMapping(value = "/stream", produces = MediaType.TEXT_EVENT_STREAM_VALUE)
public Flux<Menu> streamAllAvailableMenu() {
    return menuService.findAll();
}

我对结果的期望是，我在浏览器中调用这个API（使用浏览器的原因不是所有客户端都支持实时流），当我在mongob中更改我的数据时，它应该会立即在我的浏览器中反映更改，就像使用web套接字技术的实时流，但实际上它并没有改变任何东西。

我是不是误解了这个分流机制，还是我遗漏了什么？

我正在使用完全反应式堆栈：

Spring webflux 
Netty
Spring Data MongoDB Reactive

Answer 1

您所描述的用例不在websocket上运行（而是使用服务器发送事件的普通HTTP）。为了实现您想要做的事情，您需要利用Spring Data MongoDB中的可裁剪光标支持。

为此，您需要调整存储库定义，如下所示：

public interface PersonRepository extends ReactiveMongoRepository<Person, String> {

  @Tailable
  Flux<Person> findByFirstname(String firstname);

}