Sinatra 和 Thin 上的服务器发送事件 (SSE) 反复断开连接并重新连接

Question

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

设置非常像 dashing.io/:

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

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

订阅 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
...

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

Answer 1

是的，无论发送的数据如何，客户端（浏览器）都会保持套接字打开。

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

但是，一个很好的解决方案（可以很好地涵盖这两个原因）是添加一个保持活动（又名心跳）信号。这是从服务器发送到客户端，大约每 N 秒发送一次，例如N=50.

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

Sinatra 和 Thin 上的服务器发送事件 (SSE) 反复断开连接并重新连接

Server Sent Events (SSE) on Sinatra and Thin disconnects and reconnects repeatedly

server-sent-events

eventsource