package main
import (
"log"
"net"
"net/http"
"sync"
)
func main() {
// 创建一个WaitGroup对象，用于记录并发请求的数量
var wg sync.WaitGroup
// 创建一个Mutex对象，用于保证并发安全
var mu sync.Mutex
// 定义HTTP请求处理函数
handler := func(w http.ResponseWriter, r *http.Request) {
if r.URL.Path == "/index" && r.Method == "GET" {
// 加锁，确保并发安全
mu.Lock()
// 如果并发请求的数量已经超过限制，返回错误码
if wg.Len() >= 500 {
http.Error(w, "Too Many Requests", http.StatusTooManyRequests)
// 解锁，释放锁资源
mu.Unlock()
return
}
// 增加并发请求数量
wg.Add(1)
// 解锁，释放锁资源
mu.Unlock()
defer wg.Done()
}
// 正常处理请求
w.Write([]byte("Hello, world!"))
}
// 创建一个HTTP服务器，监听在localhost:8080地址上
listener, err := net.Listen("tcp", ":8080")
if err != nil {
log.Fatal(err)
}
defer listener.Close()
server := http.Server{
Handler: http.HandlerFunc(handler),
}
// 启动HTTP服务器
err = server.Serve(listener)
if err != nil {
log.Fatal(err)
}
}
这就没啥讲的， /index get 接口的请求并发最大500个超出即返回， 每个氢气处理完成，会进行回收
