package main
<p>import (
"net/http"
"net/http/httptest"
"testing"
)</p><p>func MyHandler(w http.ResponseWriter, r *http.Request) {
w.WriteHeader(http.StatusOK)
w.Write([]byte("Hello, World!"))
}</p><p>func BenchmarkMyHandler(b *testing.B) {
req := httptest.NewRequest("GET", "<a href="https://www.php.cn/link/0175d23af8e2d1e2bbdce27998c98aeb">https://www.php.cn/link/0175d23af8e2d1e2bbdce27998c98aeb</a>", nil)
recorder := httptest.NewRecorder()
handler := http.HandlerFunc(MyHandler)</p><pre class='brush:php;toolbar:false;'>b.ResetTimer()
for i := 0; i < b.N; i++ {
    handler.ServeHTTP(recorder, req)
}

}

package main
<p>import (
"fmt"
"net/http"
"sync"
"time"
)</p><p>func main() {
url := "<a href="https://www.php.cn/link/d6686469a29701048799005b5ebb1529">https://www.php.cn/link/d6686469a29701048799005b5ebb1529</a>"
totalRequests := 1000
concurrency := 50
var wg sync.WaitGroup
client := &http.Client{Timeout: 10 * time.Second}
var mu sync.Mutex
var success, failure int</p><pre class='brush:php;toolbar:false;'>start := time.Now()

for i := 0; i < concurrency; i++ {
    wg.Add(1)
    go func() {
        defer wg.Done()
        for j := 0; j < totalRequests/concurrency; j++ {
            req, _ := http.NewRequest("GET", url, nil)
            resp, err := client.Do(req)
            mu.Lock()
            if err != nil || resp.StatusCode != http.StatusOK {
                failure++
            } else {
                success++
            }
            mu.Unlock()
            if err == nil {
                resp.Body.Close()
            }
        }
    }()
}

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

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

}