9得票2回答
事件源命名的事件使用TypeScript

我正在尝试在Typescript中使用EventSource,但是当使用命名事件时无法正确地为响应类型进行定义。 我尝试过: const evtSource = new EventSource('/my-url'); const parseMyEvent = (evt: Event) =...

8得票1回答
多服务器实例环境下,服务器如何使用SSE发送消息

我有一个问题,如何在多个服务器环境中使SSE工作。 在用户界面(UI)中,有两个步骤: 1. source = new EventSource('http://localhost:3000/stream'); source.addEventListener('open', funct...

8得票3回答
Spring的SseEmitter.complete()方法是否应该触发EventSource重新连接 - 如何在服务器端关闭连接

我正在尝试设置Spring SseEmitter以发送运行作业状态的一系列更新。看起来它正在工作,但是: 每当我在Java服务器代码中调用emitter.complete()时,javascript EventSource客户端就会调用注册的onerror函数,然后再次使用新连接调用我的Ja...

7得票5回答
SSE非常缓慢

我目前正在编写一个网络游戏的通信框架,通信图如下所示: 代码如下: test.php: <!DOCTYPE html> <html> <head> <title> Test </title> ...

8得票2回答
使用 Apache Kafka 的“无限保留策略”作为基础,用于使用 CQRS 的事件溯源系统是否可行?

我目前正在评估设计/实现事件溯源+ CQRS架构方法以进行系统设计的选项。由于我们希望在其他方面使用Apache Kafka(正常的发布-订阅消息+流处理),因此下一个合乎逻辑的问题是:“我们可以将Apache Kafka存储用作CQRS的事件存储吗?”或者更重要的是,这是否是一个明智的决定?...

7得票1回答
使用标准ASP.NET MVC发送服务器事件(EventSource)导致错误。

我正在尝试使用服务器推送事件(Server-Sent Events),但是我无法在一个MVC项目(非WebAPI)中使其正常工作。我在网上没有找到任何好的示例。 以下是我尝试的服务器端代码(包括从各种帖子中失败的尝试): Function GetRows() as ActionResult...

7得票2回答
SSE事件在调用res.end()之前无法传递到客户端

之前用的代码能够工作,但是现在不知道为什么不能正常工作了。请帮忙解决。 我的问题是,在实时数据共享中使用SSE时,应该通过res.write(data:${JSON.stringify(dataObject)}\n\n)发送数据对象,但在调用res.end()之前并没有发送,直到所有数据的事...

7得票3回答
Angular2/TypeScript和SSE(EventSource)

首先,我对ng2和typescript都比较陌生。 我的目标是在Angular2组件中实现服务器发送事件。我已经按照早期帖子中提到的示例进行了操作,但是我的问题是“EventSource”对象未被识别(在VS Code中显示为红色下划线)。 我不确定是否缺少某些引用...... 我的引用如...

9得票2回答
从(服务器发送的)EventSource创建RxJS Observable

我想从EventSource (服务器发送的事件)创建一个 RxJs Observable。 我尝试了以下代码: import {Component, OnInit} from 'angular2/core'; import {Subject, Observable} from 'rxj...

11得票3回答
Chrome net::ERR_HTTP2_PROTOCOL_ERROR在重新连接后出现200错误

我正在使用基于Express的Node服务器来处理Server Sent Events流。该流通过启用了http2的NginX代理。React应用程序使用EventSource消费SSE事件。为保持连接活动状态,我每10秒发送一个心跳消息。 这一切都很好,直到出现某种形式的网络中断,比如将我...