为什么主服务器 goroutine 在处理传入请求时会有这样的延迟，如何避免这种延迟？

没有延迟的简单代码

package main
import (
    "log"
    "net/http"
)
func main() {
    http.HandleFunc("/", root)
    http.ListenAndServe(":8090", nil)
}
//---------------------------------------------------------------------------
//  http handlers
//---------------------------------------------------------------------------
func root(w http.ResponseWriter, r *http.Request) {
    log.Printf("[root] `%v`\n", r.URL.Path)
    w.Write([]byte("What the hell"))
}

加载测试结果

    ╰─➤  wrk -d20s -t5 -c100 http://localhost:8090
Running 20s test @ http://localhost:8090
  5 threads and 100 connections
  Thread Stats   Avg      Stdev     Max   +/- Stdev
    Latency    17.07ms   46.63ms 368.77ms   91.73%
    Req/Sec    10.99k     4.87k   24.48k    62.49%
  1038912 requests in 20.10s, 128.80MB read
Requests/sec:  51684.63
Transfer/sec:      6.41MB

添加协程

package main
import (
    "log"
    "net/http"
)
func main() {
    _ = NewTesterGo(100)

    http.HandleFunc("/", root)
    http.ListenAndServe(":8090", nil)
}
//---------------------------------------------------------------------------
//  http handlers
//---------------------------------------------------------------------------
func root(w http.ResponseWriter, r *http.Request) {
    log.Printf("[root] `%v`\n", r.URL.Path)
    w.Write([]byte("What the fuck"))
}

//---------------------------------------------------------------------------
//  tester segment
//---------------------------------------------------------------------------
type (
    TesterGo struct {
        Work chan string
    }
)

func NewTesterGo(count int) *TesterGo {
    t:=&TesterGo{
        Work:make(chan string,100),
    }
    for ; count > 0 ; count -- {
        go t.Worker()
    }
    return t

}
func (t *TesterGo) Worker() {
    log.Printf("[testergo][worker][work] стартовал....\n")
    for {
        select {
        case work := <-t.Work:
            log.Printf("[testerGo][Worker] %v\n", work)
        default:
        }
    }
}

加载结果

╰─➤  wrk -d20s -t5 -c100 http://localhost:8090
Running 20s test @ http://localhost:8090
  5 threads and 100 connections
  Thread Stats   Avg      Stdev     Max   +/- Stdev
    Latency   464.71ms  305.44ms   1.90s    77.90%
    Req/Sec    54.62     43.74   200.00     67.50%
  3672 requests in 20.05s, 466.17KB read
  Socket errors: connect 0, read 0, write 0, **timeout 97**
Requests/sec:    **183.11**
Transfer/sec:     23.25KB

最佳答案

您的 goroutines 使用 default，如果 channel 中没有任何内容(您的示例中也没有)，它们会立即旋转。这可能会使 Go 的调度程序执行比需要更多的上下文切换，并且可能会白白消耗大量 CPU。

是否有理由在循环中默认？如果没有，请尝试以下操作之一:

要么没有默认值，goroutines 将简单地“休眠”直到有工作。

 for {
        select {
        case work := <-t.Work:
            log.Printf("[testerGo][Worker] %v\n", work)
        }
    }

这个 BTW 使选择完全多余，所以干脆去掉它:

 for { //you can also use a range on the channel
     work := <- t.Work 
     log.Printf("[testerGo][Worker] %v\n", work)
 }

第二个选项 - 一个超时，让他们在继续循环之前等待:

 for {
        select {
        case work := <-t.Work:
            log.Printf("[testerGo][Worker] %v\n", work)

        case <- time.After(100*time.Millisecond): //or whatever you prefer

        }
    }

关于go - 在后台使用 goroutines 的 http 并发延迟，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/39250051/