问题标签 [event-stream]

我第一次尝试开发rest api。并寻找对资源使用更改流的环回引用，例如/resources/change-stream使用 GET 和 POST 方法。

我访问过这篇文章，它指出了 rest api 和流 api 之间的区别。

我认为，虽然环回在 rest api 中提供它。它是什么以及它的作用。您能否以您对我清楚的方式向我解释（对于一个六岁的孩子）。因为，我是第一次自己开发 REST API。因此，如果可能的话，我想逐步了解邮递员中应该有什么。我应该将 url'/api/resources/change-stream?_format=event-stream与application/jsoncontent-type 一起使用还是就/api/resources/change-stream可以了。

如果您能给我提供一些真实的示例以便我可以在自己的应用程序中尝试开发它，那将是一个很好的示例。

PS：无论您选择哪种语言（Node.js、Python、Ruby、PHP），我都可以通过一些示例来提供答案。

我的总体目标是观察我的数据库是否有任何更改，并自动将这些更改广播给连接到我网站的任何用户。我看到的问题是我有一个动作触发了对我的数据库的发布请求，然后同时触发了事件流，因为我正在观看的模型已经改变。这导致初始操作完成，并且由事件流触发的操作在完成之前被中断。

这是为在我的数据库中创建新的博客文章条目而触发的第一个操作

我期望在事件侦听器调度“liveChangeBlogs”操作之前，“TOPIC_SUBMIT”操作应该返回完成这是我在环回事件流https://loopback.io/doc/en/lb3/Realtime上找到的文档-server-sent-events.html

我最近使用 nodejs 的事件流库来解析一个巨大的 csv 文件，将结果保存到数据库。如何解决不仅读取文件，而且修改每一行，将结果写入新文件的任务？它是通过和映射方法的某种组合，还是双工？非常感谢任何帮助。

我正在创建一个 SSE 简单示例，我使用 Scalatra 创建了一个 API，并通过 header 的间隔获取响应text/event-stream。看起来 Scalatra 不支持这种类型。这是我的简单代码，

但我只收到来自服务器的消息。我想做类似的事情akka-http

你们知道如何从 Scalatra获取事件流吗？谢谢你。

以上与我的设置非常相似。不过，我对此有两个问题。要么显示未更新，要么当一个流结束时，其他流停止更新。

我使用事件溯源模型构建了一个应用程序，并且我认为在事件流中记忆它们的历史没有任何好处，例如用户实体。将我的系统事件的一部分作为源，而其他部分使用实体关系模型进行常规建模是否很好。

后者如果我决定事件源非事件源实体，有没有我可以遵循的通用方案，所以转换是无缝的并且没有数据丢失。

我有React web application和REST API (Express.js)。

我发现如果您不想使用长轮询或套接字（无需发送数据客户端->服务器），使用 EventStream 是更好的选择。

用例：

1. 用户打开页面，其中是空表，其他用户可以在其中添加数据POST /data。
2. 该表由来自 API 的初始数据填充GET /data。
3. 然后页面连接到 EventStream/data/stream并监听更新
4. 有人添加新行和表需要更新...

是否可以从后端（用于添加行的控制器）向所有连接的用户广播此更改（添加的新行）/data/stream？

我的任务是创建一个事件流，我有一个自动轮询器（设置为 10 分钟间隔）来检索在过去 10 分钟内更改的所有实体。

现在，业务逻辑规定我们仅在实体中特定字段发生更改时创建新的更新事件。由于我们没有关于特定字段更改的粒度（我们所知道的是某些更改），因此我必须创建某种执行以下操作的微分器方法：

1. 获取之前的实体状态
2. 将之前的状态与最新的状态进行比较（即差异）
3. 如果至少有一个字段被业务逻辑确定为重要，则创建更新事件
4. 如果更新事件已创建，则将之前的实体状态替换为最新的

考虑到这个架构问题，是否有已知的模式或模式集，或指导如何构建这种类型的系统？

我们的服务器用于 Nginx 作为 webserver，并添加了 nginx_push_stream的编译模块。之前推流用的是Restful，后来改成Websocket，但是WebSocket有时在客户端或服务器带宽小的时候会丢失。在 2019 年，从 Websocekt 到 Server-Sent Event (SSE) / event-source，例如 event stream 或 text/event-stream，以减少客户端或服务器的损失。

拜托，任何人，对库事件流能够用于 android 客户端和 iPhone 客户端有任何想法。

我已经习惯了 Okhttp 但还没有准备好使用的事件流，RxSSE 无法在 Android 中使用，根本没有响应。

我希望明年 OkHttp 已经为 Android 客户端和 iPhone 客户端更新了 OkHttp-EventSource

对于我的 DIY 项目，我想从第 3 方 API 中检索数据，该 API 返回带有“文本/事件流”标头。

因为连接没有关闭，所以我使用超时来完成，如下所示：

除了超级hacky之外，它很慢而且感觉很糟糕。

是否可以仅从事件流中捕获第一个数据元素 (JSON)？

到目前为止，我找不到任何令人满意的解决方案来解决我的问题。也许我缺乏正确的词汇来搜索。

非常感谢帮助。