Go高并发需限流熔断防雪崩：官方rate包适合单机粗粒度限流但易配置错误；gobreaker实现标准熔断器需合理设阈值；uber-go/ratelimit提供更精准漏桶限流；分布式场景必须用Redis+Lua滑动窗口限流，注意key设计与降级策略。
Go 服务在高并发下不加限流和熔断，轻则响应变慢、超时堆积，重则雪崩崩溃。标准库不提供开箱即用的限流/熔断组件，必须依赖第三方库或手写逻辑，但选型不当或配置错误极易失效。
用 golang.org/x/time/rate 做简单请求速率限制
这是 Go 官方维护的令牌桶实现，适合单机、低精度、无状态的 QPS 控制。它不跨进程同步，也不感知下游健康状况，仅适用于网关层或内部轻量 API 的粗粒度防护。
常见错误是把 rate.Limiter 实例定义成全局变量却未做并发保护——它本身是线程安全的，但误以为要加锁反而引入竞争；另一个坑是设置 burst 过大（比如等于 qps * 5），导致突发流量瞬间打穿后端。
-
rate.NewLimiter(10, 5)表示平均 10 QPS，最多允许 5 个请求“借支”（burst） - 用
limiter.Wait(ctx)阻塞等待令牌，或limiter.Allow()非阻塞判断 - 不要在 HTTP handler 中直接对每个请求调用
Wait后再处理业务逻辑——若后端慢，令牌会持续被占住，实际吞吐远低于预期
用 sony/gobreaker 实现熔断器
这是最轻量且符合 Circuit Breaker 模式规范的 Go 熔断库。它不绑定任何传输协议，只关注失败率、超时、连续错误数等信号，适合包装数据库调用、RPC 或 HTTP client。
立即学习“go语言免费学习笔记（深入）”；
典型误用是把熔断阈值设得太激进：比如 MaxRequests: 1 + Interval: 0，会导致每次失败都立即熔断，失去容错弹性；或者完全忽略 Timeout 字段，让半开状态永远不触发试探请求。
- 推荐配置：
MaxRequests: 10,Interval: 60 * time.Second,Timeout: 30 * time.Second - 必须用
cb.Execute(func() (interface{}, error) { ... })包裹可能失败的操作，不能只靠外部判断 err 再手动调用cb.OnSuccess()/cb.OnError() - 熔断器状态变更（如
StateOpen→StateHalfOpen）不会自动重试，需在StateHalfOpen下由业务主动发起试探性调用
用 uber-go/ratelimit 替代官方 rate 包做更精准的单机限流
当需要严格平滑限流（比如每秒刚好 100 次，不允许 burst）、或对延迟敏感（如实时音视频信令），uber-go/ratelimit 的漏桶实现比官方 rate 更合适。它的 Take() 方法返回的是“应等待多久”，而非阻塞，便于与 context deadline 协同。
注意它默认不支持多实例共享状态，若部署多个 Pod，需配合 Redis 或 etcd 做分布式限流——此时不应继续用此库，而该换用 go-redsync + Lua 脚本或专门的限流服务。
-
rl := ratelimit.New(100)创建每秒 100 次的漏桶 -
delay := rl.Take()返回距离下次允许执行还需 sleep 的时间，可结合time.Sleep(delay)或用于预估排队延迟 - 它不处理上下文取消，需手动检查
ctx.Err()并提前退出
分布式场景下必须放弃单机限流，改用 Redis + Lua
微服务集群中，单机限流毫无意义。真实生产环境几乎都用 Redis 记录窗口内请求数，靠原子 Lua 脚本完成计数+过期+判断三步操作。Gin 或 Echo 中间件常用 github.com/go-redis/redis/v8 + 自定义脚本实现。
最容易出错的是 key 设计：如果所有请求共用一个 key（如 "global:qps"），就退化成全局锁；如果 key 粒度太细（如带完整 query string），又会导致内存爆炸和缓存击穿。正确做法是按服务名+接口路径+必要标签（如 user_tier）拼接 key，并设置合理 TTL（通常略大于窗口长度）。
以下是一个标准的滑动窗口计数 Lua 脚本示例，用于 60 秒内最多 1000 次请求：
local key = KEYS[1] local window = tonumber(ARGV[1]) local max = tonumber(ARGV[2]) local now = tonumber(ARGV[3])local count = redis.call("ZCOUNT", key, now - window, now) if count >= max then return 0 end
redis.call("ZADD", key, now, now .. ":" .. math.random(10000, 99999)) redis.call("EXPIRE", key, window + 1) return 1
调用时传入 key="limit:svc_user:GET:/api/v1/users"、ARGV={60, 1000, time.Now().Unix()} 即可。别忘了在 Go 里用 script.Load(ctx, rdb).Run(ctx, rdb, keys, args) 执行。
Redis 本身不是限流银弹——如果它响应慢或断连，整个限流逻辑就失效。务必给 Lua 脚本调用设置短 timeout（如 50ms），并准备 fallback 策略（如降级为本地计数或直接拒绝）。
