在Go語言中,可以使用goroutine和channel來實現百萬并發請求的處理。以下是一種解決方案的示例:
示例代碼如下:
package main
import (
"fmt"
"net/http"
"sync"
)
func worker(requests <-chan string, results chan<- string, wg *sync.WaitGroup) {
defer wg.Done()
for req := range requests {
resp, err := http.Get(req)
if err != nil {
results <- fmt.Sprintf("Error: %s", err.Error())
} else {
results <- fmt.Sprintf("Response: %s", resp.Status)
}
}
}
func main() {
numWorkers := 100
numRequests := 1000000
requests := make(chan string, numRequests)
results := make(chan string, numRequests)
var wg sync.WaitGroup
wg.Add(numWorkers)
// 啟動工作協程
for i := 0; i < numWorkers; i++ {
go worker(requests, results, &wg)
}
// 填充請求隊列
for i := 0; i < numRequests; i++ {
requests <- "https://example.com"
}
close(requests)
// 等待所有工作協程完成
go func() {
wg.Wait()
close(results)
}()
// 處理結果隊列
for res := range results {
fmt.Println(res)
}
}
該示例中,使用了100個工作協程來處理100萬個并發請求。每個工作協程從請求隊列中獲取一個請求,發送請求并將響應結果放入結果隊列中。主協程等待所有工作協程完成后,從結果隊列中獲取響應結果并輸出。
請注意,該示例中的請求隊列和結果隊列都使用了緩沖通道,以避免阻塞。根據實際情況,你可以根據系統的負載情況調整隊列大小。
此外,你還可以根據實際情況使用連接池、調整超時時間等來優化并發請求的處理。