我正在尝试用gorilla/websocket写一个简单的go WebSocket服务器
http.HandleFunc("/ws", func(w http.ResponseWriter, r *http.Request) {
if os.Getenv("env") == "development" {
upgrader.CheckOrigin = func(r *http.Request) bool { return true }
}
conn, err := upgrader.Upgrade(w, r, nil)
if err != nil {
log.Printf("Websocket error: %s", err)
return
}
defer conn.Close()
// Register client
clients[conn] = true
for {
message := message.Message{}
_, msg, err := conn.ReadMessage()
if err != nil {
log.Printf("Websocket error: %s", err)
return
}
res, _ = json.Marshal(context.Game)
// Send to every client that is currently connected
for client := range clients {
err := client.WriteMessage(websocket.TextMessage, res)
if err != nil {
// Remove connection
client.Close()
delete(clients, client)
}
}
}
})_, msg, err := conn.ReadMessage()行抛出错误并关闭WebSocket，但我不确定原因。
错误是close 1006 (abnormal closure): unexpected EOF。如何防止此错误？
2条答案
按热度按时间gwbalxhn1#
该错误表示对等方在没有发送关闭消息的情况下关闭了连接。RFC将此称为“异常关闭”，但接收到该错误是正常的。
使用IsUnexpectedCloseError过滤掉预期的关闭错误。Gorilla Chat Example展示了如何使用该函数（在此处查看代码）。
正如Adrian指出的那样，问题中的应用程序在
clients上存在数据竞争。Gorilla Chat示例展示了如何在没有数据竞争（中心）的情况下维护客户端Map。l0oc07j22#
除了服务器和客户端本身断开连接外，您可能还需要注意WS是否由于中间代理转发的存在而断开连接。
例如，使用
nginx反向代理后，连接到sokcet后一段时间后报告错误，这是由不适当的超时设置引起的。例如
将
proxy_read_timeout time设置为大于服务器的心跳时间可以解决此断开问题