如何在Golang中实现服务限流_服务限流策略说明
技术百科
P粉602998670
发布时间:2026-01-19
浏览: 次 直接用 golang.org/x/time/rate,它基于线程安全的令牌桶,支持突发流量且经生产验证;不支持分布式限流,跨实例需结合 Redis 或专用服务。
Go 限流选 golang.org/x/time/rate 还是自己写?
直接用 golang.org/x/time/rate,别自己造轮子。它基于令牌桶(token bucket),线程安全、内存开销低、支持突发流量,且已被大量生产服务验证。自己实现容易在并发场景下漏判或误限(比如未加锁的计数器、时钟漂移导致的桶重置异常)。
注意:它不支持分布式限流,单机有效;若需跨实例统一限流(如 API 网关),得配

redis-cell 模块)或专用限流服务。
rate.Limiter 的三个关键参数怎么设?
初始化 rate.NewLimiter 时传入两个核心参数:limit rate.Limit(每秒令牌数)和 burst int(桶容量)。第三个参数是可选的 clock,一般不用动。
-
limit = 100表示长期平均速率 ≤ 100 QPS;但瞬时可能达到burst级别(比如burst = 200,允许短时 200 并发请求) -
burst必须 ≥ 1,且建议 ≥limit(否则桶太小,刚填充就耗尽,失去平滑作用) - 若想严格硬限流(不允许任何突发),设
burst = 1,但会显著降低用户体验——例如连续两次 HTTP 请求大概率第二次被拒
limiter := rate.NewLimiter(rate.Limit(50), 100) // 平均 50 QPS,最多容忍 100 次瞬时请求
HTTP 中间件里怎么正确调用 Wait 或 AllowN?
别在 handler 开头无脑 limiter.Wait(r.Context())——它会阻塞直到拿到令牌,对超时敏感的接口(如移动端心跳)可能拖垮整个请求链路。优先用非阻塞的 AllowN 做预检。
- 用
AllowN(time.Now(), n)判断能否立即执行n次操作(如单次请求算 1 次) - 返回
false时立刻返回http.StatusTooManyRequests,不进业务逻辑 - 注意时间戳必须用
time.Now(),不要复用旧时间,否则会导致令牌计算偏差
func rateLimitMiddleware(next http.Handler) http.Handler {
return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
if !limiter.AllowN(time.Now(), 1) {
http.Error(w, "too many requests", http.StatusTooManyRequests)
return
}
next.ServeHTTP(w, r)
})
}
为什么压测时发现限流没生效?常见漏点
限流失效往往不是库的问题,而是使用姿势不对:
- 把
rate.Limiter声明在 handler 函数内 → 每次请求新建一个 limiter,完全没效果 - 在中间件里每次
http.Request都 new 一个 limiter → 同上,作用域错 - 没考虑不同路由/用户维度的差异化限流(如 /login 接口应比 /public/data 更宽松),而只用了全局单例 limiter
- 测试时用
curl串行发请求 → 实际并发不足,看不出限流效果;要用ab -n 1000 -c 200或hey -z 10s -q 50 -c 100
真正复杂的场景(按用户 ID 限流、分层限流、动态配额)需要封装自己的限流管理器,用 sync.Map 存不同 key 对应的 *rate.Limiter,并加 TTL 清理闲置条目——这点最容易被忽略,跑几天后 map 不释放会内存泄漏。
# ai
# redis
# go
# golang
# curl
# 路由
# 并发请求
# 为什么
# red
# 封装
# 作用域
# 中间件
# lua
# 分布式
相关栏目:
<?muma
$count = M('archives')->where(['typeid'=>$field['id']])->count();
?>
【
AI推广<?muma echo $count; ?>
】
<?muma
$count = M('archives')->where(['typeid'=>$field['id']])->count();
?>
【
SEO优化<?muma echo $count; ?>
】
<?muma
$count = M('archives')->where(['typeid'=>$field['id']])->count();
?>
【
技术百科<?muma echo $count; ?>
】
<?muma
$count = M('archives')->where(['typeid'=>$field['id']])->count();
?>
【
谷歌推广<?muma echo $count; ?>
】
<?muma
$count = M('archives')->where(['typeid'=>$field['id']])->count();
?>
【
百度推广<?muma echo $count; ?>
】
<?muma
$count = M('archives')->where(['typeid'=>$field['id']])->count();
?>
【
网络营销<?muma echo $count; ?>
】
<?muma
$count = M('archives')->where(['typeid'=>$field['id']])->count();
?>
【
案例网站<?muma echo $count; ?>
】
<?muma
$count = M('archives')->where(['typeid'=>$field['id']])->count();
?>
【
精选文章<?muma echo $count; ?>
】
相关推荐
- MySQL 中使用 IF 和 CASE 实现查询字
- Win11怎么更改系统语言_Win11中文语言包下
- Win11怎么退出高对比度模式_Win11取消反色
- Win11怎么设置虚拟桌面 Win11新建多桌面切
- Win11怎么关闭键盘按键音_Win11禁用打字声
- Windows蓝屏错误0x0000002C怎么解决
- LINUX怎么进行文本内容搜索_Linux gre
- Win11如何设置环境变量 Win11添加和修改系
- Win10电脑C盘红了怎么清理_Windows10
- Win11怎么设置快速访问主页_Windows11
- 如何在Golang中编写异步函数测试_Golang
- PowerShell怎么创建复杂的XML结构
- MAC如何安装Git版本控制工具_MAC开发环境配
- Python邮件系统自动化教程_批量发送解析与模板
- Win11怎么用设置清理回收站_Win11设置清理
- Win11怎么关闭内容自适应亮度_Windows1
- c++怎么使用std::unique实现去重_c+
- C++中的constexpr和const有什么区别
- c++中的可变参数模板(variadic temp
- Windows 11登录时提示“用户配置文件服务登
- Windows如何查看和管理已安装的字体?(字体文
- C++中的std::shared_from_thi
- Go 语言标准库为何不提供泛型切片的 Contai
- PythonDocker高级项目部署教程_多容器管
- php485返回数据不完整怎么办_php485数据
- Windows怎样关闭开始菜单推荐广告_Windo
- Windows10系统怎么查看系统版本_Win10
- Python与OpenAI接口集成实战_生成式AI
- Win11怎么设置麦克风权限_允许应用访问Win1
- Win11怎么关闭定位服务_保护Win11位置隐私
- Windows蓝屏错误0x00000018怎么处理
- Python装饰器设计思路_功能增强机制说明【指导
- 如何使用Golang sort排序切片_Golan
- Windows怎样拦截WPS弹窗广告_Window
- Win10如何优化内存使用_Win10内存优化技巧
- Mac如何与安卓手机传文件_Mac和Android
- Win11怎么关闭触控板_Win11笔记本禁用触摸
- Windows10如何更改任务栏高度_Win10解
- 如何在Golang中写入JSON文件_保存结构体数
- Windows如何设置登录时的欢迎屏幕背景?(锁屏
- php在Linux怎么部署_LNMP环境搭建PHP
- Windows10无法连接到Internet_Wi
- c++如何用AFL++进行模糊测试 c++ Fuz
- 如何在Golang中实现CI/CD流水线自动化测试
- php485能和物联网模块通信吗_php485对接
- 如何使用Golang处理静态文件缓存_提高页面加载
- Windows家庭版如何开启组策略(gpedit.
- Windows10任务栏图标变成白色文件_Win1
- Windows10系统更新错误0x80070002
- Windows10如何更改桌面图标间距_Win10

QQ客服