Perché il mio server web in golang non gestisce richieste concorrenti?

Question

Questo semplice server HTTP contiene una chiamata a time.Sleep() che rende ogni richiesta impiega cinque secondi. Quando provo a caricare rapidamente più schede in un browser, è ovvio che ogni richiesta viene accodata e gestita in modo sequenziale. Come posso far sì che gestisca richieste concorrenti?

package main 

import (
    "fmt" 
    "net/http" 
    "time" 
) 

func serve(w http.ResponseWriter, r *http.Request) { 
    fmt.Fprintln(w, "Hello, world.") 
    time.Sleep(5 * time.Second) 
} 

func main() { 
    http.HandleFunc("/", serve) 
    http.ListenAndServe(":1234", nil) 
} 

In realtà, ho appena trovato la risposta a questo dopo aver scritto la domanda, ed è molto sottile. Lo sto pubblicando comunque, perché non ho trovato la risposta su Google. Riesci a vedere cosa sto facendo male?

Answer 1

Il programma gestisce già le richieste contemporaneamente. È possibile verificare con ab, uno strumento di riferimento che viene fornito con Apache 2:

ab -c 500 -n 500 http://localhost:1234/ 

Sul mio sistema, il punto di riferimento prende un totale di 5043ms per servire tutte le 500 richieste simultanee. È solo il tuo browser che limita il numero di connessioni per sito web.

Benchmarking I programmi Go non sono così semplici, perché è necessario assicurarsi che lo strumento di benchmark non sia il collo di bottiglia e che sia anche in grado di gestire molte connessioni simultanee. Pertanto, è una buona idea utilizzare un paio di computer dedicati per generare carico.

Answer 2

Da Server.go, la routine di go viene generata nella funzione Serve quando viene accettata una connessione. Qui di seguito è il frammento di,: -

// Serve accepts incoming connections on the Listener l, creating a 
// new service goroutine for each. The service goroutines read requests and 
// then call srv.Handler to reply to them. 
func (srv *Server) Serve(l net.Listener) error { 
     for { 
      rw, e := l.Accept() 
       if e != nil { 
...... 
      c, err := srv.newConn(rw) 
      if err != nil { 
       continue 
      } 
      c.setState(c.rwc, StateNew) // before Serve can return 
      go c.serve() 
     } 
} 

Answer 3

Se si utilizza richiesta XHR, assicurarsi che esempio XHR è una variabile locale.

Ad esempio, xhr = new XMLHttpRequest() è una variabile globale. Quando si esegue una richiesta parallela con la stessa variabile xhr, si riceve solo un risultato. Quindi, devi dichiarare xhr localmente come questo var xhr = new XMLHttpRequest().