golang框架在高并发场景中的稳定性保障

package main

import (
    "context"
    "fmt"
    "sync"

    "github.com/gin-gonic/gin"
)

type Counter struct {
    sync.Mutex
    count int
}

func main() {
    r := gin.Default()
    counter := &Counter{}

    r.GET("/increment", func(c *gin.Context) {
        counter.Lock()
        defer counter.Unlock()
        counter.count++
        c.JSON(200, gin.H{"count": counter.count})
    })

    ctx, cancel := context.WithCancel(context.Background())
    defer cancel()

    // HTTP サーバーの起動
    go func() {
        if err := r.Run(); err != nil {
            fmt.Println("HTTP サーバーの実行中にエラーが発生しました:", err)
        }
    }()

    // ロードシミュレーション
    for i := 0; i < 100; i++ {
        go func() {
            for {
                select {
                case <-ctx.Done():
                    return
                default:
                    c, err := http.Get("http://localhost:8080/increment")
                    if err != nil {
                        fmt.Println("リクエストの送信中にエラーが発生しました:", err)
                    } else {
                        _ = c.Body.Close()
                    }
                }
            }
        }()
    }

    // 10 秒後にロードシミュレーションを停止
    time.Sleep(10 * time.Second)

    cancel()
}