Spring Web Flux Reactive+服务器发送的事件=无限循环？
@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);
如果我在浏览器中点击http://localhost:8080/test，它只返回4个预期的事件。
你能解释一下我缺了什么吗？多谢了。
共有1个答案
我的最佳猜测是：
- 浏览器连接到SSE流，从而触发存储库查询
- 检索到所有4个条目后，
通量将由存储库完成 - 这将完成SSE流
- 浏览器自动重新连接到SSE源
- 返回步骤1
您应该在浏览器devtools（网络选项卡）中看到浏览器重新连接。
-
概述 客户端代码 概述 建立连接 open事件 message事件 error事件 自定义事件 close方法 数据格式 概述 data：数据栏 id：数据标识符 event栏：自定义信息类型 retry：最大间隔时间 服务器代码 参考链接 概述 传统的网页都是浏览器向服务器“查询”数据，但是很多场合，最有效的方式是服务器向浏览器“发送”数据。比如，每当收到新的电子邮件，服务器就向浏览器发送一个“
-
概述 客户端代码 概述 建立连接 open事件 message事件 error事件 自定义事件 close方法 数据格式 概述 data：数据栏 id：数据标识符 event栏：自定义信息类型 retry：最大间隔时间 服务器代码 参考链接 概述 传统的网页都是浏览器向服务器“查询”数据，但是很多场合，最有效的方式是服务器向浏览器“发送”数据。比如，每当收到新的电子邮件，服务器就向浏览器发送一个“
-
我试图让服务器发送的事件与Mozilla Firefox一起工作。给定一个Spring Boot的网络服务 使用Chrome浏览器或Edge（始终是最新版本）可以正常工作。我可以在网络分析器选项卡中看到未完成的请求，并且每秒都会显示一个新的时间戳。 然而，当我使用Firefox（84.0.2或更早版本）时，请求也会显示在网络选项卡中，但不会显示响应头或流数据。当我终止Spring后端时，Firef
-
如果我正确理解了服务器发送事件的原则，那么每次客户端注册到EventSource时，它实际上会打开一个到管理事件的资源的新HTTP连接。与其他HTTP请求相反，连接保持活动状态，因此专用于此客户端的服务器进程/线程将一直运行，直到客户端断开连接。 如果我们有1000个客户端使用SSE连接到一个应用程序，该怎么办？我们是否会有1000个进程/线程（做同样的事情）并发运行以处理SSE？我想我错了，但如
-
http://www.html5rocks.com/en/tutorials/eventsource/basics/ 但是，我不明白一个重要的概念--是什么触发了服务器上导致消息发送的事件？ 换句话说--在HTML5示例中--服务器只发送一次时间戳： 如果我建立一个实际的例子--例如，一个Facebook风格的“墙”或一个股票报价器，在这个例子中，每当某个数据发生变化时，服务器就会向客户机“推送”
-
问题内容： 双方的WebSockets和服务器发送的事件能够将数据推送到浏览器。在我看来，它们似乎是竞争技术。它们之间有什么区别？您何时会选择一个？ 问题答案： Websocket和SSE（服务器发送事件）都能够将数据推送到浏览器，但是它们不是竞争技术。 Websockets连接既可以将数据发送到浏览器，也可以从浏览器接收数据。可以使用websockets的应用程序的一个很好的例子是聊天应用程序。