9

我在玩 go HTTP 包。我想像在 java 中那样并行处理请求。但我做不到。

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

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

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

所以...我的问题，

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

欢迎任何帮助....

福斯卡

4

3 回答 3

21

所有连接都会自动同时处理。每个 TCP 连接（不是请求）都有自己的 goroutine。

在一个使用 http 管道和重用连接的浏览器的世界中，这可能并不总是很好。您的浏览器很可能正在重用一个连接，该连接会使其停止，直到 goroutine 正在处理的当前请求完成。

于 2012-06-25T23:47:57.820 回答
0

要允许运行时支持使用多个操作系统线程，您可能需要通过以下方式设置该数字：

 runtime.GOMAXPROCS(n)

或设置 GOMAXPROCS 环境变量。

要获取可用内核的数量，请使用

 runtime.NumCPU()

所以你经常以

 runtime.GOMAXPROCS(runtime.NumCPU())
于 2013-07-29T18:04:27.907 回答
0

我认为您的浏览器正在等待，因为您没有向它发送响应您的浏览器向 sayHello 发出请求，sayHello 也向 processRequest 发出请求，从您的代码 processRequest 向 sayHello 发送了响应，但 sayHello 没有发送回响应到浏览器。

您可以使用 http.Get 或 http.Post 来调用 processRequest

于 2013-10-06T11:12:49.447 回答