Jak otworzyć stronę golang.org/x/net/websocket?

Question

Jestem naiwnie używać _, err := ws.Read(msg), aby otworzyć gniazdo sieci Web w moim kodzie. Nie sądzę, że działa niezawodnie.

W innym kodzie zauważyłem, że ludzie robią sleep loop. Jaki jest poprawny sposób na utrzymanie gniazda sieciowego na otwartą & stabilną? Zakładam, że bazowa biblioteka wykonuje ping/ponga?

Aktualizacja: Jestem przekonany, że winę ponosi client.go, ponieważ nie wydaje się, aby ponownie wybrać numer po rozłączeniu na serwerze. Zrobiłem a video demonstrating the issue.

Answer 1

Źle odczytałem pierwotne pytanie.

Nie robisz tego od razu. Zasadniczo trzeba zablokować obsługę programu, aby utrzymać połączenie sieci Web przy życiu. Jeśli nie zależy ci na wiadomości, po prostu ją odrzuć i nic z nią nie rób.

Częstym sposobem ludzie robią to mieć dedykowany Read i Write goroutine, coś jak:

func fishHandler(ws *websocket.Conn) { 
    id := ws.RemoteAddr().String() + "-" + ws.Request().RemoteAddr + "-" + ws.Request().UserAgent() 
    sockets[id] = ws 

    go writePump(ws) 
    readPump(ws) 
} 

func readPump(ws *websocket.Conn) { 
    defer ws.Close() 
    msg := make([]byte, 512) 
    _, err := ws.Read(msg) 
    if err != nil { 
     return 
    } 
} 

func writePump(ws *websocket.Conn) { 
    // Hand the write messages here 
} 

Answer 2

golang.org/x/net/websocket nie implementuje do ping-ponga z RFC 6455, ale goryl websocket implementation robi. Minimalny przykład z webletem Gorilla

c := time.Tick(pingInterval) 
go func(){ 
     for _ := range c { 
      if err := conn.WriteControl(Ping...); err != nil { 
       handle error 
      } 
     } 
    }() 

      ----- 

conn.SetPongHandler(func(string) error { return conn.SetReadDeadline(time.Now().Add(pingInterval)) }) 
go func(){ 
     for { 
      if _, _, err := conn.NextReader(); err != nil { 
       handle error 
      } 
     } 
    }()