Golang 结合 Redis 实现滑动窗口限流算法

雨枫姑娘_6714

雨枫姑娘_6714

2026-05-02

344人浏览

原创

不能用 incr + expire 实现滑动窗口,因其为固定窗口、存在断连漏限/误限风险,且无法统计过去n秒内请求;必须用redis zset+lua脚本,并以服务端time命令获取毫秒级时间戳确保原子性与一致性。

golang 结合 redis 实现滑动窗口限流算法

直接用 INCR + EXPIRE 是固定窗口,不是滑动窗口;并发下还可能 panic 或漏限——必须用 Redis ZSET + Lua 脚本,且时间戳必须来自 Redis 服务端。

为什么不能用 INCR + EXPIRE 模拟滑动窗口

这是最常踩的坑:INCR 和 EXPIRE 是两个独立命令,中间一旦断连、超时或服务崩溃,就会导致 key 永久存在(漏限)或永久丢失(误限)。更关键的是,它根本无法回溯「过去 N 秒内」的请求数,只能统计「当前窗口内」——这叫固定窗口,有严重临界突刺问题。

滑动窗口的核心是「时间维度上的连续覆盖」,不是「周期性重置」。比如窗口设为 60 秒,第 59 秒和第 61 秒的请求必须被算进同一个逻辑窗口,而固定窗口会把它们分到两个完全隔离的桶里。

  • 固定窗口:窗口边界硬切,time.Now().Unix() / 60 取整决定归属
  • 滑动窗口:所有请求按真实时间戳存入 ZSET,每次查 ZCOUNT key (now-60) +inf
  • 多实例部署时,各机器本地时间差 > 窗口粒度(如 1 秒),结果直接失效

必须用 Redis 的 TIME 命令获取服务端时间戳

Go 层调 time.Now().Unix() 再传给 Lua,等于把客户端时间当权威——只要两台机器 NTP 同步误差超过窗口长度(比如窗口 1 秒,A 机快 1.2 秒),B 机就会把刚进来的请求判定为「已过期」,而 A 机还在计数,实际 QPS 翻倍也不自知。

Lua 脚本里必须调 redis.call("TIME"),它返回两个整数:[seconds, microseconds],拼成毫秒级时间戳(seconds * 1000 + microseconds / 1000)最稳妥。

redis-tools
redis-tools

按类别查找Redis命令、检测服务器连接、监控键数量和内存占用,支持离线速查表。

下载
  • 别用 redis.call("TIME")[1] 直接当秒级时间——精度不够,1 秒内多次请求会撞 score
  • 别在 Go 层算好时间戳再传入 ARGV——失去原子性前提
  • Redis 服务端时间必须开启 NTP 同步,且误差控制在 100ms 内(建议用 chrony)

Go 调用 Lua 实现限流的最小可靠写法

核心就三件事:清理过期项 → 统计当前窗口请求数 → 写入新请求。全部压进一个 Eval,返回值必须显式转 int64 判断。

示例 Lua 脚本(注意注释里的陷阱):

local key = KEYS[1]
local window_ms = tonumber(ARGV[1])  -- 窗口长度,单位毫秒
local max_req = tonumber(ARGV[2])
local now_ms = tonumber(ARGV[3]) * 1000 + tonumber(ARGV[4]) / 1000  -- 拼毫秒时间戳
local window_start = now_ms - window_ms
<p>-- 1. 清理:删掉 window_start 之前的所有项(注意 -inf 不要加引号)
redis.call("ZREMRANGEBYSCORE", key, "-inf", window_start)</p><p>-- 2. 统计当前窗口请求数
local count = redis.call("ZCARD", key)</p><p>-- 3. 未超限才写入,避免无效 ZADD 拉高内存
if count </p><p>Go 层调用要点:</p>
  • rdb.Eval(ctx, script, []string{key}, windowMs, maxReq, seconds, micros, reqID).Int64()
  • 别用 EXPIRE,老版本 Redis 不支持对已存在 key 多次设过期;PEXPIREAT 设绝对时间更稳
  • reqID 必须全局唯一(如 uuid.NewString()+"-"+strconv.FormatInt(nowMs,10)),防止同分值 member 被覆盖
  • ZSET 不是为高频写优化的结构,单 key 请求量 > 5k/s 时要考虑分片(如 hash(key) % 16)

容易被忽略的存储与性能细节

ZSET 的内存开销比 list 高不少,但它是唯一能按时间范围精准清理+统计的数据结构。list + LPUSH/LRANGE 看似简单,但无法剔除「中间过期项」,只能靠 LTRIM 截断尾部,导致窗口漂移。

真正上线前必须确认:

  • Redis 版本 ≥ 6.0(PEXPIREAT 在 2.6+ 就有,但高并发下旧版 ZSET 性能抖动明显)
  • key 生命周期靠 PEXPIREAT 保障,不是靠业务层定时清理——否则 key 泄露风险极高
  • 如果限流维度是用户 ID,key 命名建议用 sliding:uid:{id},别带冒号以外的特殊字符,避免 Lua 解析出错
  • 测试时一定要模拟时间跳变:用 redis-cli --raw -h x -p y EVAL "return redis.call('TIME')" 0 看服务端时间是否和本地一致

