如何用go编程语言处理并行HTTP请求?

Fer*_*sca 9 go

我正在使用go HTTP包.我想像在java中那样并行处理请求.但我不能.

我创建了一个简单的Web服务器,在中间休眠,并意识到每次处理一个请求,所以如果我在浏览器上刷新,第一个请求的过程必须完成,直到第二个请求开始处理,这里是代码:

func main(){

    //Process the http commands
    fmt.Printf("Starting http Server ... ")
    http.Handle("/", http.HandlerFunc(sayHello))
    err := http.ListenAndServe("0.0.0.0:8080", nil)
    if err != nil {
        fmt.Printf("ListenAndServe Error",err)
    }
}

func sayHello(c http.ResponseWriter, req *http.Request) {
    fmt.Printf("New Request\n")
    processRequest(c, req)
}

func processRequest(w http.ResponseWriter, req *http.Request){
    time.Sleep(time.Second*3)
    w.Write([]byte("Go Say’s Hello(Via http)"))
    fmt.Println("End")
}
Run Code Online (Sandbox Code Playgroud)

由于我想并行处理两个请求,我在"sayHello"函数中的"processRequest(c,req)"之前添加了"go"命令,以便处理不同gorutine中的每个请求.但是......它不起作用......我不知道为什么.我知道这两个请求都已处理,因为我在控制台看到了打印的行,但浏览器一直在等待信息.....并且没有显示我的回复.

那么......我的问题,

每个请求都会创建一个新的http.ResponseWriter吗?或它使用相同?您知道如何指示Web服务器使用不同的线程处理每个请求吗?

欢迎任何帮助....

Fersca

Ste*_*erg 21

所有连接都会自动同时处理.每个TCP连接(不是请求)都有自己的goroutine.

在具有http流水线和重用连接的浏览器的世界中,这可能并不总是很好.很可能你的浏览器正在重用一个连接,这个连接会停止它,直到goroutine处理当前请求结束.