服务器发送的事件 Golang
server-sent events Golang
我想以一种方式进行数据流传输,并且正在试验 SSE 与 Websockets。
使用 SSE 形成一个 golang 服务器 我发现在会话结束时如何通知客户端令人困惑。 (例如服务器已完成发送事件或服务器突然离线或客户端失去连接)
我需要做的一件事是可靠地知道这些断开连接的情况。不使用超时等。
到目前为止,我的实验是,当我使服务器脱机时,客户端会收到 EOF。但是我无法弄清楚如何从服务器向客户端发出连接关闭/完成的信号,然后如何处理/读取它? EOF 是确定关闭/错误/完成状态的可靠方法吗?
许多使用 SSE 的示例无法显示客户端良好的客户端连接处理。
使用 Websockets 会更容易吗?
非常感谢任何经验建议。
谢谢
SSE 标准要求浏览器在 N 秒后自动重新连接,如果连接丢失或服务器故意关闭套接字。 (在 Firefox 中 N 默认为 5,在 Chrome 和 Safari 中默认为 3,上次我检查过。)因此,如果需要,您不需要做任何事情。 (在 WebSockets 中,您必须自己实现这种重新连接。)
如果那种重新连接不是可取的,您应该向客户端发回消息,说"the show is over, go away"。例如。如果您正在传输财务数据,您可以在周五晚上市场关闭时发送。然后,客户端应拦截此消息并从其端关闭连接。 (然后套接字将消失,因此服务器进程将自动关闭。)
在 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);
更新:
您可以通过侦听 "close" 事件,然后查看 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
.
我想以一种方式进行数据流传输,并且正在试验 SSE 与 Websockets。
使用 SSE 形成一个 golang 服务器 我发现在会话结束时如何通知客户端令人困惑。 (例如服务器已完成发送事件或服务器突然离线或客户端失去连接)
我需要做的一件事是可靠地知道这些断开连接的情况。不使用超时等。 到目前为止,我的实验是,当我使服务器脱机时,客户端会收到 EOF。但是我无法弄清楚如何从服务器向客户端发出连接关闭/完成的信号,然后如何处理/读取它? EOF 是确定关闭/错误/完成状态的可靠方法吗?
许多使用 SSE 的示例无法显示客户端良好的客户端连接处理。
使用 Websockets 会更容易吗?
非常感谢任何经验建议。
谢谢
SSE 标准要求浏览器在 N 秒后自动重新连接,如果连接丢失或服务器故意关闭套接字。 (在 Firefox 中 N 默认为 5,在 Chrome 和 Safari 中默认为 3,上次我检查过。)因此,如果需要,您不需要做任何事情。 (在 WebSockets 中,您必须自己实现这种重新连接。)
如果那种重新连接不是可取的,您应该向客户端发回消息,说"the show is over, go away"。例如。如果您正在传输财务数据,您可以在周五晚上市场关闭时发送。然后,客户端应拦截此消息并从其端关闭连接。 (然后套接字将消失,因此服务器进程将自动关闭。)
在 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);
更新:
您可以通过侦听 "close" 事件,然后查看 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
.