我正在使用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处理当前请求结束.