Spring Web Flux Reactive + 服务器发送事件 = 无限循环？

Question

我正在使用 Spring Web Flux Reactive、MongoDB 和 Angular 构建实时事件流应用程序（例如股票汇率）。我想构建以下管道：MongoDB -> Reactive MongoDB Driver -> Spring Web Reactive MongoDB Repository -> Spring Web Reactive Controller -> Angular（通过服务器发送的事件）。

这是我的 Spring Web 反应式控制器：

@GetMapping(value = "/test", produces = MediaType.TEXT_EVENT_STREAM_VALUE)
public Flux<LiveRate> test() {
    Flux<LiveRate> res = liveRateRepository.findByLastUpdate(1504580678).log(); // I query hard-coded value and MongoDB returns 4 events

    return res;
}

这是我的角度代码：

var source = new EventSource('http://localhost:8080/test');
source.addEventListener('message', function(e) {
    console.log(e.data);
}, false);

由于某种原因，Angular 无限次返回 4 个事件，Spring 也不断查询 MongoDB。我的理解是，使用服务器发送事件方法 Spring 应该返回它拥有的所有事件并继续等待新事件，但看起来 Angular 不断要求越来越多的事件。

如果我在浏览器中点击http://localhost:8080/test它只返回预期的 4 个事件。

你能解释一下我缺少什么吗？谢谢。

Answer 1

我最好的猜测是：

1. 浏览器连接到 SSE 流，这会触发存储库查询
2. 检索到所有 4 个条目Flux后，存储库完成
3. 这完成了 SSE 流
4. 浏览器自动重新连接到 SSE 源
5. 回到第 1 步

您应该会在浏览器开发工具（网络选项卡）中看到浏览器重新连接。

如果您正在寻找无限流，您应该使用Spring Data MongoDB 中的 Tailable Cursors 功能。在你的情况下，只需用注释你的存储库方法@Tailable就可以了。