如何在 Go 中最大化並發 HTTP 請求？

如何有效地「最大化」並發 HTTP 請求？

在嘗試 Go 的效能時，您可能會在嘗試並發執行大量 HTTP 請求時遇到限制。本文探討了所面臨的挑戰，並提供了最大並發性的解決方案。

問題

您最初的方法涉及啟動大量 goroutine 並行發送 HTTP 請求，期望它們利用所有可用的 CPU。但是，由於檔案描述符限制，您會遇到錯誤。

解決方案

要克服這些限制，請考慮以下方法：

• 使用有界信號量通道來控制並發： 實現一個緩衝通道作為信號量，限制並發請求的數量。透過調整通道緩衝區大小和調整 GOMAXPROCS，您可以最佳化系統的並發性。
• 透過排程器利用工作池： 採用工作池模式，將請求排隊到通道中。調度程序填充通道，而一組工作人員一次處理一個請求。這種方法可確保維持最大並發請求數。
• 利用專用的消費者 Goroutine 來處理回應：為了避免阻塞請求處理，請使用專用的 Goroutine 來消費來自 Worker 的回應水池。這可確保連續執行請求，使您的系統能夠處理更多並發請求。

最佳化程式碼

以下是包含這些最佳化的程式碼的修改版本：

package main

import (
    "fmt"
    "net/http"
    "runtime"
    "sync"
    "time"
)

var (
    reqs       int
    concurrent int
    work       chan *http.Request
    results    chan *http.Response
)

func init() {
    reqs = 1000000
    concurrent = 200
}

func main() {
    runtime.GOMAXPROCS(runtime.NumCPU())
    work = make(chan *http.Request, concurrent)
    results = make(chan *http.Response)
    start := time.Now()

    // Create a semaphore channel to limit concurrency
    sem := make(chan struct{}, concurrent)

    // Create a dispatcher to populate the work channel
    go func() {
        for i := 0; i  <p>透過調整並發變數並觀察結果，您可以確定係統的最佳並發級別，「最大化」其並發HTTP 的能力請求。 </p>

以上是如何在 Go 中最大化並發 HTTP 請求？的詳細內容。更多資訊請關注PHP中文網其他相關文章！