go - 服务器发送的事件 Golang

Question

我想以某种方式进行数据流传输，并且正在试验 SSE 与 Websockets。

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

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

许多使用 SSE 的示例无法显示客户端良好的客户端连接处理。

使用 Websockets 会更容易吗？

非常感谢任何经验建议。

谢谢

Answer 1

SSE 标准要求浏览器在 N 秒后自动重新连接，如果连接丢失或服务器故意关闭套接字。 (N 默认为 5 在 Firefox 中，在 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.");
  }

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

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