Come mantenere aperto un golang.org/x/net/websocket?

Question

Uso ingenuo _, err := ws.Read(msg) per mantenere aperto un socket Web nel mio codice. Non penso che funzioni in modo affidabile.

In altri codici ho notato persone che fanno uno sleep loop. Qual è il modo corretto per mantenere aperto un socket Web & stabile? Presumo che la libreria sottostante faccia ping/pongs?

Aggiornamento: Sono abbastanza fiducioso che il client.go è la colpa poiché non sembra riselezionare dopo una disconnessione è visto sul server. Ho fatto a video demonstrating the issue.

Answer 1

Ho letto male la tua domanda originale.

No, lo stai facendo subito. Fondamentalmente è necessario bloccare il gestore per tornare a mantenere in vita la connessione web. Se non ti interessa il messaggio, scartalo e non fare nulla con esso.

Un modo comune le persone lo fanno è quello di avere un apposito Read e Write goroutine, qualcosa di simile a:

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 non implementa ping-pong da RFC 6455, ma la webs gorilla implementation fa. Esempio minimo con ragnatela di 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 
      } 
     } 
    }()