如何在Golang服务器中实现长轮询保持通话开启？

从现在开始，我们要努力学习啦！今天我给大家带来《如何在Golang服务器中实现长轮询保持通话开启？》，感兴趣的朋友请继续看下去吧！下文中的内容我们主要会涉及到等等知识点，如果在阅读本文过程中有遇到不清楚的地方，欢迎留言呀！我们一起讨论，一起学习！

我正在 heroku 上的 golang (https://github.com/r3labs/sse) 中使用这个令人惊叹的 sse 服务器。

那里有超时限制：https://devcenter.heroku.com/articles/request-timeout#long-polling-and-streaming-responses：

如果您要发送流式响应，例如服务器发送的事件，则需要检测客户端何时挂断，并确保您的应用程序服务器立即关闭连接。如果服务器保持连接打开 55 秒而不发送任何数据，您将看到请求超时。

我知道在 websocket 世界中存在 keep-alive ping 的概念。

我正在尝试使用这段代码：

go func() {
  for range time.tick(time.second * 1) {
    fmt.println("a second")
    sseserver.publish("test", &sse.event{data: []byte("ping")})
  }
}()

使用像这样的简单服务器：

httpServer := &http.Server{
  //...
  ReadTimeout:  "10s",
  WriteTimeout: "10s",
}

但它不起作用。呼叫在 10 秒（和 10 次 ping 操作）后关闭。

我认为它在 heroku 上也会失败。

我哪里错了？

我们可以仅更改这些 sse 调用的超时吗？

还有其他方法吗？

更新

我不需要准确检测断开连接的客户端，我根本不在乎。当服务器发生问题时，我使用它来刷新仪表板。

我不喜欢使用 websocket 来完成如此简单的事情。

我想我没有很好地解释自己，因为我不太想使用 ping 来检测断开连接的客户端，而是因为我希望连接不被中断（就像 heroku 上发生的那样）。

现在的情况

本地

如果我在 windows 上以及 docker linux 容器上完全删除 readtimeout 字段，则连接不会停止并且一切正常。

关于 heroku

由于在 heroku 上，连接在超时期间每 55 秒就会断开一次，我在第一篇文章中告诉过您，我使用非常简单的代码尝试了该循环，并且它有效：sse 调用不再关闭！

剩下的问题

1. 如何在任何情况下为所有其他调用（非 sse）提供默认的 readtimeout；我认为最好的做法是设置默认的 readtimeout。

怎么办？

正确答案

你不需要ReadTimeout；在初始 EventSource/服务器发送事件 (SSE) 连接之后，服务器将永远从客户端读取任何内容。

因此，使用 SSE 连接设置默认读取超时并不是最佳实践，因为读取超时总是会受到影响。您无法通过初始 SSE GET 请求发送更多数据备份。

您应该将 SSE 视为基本上一个永远不会关闭的 GET 请求，因为这几乎就是它的本质。这意味着它可以在大多数代理服务器上正常工作，而在不能正常工作的情况下（代理服务器应用自己的超时），客户端将自动重新连接，这实际上是一个非常好的功能，在 websocket 中找不到（尽管大多数 websocket 客户端库都实现了它）。

您可能想阅读这篇文章，了解有关 SSE 的更多精彩（和不太精彩）的内容：https://www.smashingmagazine.com/2018/02/sse-websockets-data-flow-http2/

关于您的其他问题，您可能正在寻找 HTTP 路由库，该库将允许您对某些 GET 请求应用超时，而不是其他请求，但问题是为什么；如果您试图防止资源耗尽，您应该在所有端点上均匀地应用该保护。

以上就是本文的全部内容了，是否有顺利帮助你解决问题？若是能给你带来学习上的帮助，请大家多多支持golang学习网！更多关于Golang的相关知识，也可关注golang学习网公众号。