1

我制作了一个小型 Sinatra 应用程序来或多或少地实时跟踪我们公司的一些数据。

设置很像dashing.io/：

  • Rufus Scheduler 作业用于在一定的时间间隔内查询数据库。
  • 查询结果返回到 SSE 连接流。
  • 客户端订阅流（在 erb 视图中的 javascript 中定义）并以不同的方式显示数据，例如使用 highcharts。

这一切都很好，但是，我注意到如果我让作业运行的频率低于每分钟，客户端将一直断开连接并重新连接。让我解释：

订阅 javascript 代码如下所示：

<script type="text/javascript">

var source       = new EventSource('/stream/channels-energy');

source.onopen    = function(event) { 
    console.log("Connection opened", event) 
}

source.onerror   = function(event) {
    console.log("Connection error", event) 
}

source.onmessage = function(event) { 
    var data_energy = JSON.parse(event.data);
    console.log("Time: " + event.lastEventId + "Length: " + Object.keys(data_energy).length);
}

</script>

如果我让作业每 30 秒运行一次，那么一切都会完美运行。在 Chrome（或 Firefox）的控制台中查看以下内容：

Connection opened Event
Time: 2016-03-13T13:33:39.625ZLength: 2854
Time: 2016-03-13T13:34:09.656ZLength: 2854
Time: 2016-03-13T13:34:39.698ZLength: 2854
Time: 2016-03-13T13:35:09.395ZLength: 2854
Time: 2016-03-13T13:35:39.493ZLength: 2854
Time: 2016-03-13T13:36:09.592ZLength: 2854
Time: 2016-03-13T13:36:39.674ZLength: 2854

但是，如果我将作业间隔调整为 3 分钟，控制台会显示客户端不断断开连接：

Connection opened Event
Time: 2016-03-13T13:00:16.018ZLength: 2909
Connection error Event
Connection opened Event
Connection error Event
Connection opened Event
Connection error Event
Connection opened Event
Time: 2016-03-13T13:03:15.912ZLength: 2891
Connection error Event
Connection opened Event
Connection error Event
Connection opened Event
Connection error Event
Connection opened Event
Time: 2016-03-13T13:06:15.857ZLength: 2891
Connection error Event
Connection opened Event
Connection error Event
Connection opened Event
Connection error Event
Connection opened Event
...

客户端似乎仍然能够检索输入数据，因此最终结果不会受到此影响。我的问题是，这是不断断开/重新连接的正常行为吗？无论数据流式传输的频率如何，客户端不应该保持连接打开吗？

4

1 回答 1

1

是的，客户端（浏览器）将保持套接字打开，而不管发送的数据如何。

这可能是因为您的后端服务器在安静时关闭了套接字。但是，也可能是您的本地 ISP 关闭了套接字。您可以通过从另一个物理位置对其进行测试来诊断它是什么。

然而，一个很好的解决方案，很好地涵盖了任何一个原因，是添加一个保持活动（又名心跳）信号。这从服务器发送到客户端，类似于每 N 秒，例如 N=50。

对于网络级断开连接，发送 SSE 评论就足够了。但我喜欢做的是发送适当的信息。这允许客户端跟踪它上次从服务器听到的时间，并在它怀疑出现问题时启动它自己的断开和重新连接，即如果超过 N+10 秒内没有数据到达。（这种情况很少见，但有时确实会发生。）

于 2016-03-14T13:50:56.027 回答