Dlaczego mój serwer internetowy w golang nie obsługuje jednoczesnych żądań?

Question

Ten prosty serwer HTTP zawiera wywołanie metody time.Sleep(), która powoduje, że każde żądanie trwa pięć sekund. Kiedy próbuję szybko ładować wiele zakładek w przeglądarce, oczywiste jest, że każde żądanie jest kolejkowane i obsługiwane sekwencyjnie. Jak mogę obsłużyć współbieżne żądania?

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) 
} 

Właściwie znalazłem odpowiedź na to pytanie po napisaniu pytania i jest bardzo subtelne. Mimo to publikuję, ponieważ nie mogłem znaleźć odpowiedzi w Google. Czy widzisz, co robię źle?

Answer 1

Twój program już obsługuje zgłoszenia jednocześnie. Można przetestować go z ab, benchmark narzędzie, które jest dostarczany z Apache 2:

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

W moim systemie, ceniony zajmuje łącznie 5043ms służyć wszystkim 500 jednoczesnych żądań. To tylko przeglądarka, która ogranicza liczbę połączeń na stronę.

Benchmarking Go programów nie jest tak łatwo przy okazji, ponieważ trzeba się upewnić, że narzędzie analizy porównawczej nie jest wąskim gardłem i że jest w stanie obsłużyć wiele jednoczesnych połączeń. Dlatego dobrym pomysłem jest użycie kilku dedykowanych komputerów do generowania obciążenia.

Answer 2

Z Server.go rutynowa procedura spawn pojawia się w funkcji Serve, gdy połączenie jest akceptowane. Poniżej znajduje się opis: -

// 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

Jeśli używasz żądania xhr, upewnij się, że instancja xhr jest zmienną lokalną. Na przykład xhr = new XMLHttpRequest() jest zmienną globalną. Gdy wykonasz żądanie równoległe z tą samą zmienną xhr, otrzymasz tylko jeden wynik. Tak więc musisz zadeklarować xhr lokalnie, tak jak ten var xhr = new XMLHttpRequest().