56得票4回答
服务器发送事件(SSE)和EventSource能否通过POST方法传递参数?

我正在使用Html5服务器发送事件。 服务器端是Java Servlet。 我有一个JSON数组数据想要传递给服务器。var source = new EventSource("../GetPointVal?id=100&jsondata=" + JSON.stringify(data...

14得票1回答
测试一个包含ActionController::Live的控制器

我有一个控制器,其中包括Rails的ActionController::Live模块。我正在显示一个日志文件的内容,该文件使用FileTail gem进行读取,并使用来自ActionController::Live的SSE,如下所示:class LogsController < Appl...

14得票2回答
AWS中哪个服务适合将实时更新发送到浏览器?

我正在开发一款股票应用,需要对用户的浏览器进行价格更新。 我不需要访问过去的数据,只需在价格变动时让浏览器获取当前数据。 是否可能过滤 DynamoDB 流并公开一个端点(在 API 网关后面),可与 JavaScript EventSource 一起使用?

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

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

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

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

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

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

9得票4回答
GraphQL使用服务器推送事件和EventSource进行订阅

我正在研究使用服务器发送事件作为支持api来实现“订阅”类型。但我遇到的问题是界面,更确切地说,此类操作的http层。使用原生EventSource不支持:1.指定HTTP方法,默认使用“GET”;2.包含有效载荷(GraphQL查询)。虽然第一个无可辩驳,但第二个可以通过使用查询参数来规避。...

8得票2回答
在使用ReactJs中的EventSource消费事件流时,遇到net::ERR_INCOMPLETE_CHUNKED_ENCODING 200错误。

我有一个非常简单的节点服务,公开了一个端点,旨在使用服务器发送事件(SSE)连接,而基本的ReactJs客户端则通过EventSource.onmessage进行消耗。 首先,在updateAmountState(Chrome Dev)中设置调试点时,我无法看到它被调用。 其次,我遇到了net...

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

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

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

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