我有一个 Go 程序,它从多个 goroutine 生成大量 HTTP 请求。运行一段时间后,程序报错:connect:cannot allocaterequestedaddress。
当检查时netstat
,我得到大量 (28229) 个连接TIME_WAIT
.
数量众多TIME_WAIT
当 goroutine 数量为 3 时,socket 就会发生,当 goroutine 数量为 5 时,严重程度足以导致崩溃。
我在 docker 下运行 Ubuntu 14.4,go 版本 1.7
这就是 Go 程序。
package main
import (
"io/ioutil"
"log"
"net/http"
"sync"
)
var wg sync.WaitGroup
var url="http://172.17.0.9:3000/";
const num_coroutines=5;
const num_request_per_coroutine=100000
func get_page(){
response, err := http.Get(url)
if err != nil {
log.Fatal(err)
} else {
defer response.Body.Close()
_, err =ioutil.ReadAll(response.Body)
if err != nil {
log.Fatal(err)
}
}
}
func get_pages(){
defer wg.Done()
for i := 0; i < num_request_per_coroutine; i++{
get_page();
}
}
func main() {
for i:=0;i<num_coroutines;i++{
wg.Add(1)
go get_pages()
}
wg.Wait()
}
这是服务器程序:
package main
import (
"fmt"
"net/http"
"log"
)
var count int;
func sayhelloName(w http.ResponseWriter, r *http.Request) {
count++;
fmt.Fprintf(w,"Hello World, count is %d",count) // send data to client side
}
func main() {
http.HandleFunc("/", sayhelloName) // set router
err := http.ListenAndServe(":3000", nil) // set listen port
if err != nil {
log.Fatal("ListenAndServe: ", err)
}
}