问题标签 [event-stream]

我有一个 python 脚本（在 CherryPy 框架中），它发送 Event: 和 data: 这篇Opera 博客文章描述的文本到客户端浏览器。接收 x-dom-event-stream 内容的 javascript 与它们在博客文章中显示的内容几乎相同。但是，浏览器只显示发送的第一个事件。有人知道我错过了什么吗？

我尝试了几个旧版本的 Opera，发现它可以在 Opera 9.52 中运行，但不能在任何新版本中运行。他们改变了什么？

这是python代码：

这是javascript/html。向 /data/ 发出请求会运行上面的 python 函数。

在 Firefox 中打开直接 /data/ url 会将流保存到文件中。所以我知道输出格式正确，并且流完全可以工作。

是否有用于 ruby​​ 的开源复杂事件处理 (CEP) 引擎？

我正在寻找能够提供状态分析的东西，而不仅仅是规则引擎式的先行谓词产生式。

对于我正在进行的项目，我不能使用 [dbo] 模式。通过查看 EventStore 源，使用非 dbo 模式看起来并不简单。

到目前为止，我想出的最好的方法是使用这样的自定义方言：

• 子类 CommonSqlDialect
• 添加 MsSqlDialect 的私有实例
• 然后覆盖 CommonSqlDialect 的所有虚拟属性以执行类似的操作

例子：

我还必须自定义 InitializeStorage 属性以将“sysobjects”替换为“sys.objects”，这样我就可以在模式名称上添加额外的约束。

这可行，但似乎应该有用于自定义模式和表名的连接选项。

有没有更好的方法来处理我错过的这个问题？

我想每 2 分钟向用户推送一次数据。使用 EventSource 需要每 29 秒额外推送一次空字节以保持连接打开。WebSocket 不需要这样的 ping。为什么 EventSource 连接会定期关闭和重新打开？是因为HTTP中没有好的内置方法来检查连接是否仍然打开还是其他原因？

我是 Drools 应用程序的新手，尤其是 Drools fusion。在我的办公室里，我们正在开发一个独立的复杂事件处理应用程序。主要要求之一是计算每个事件的开始时间、频率、结束时间、持续时间的可能性。我们正在测试 Drools Fusion 这样做，我们制作了这个不起作用的例子。在此示例中，我们尝试计算持续时间。作为旁注，我们无法计算事件时间戳，现在我们使用 System.currentTimeMillis() 解决。

也许 Drools 不是一个好的框架，我们必须改变我们的选择？

示例.drl

和示例类

我正在编写一个 C# 类来包装一个简单的 Web 服务。RESTful 的东西很容易总结，但现在我需要在服务器上的某些东西发生变化时引发一个事件。

我已经设置了服务器以使事件流可用，但我不知道如何在 C# 中获取流。

目前我正在做这样的事情：

在我的测试中，该事件被拾取一次，但不是两次。服务器上的事件本质上是一个开关——有些事情发生了，它继续，其他事情发生了，它熄灭了。我知道切换是有效的，因为我已经将事件流连接到一个普通的网页来测试它。

我应该如何处理 C# 中的事件流？

编辑 1：我已经更新了代码以修复 TimVK 指出的错误，但事件流仍然没有被第二次拾取。

好的，这就去。我制作了一个使用 Node.js 和 HTML5 Event-Streams 的简单聊天服务器，但由于某种原因，Event-Stream 无法工作，客户端页面在 textarea 中不显示任何应该保存来自 Event-Stream 的消息的内容. 我无法确定原因，我想知道是否有人可以帮助解决这个问题。

下面是我的 Javascript 文件：

请注意，另一个服务器文件采用传递给 /chat 的任何参数并将其作为 params 变量传递。例如：

/chat?room=testroom&nick=用户名&message=message1

将被解析为：

var params = { room : "testroom", nick : "username", message : "message1" };

聊天.js

这是控制台输出：

我正在尝试使用 Rails 4 的实时流实现文本/事件流。它工作得很好，我遇到的唯一问题是我无法在不发送任何消息的情况下检查连接是否存在。

我想出的唯一解决方案是使用循环滴答发生器制作支持通道，以便一些后台任务会定期在那里发送消息。但它似乎是混乱和不可靠的。有更好的解决方案吗？

这是我的控制器：

我有以下（无效）代码：

问题在于最后一个流是从流es.child(cp.exec("cat "+data))中data写入的块map()。如何实现这一目标？另请注意，“ls”和“cat”不是我使用的实际命令，但执行动态生成的 unix 命令和流式输出的原理是相同的。

我有一个使用 HTML、CSS、jQuery 的聊天面板。设置一个没有问题的事件监听器。设置一个文本/事件流 php 文件，它可以毫无问题地向客户端发送消息。如何从客户端与此服务器脚本进行通信，以便在收到来自任何一个客户端的新消息后，它将向所有打开事件流的用户广播一条消息？服务器应仅在收到新消息时发送事件。

这是 message_sender.php：

这是js：