如何在 Go 中实现 HTTP 请求的并发限速和排队-Golang-PHP中文网

rate.limiter不能直接限制并发数，它基于令牌桶控制单位时间调用次数；要控制瞬时并发数，应设填充速率为0、桶容量为最大并发数，如rate.newlimiter(0, 5)。

如何在 go 中实现 http 请求的并发限速和排队

用 `rate.Limiter` 控制并发请求数量

Go 标准库的 golang.org/x/time/rate 提供了轻量、线程安全的限速器，适合控制 HTTP 请求的**瞬时并发数**（即同时发出的请求数），而不是每秒请求数（QPS）。关键在于用 rate.NewLimiter 初始化一个令牌桶，并在每次发请求前调用 limiter.Wait 阻塞等待可用令牌。

常见错误是把 rate.Limit 设为 1 以为能串行化，但实际它只限制“填充速率”，真正控制并发的是桶容量（第二个参数）：

limiter := rate.NewLimiter(rate.Every(time.Second), 5) // 每秒最多 5 个请求，但允许突发最多 5 个
// ❌ 错误：这样不能限制并发，只限制平均速率
// ✅ 正确：要控并发，应设填充速率为 0，桶容量即最大并发数
limiter := rate.NewLimiter(0, 5) // 瞬时最多 5 个请求，不自动补充令牌

桶容量（如 5）就是你允许的最大并发请求数，超出会阻塞
填充速率为 0 表示令牌不自动恢复，适合严格并发控制；若需“带缓冲的节流”，可设非零值（如 rate.Every(200 * time.Millisecond)）
每个 goroutine 调用 limiter.Wait(ctx) 时，若无令牌则挂起，直到有空位 —— 这天然形成排队效果

用带缓冲 channel 实现显式排队与超时丢弃

仅靠 rate.Limiter 无法优雅处理排队超时或主动拒绝过载请求。这时需要一层显式队列，典型做法是用带缓冲的 chan struct{} 做信号槽，配合 select 实现非阻塞尝试或带超时的等待。

场景举例：你最多容忍 100 个请求排队，超时 3 秒还没轮到就直接返回错误：

queue := make(chan struct{}, 100)
// 启动一个消费者 goroutine 持续取任务
go func() {
    for range queue {
        // 实际发 HTTP 请求
        resp, err := http.DefaultClient.Do(req)
        // 处理 resp/err...
    }
}()
<p>// 发起请求前尝试入队（带超时）
select {
case queue </p>