服务器发送事件 Golang

Posted

技术标签:

【中文标题】服务器发送事件 Golang【英文标题】:server-sent events Golang 【发布时间】:2015-09-24 22:40:11 【问题描述】:

我想做一些单向的数据流,并正在试验 SSE 与 Websockets。

使用 SSE 形成一个 golang 服务器,我发现在会话完成时如何通知客户端令人困惑。 (例如服务器已完成发送事件或服务器突然下线或客户端失去连接)

我需要做的一件事是可靠地知道这些断开连接的情况。不使用超时等。 到目前为止,我的实验是,当我使服务器离线时,客户端会收到 EOF。但是我很难弄清楚如何从服务器向客户端发出连接已关闭/完成的信号,然后如何处理/读取它? EOF 是确定关闭/错误/完成状态的可靠方法吗?

许多 SSE 示例未能显示客户端良好的客户端连接处理。

使用 Websockets 会更容易吗?

任何经验建议最受赞赏。

谢谢

【问题讨论】:

您能否从服务器发送一条数据消息,指示客户端应关闭连接,然后让客户端显式调用关闭连接? 您使用的是什么 sse 客户端? EventSource? 我使用的是github.com/JanBerktold/sse,但我的问题比特定的lib实现更笼统。我想我可能会尝试制定一个好的客户端服务器示例.. 【参考方案1】:

如果连接丢失或服务器故意关闭套接字,SSE 标准要求浏览器在 N 秒后自动重新连接。 (N 在 Firefox 中默认为 5,在 Chrome 和 Safari 中默认为 3,上次我检查过。)因此,如果需要,您无需执行任何操作。 (在 WebSockets 中,您必须自己实现这种重新连接。)

如果这种重新连接是可取的,您应该改为向客户端发送一条消息,说“演出结束,走开”。例如。如果您正在流式传输财务数据,您可能会在周五晚上市场关闭时发送。然后,客户端应拦截此消息并从其一侧关闭连接。 (然后套接字将消失,因此服务器进程将自动关闭。)

javascript 中,假设您使用 JSON 发送数据,看起来像这样:

var es = EventSource("/datasource");
es.addEventListener("message", function(e)
  var d = JSON.parse(e.data);
  if(d.shutdownRequest)
    es.close();
    es=null;
    //Tell user what just happened.
    
  else
    //Normal processing here
    
  ,false);

更新:

您可以通过侦听“关闭”事件,然后查看e.target.readyState 来了解重新连接发生的时间

es.addEventListener("error", handleError, false);
function handleError(e)
  if(e.target.readyState == 0)console.log("Reconnecting...");
  if(e.target.readyState == 2)console.log("Giving up.");
  

没有其他信息可用,但更重要的是它无法区分您的服务器进程故意关闭连接、您的 Web 服务器崩溃或您的客户端的 Internet 连接断开。

您可以自定义的另一件事是重试时间,方法是让服务器发送retry:NN 消息。因此,如果您不想快速重新连接,而是希望在任何重新连接尝试之间至少间隔 60 秒,请让您的服务器发送 retry:60

【讨论】:

好吧,我明白了,也许我只是在假设连接协议中有我可以使用的东西的情况下工作。所以基本上我需要为我的客户创建某种断开连接的消息然后处理它。我想这可以正常工作。我的特定客户可能需要更严格的处理断开连接的规则,即,如果应用程序失去连接等,请关闭应用程序。感谢您提供信息! 刚刚检查了我的书,第 59 页对此进行了介绍 - 使用错误处理程序。它不是很有用,我不建议您将其用于您的情况,但我会更新我的答案。

以上是关于服务器发送事件 Golang的主要内容,如果未能解决你的问题,请参考以下文章

Golang中用到的的Websocket库

Eventsource golang:如何检测客户端断开连接?

在 golang 中更新 grpc 的接收和发送消息大小

分析 Golang 服务器

golang socket通信 怎么把一个客户端发送的数据推送给其他客户端

Golang发送邮件