golang免费学习笔记(深入):立即使用
在学习笔记中,你将探索golang的核心概念和高级技巧!

相关文章

PHP速学视频免费教程(入门到精通)
PHP速学视频免费教程(入门到精通)

PHP怎么学习?PHP怎么入门?PHP在哪学?PHP怎么学才快?不用担心,这里为大家提供了PHP速学教程(入门到精通),有需要的小伙伴保存下载就能学习啦!

下载

相关标签:

redis golang

本站声明:本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn

相关专题

更多
Golang 入门学习路线:从零基础到上手开发
Golang 入门学习路线:从零基础到上手开发

Golang 入门路线涵盖从零到上手的核心路径:首先打牢基础语法与切片等底层机制;随后攻克 Go 的灵魂——接口设计与 Goroutine 并发模型;接着通过 Gin 框架与 GORM 深入 Web 开发实战;最后在微服务与云原生工具开发中进阶,旨在培养具备高性能并发处理能力的后端工程师。

2026.02.24

226

7

Golang 疑难杂症解决指南:常见问题排查与优化
Golang 疑难杂症解决指南:常见问题排查与优化

《Golang 疑难杂症解决指南》聚焦开发过程中常见却棘手的问题,从并发模型、内存管理、性能瓶颈到工程化实践逐步拆解。通过真实案例与调试思路,帮助开发者定位问题根因,建立系统化排查方法。不只给出答案,更强调分析路径与工具使用,让你在复杂 Go 项目中具备持续解决问题的能力。

2026.02.24

133

7

Golang 运行与部署实战:从本地到云端
Golang 运行与部署实战:从本地到云端

《Golang 运行与部署实战》围绕 Go 应用从开发完成到稳定上线的完整流程展开,系统讲解编译构建、环境配置、日志与配置管理、容器化部署以及常见运维问题处理。结合真实项目场景,拆解自动化构建与持续部署思路,帮助开发者建立可靠的发布流程,提升服务稳定性与可维护性。

2026.02.24

677

10

Golang 面试题精选:高频问题与解答
Golang 面试题精选:高频问题与解答

Golang 面试题精选》系统整理企业常见 Go 技术面试问题,覆盖语言基础、并发模型、内存与调度机制、网络编程、工程实践与性能优化等核心知识点。每道题不仅给出答案,还拆解背后的设计原理与考察思路,帮助读者建立完整知识结构,在面试与实际开发中都能更从容应对复杂问题。

2026.02.24

238

7

Golang 性能优化专题:提升应用效率
Golang 性能优化专题:提升应用效率

《Golang 性能优化专题》聚焦 Go 应用在高并发与大规模服务中的性能问题,从 profiling、内存分配、Goroutine 调度、GC 机制到 I/O 与锁竞争逐层分析。结合真实案例讲解定位瓶颈的方法与优化策略,帮助开发者建立系统化性能调优思维,在保证代码可维护性的同时显著提升服务吞吐与稳定性。

2026.02.24

477

7

Golang 生态工具与框架:扩展开发能力
Golang 生态工具与框架:扩展开发能力

《Golang 生态工具与框架》系统梳理 Go 语言在实际工程中的主流工具链与框架选型思路,涵盖 Web 框架、RPC 通信、依赖管理、测试工具、代码生成与项目结构设计等内容。通过真实项目场景解析不同工具的适用边界与组合方式,帮助开发者构建高效、可维护的 Go 工程体系,并提升团队协作与交付效率。

2026.02.24

208

7

Golang 并发编程专题:掌握多核时代的核心技能
Golang 并发编程专题:掌握多核时代的核心技能

《Golang 并发编程专题:掌握多核时代的核心技能》系统讲解 Go 在并发领域的设计哲学与实践方法,深入剖析 goroutine、channel、调度模型与并发安全机制,结合真实场景与性能思维,帮助开发者构建高吞吐、低延迟、可扩展的并发程序,全面提升多核时代的工程能力。

2026.02.26

584

7

Golang Web 开发路线:构建高效后端服务
Golang Web 开发路线:构建高效后端服务

《Golang Web 开发路线:构建高效后端服务》围绕 Go 在后端领域的工程实践,系统讲解 Web 框架选型、路由设计、中间件机制、数据库访问与接口规范,结合高并发与可维护性思维,逐步构建稳定、高性能、易扩展的后端服务体系,帮助开发者形成完整的 Go Web 架构能力。

2026.02.26

245

7

Golang 实际项目案例:从需求到上线
Golang 实际项目案例:从需求到上线

《Golang 实际项目案例:从需求到上线》以真实业务场景为主线,完整覆盖需求分析、架构设计、模块拆分、编码实现、性能优化与部署上线全过程,强调工程规范与实践决策,帮助开发者打通从技术实现到系统交付的关键路径,提升独立完成 Go 项目的综合能力。

2026.02.26

62

7

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
phpEnv手册
phpEnv手册

共0课时 | 0人学习