Golang如何进行HTTP负载测试_Golang HTTP负载测试实践

package main
<p>import (
"fmt"
"net/http"
"sync"
"time"
)</p><p>func main() {
url := "<a href="https://www.php.cn/link/1633b2e8d8d39ecaf5fd05fd16b4ffd0">https://www.php.cn/link/1633b2e8d8d39ecaf5fd05fd16b4ffd0</a>"
totalRequests := 1000
concurrency := 10
var wg sync.WaitGroup
var mu sync.Mutex
var success, failed int
var latencies []int64</p><pre class='brush:php;toolbar:false;'>start := time.Now()

for i := 0; i < concurrency; i++ {
    wg.Add(1)
    go func() {
        defer wg.Done()
        client := &http.Client{Timeout: 10 * time.Second}
        for j := 0; j < totalRequests/concurrency; j++ {
            reqStart := time.Now()
            resp, err := client.Get(url)
            latency := time.Since(reqStart).Milliseconds()
            mu.Lock()
            latencies = append(latencies, latency)
            if err != nil {
                failed++
            } else {
                if resp.StatusCode == 200 {
                    success++
                } else {
                    failed++
                }
                resp.Body.Close()
            }
            mu.Unlock()
        }
    }()
}

wg.Wait()
elapsed := time.Since(start).Seconds()

fmt.Printf("总请求数: %d\n", totalRequests)
fmt.Printf("成功: %d, 失败: %d\n", success, failed)
fmt.Printf("耗时: %.2f秒\n", elapsed)
fmt.Printf("QPS: %.2f\n", float64(totalRequests)/elapsed)

// 计算平均延迟
var totalLatency int64
for _, l := range latencies {
    totalLatency += l
}
fmt.Printf("平均响应时间: %d ms\n", totalLatency/int64(len(latencies)))

go install github.com/adjust/go-wrk@latest

go-wrk -n 1000 -c 50 -t 4 http://localhost:8080/api/data