Golang 实现基于 Redis 的滑动窗口统计-Golang-PHP中文网

滑动窗口不能只用ZREMRANGEBYSCORE清旧数据，因ZSET不保证原子性：清理与计数分离会导致并发插入漏判超限；必须用Lua脚本将ZREMRANGEBYSCORE、ZCARD和ZADD三步封装为原子操作。

golang 实现基于 redis 的滑动窗口统计

滑动窗口为什么不能只用 `ZSET` 的 `ZREMRANGEBYSCORE` 清理旧数据

因为 Redis 的 ZSET 本身不保证原子性滑动——ZADD 和 ZREMRANGEBYSCORE 是两个独立命令，中间可能插入其他请求，导致窗口内数据短暂膨胀或漏统计。更关键的是：如果清理操作失败（比如网络中断、Redis 拒绝写入），旧数据会残留，后续统计就失真。

真正可靠的滑动窗口必须把「添加新条目 + 清理过期条目」封装成一个原子动作。Go 客户端直接调用两个命令做不到这点，得靠 Lua 脚本。

实操建议：

写一个 Lua 脚本，接收窗口时长（如 60 秒）、当前时间戳（unix timestamp）、key 前缀，然后在脚本里完成 ZADD + ZREMRANGEBYSCORE + ZCARD 三步
用 redis.Script.Load().Run() 执行，确保原子性
不要把时间戳生成逻辑放在 Lua 里（redis.call('TIME') 返回的是秒+微秒，精度高但跨节点可能不一致），统一由 Go 传入 time.Now().Unix()

如何用 `go-redis` 正确加载并执行滑动窗口 Lua 脚本

很多人直接拼接字符串传 Lua，结果遇到转义、参数类型错位、返回值解析错误。核心是：Lua 脚本里的 KEYS[1] 对应 Go 调用时的第 1 个 key 参数，ARGV[i] 对应第 i 个 interface{} 参数，且 go-redis 会自动把 Go 的 int64、string 映射为 Lua 的 number/string，但 nil 会变成 false，容易误判。

示例脚本（保存为 sliding_window.lua）：

local key = KEYS[1]
local now = tonumber(ARGV[1])
local window = tonumber(ARGV[2])
local score = now
local min_score = now - window
<p>redis.call('ZADD', key, score, score)
redis.call('ZREMRANGEBYSCORE', key, '-inf', min_score - 1)
return redis.call('ZCARD', key)</p>

Go 端调用方式：

script := redis.NewScript(luaContent)
count, err := script.Run(ctx, rdb, []string{"rate:login:192.168.1.1"}, time.Now().Unix(), int64(60)).Int64()

注意点：

Sentinal Redis

监控Redis服务器健康状况、内存、性能及BullMQ队列。检查队列深度、失败任务，分析慢查询并诊断问题。

下载

KEYS 必须是非空字符串切片，哪怕只有一个 key；ARGV 中的 int64 会被正确传入 Lua，不用转 string
返回值用 .Int64() 获取，不是 .Result() —— 后者返回 (interface{}, error)，需手动类型断言
如果脚本里用了 redis.call('EXISTS', ...) 判断 key 是否存在，记得在 Go 里用 .Bool() 接收

`ZSET` 成员值该存什么：时间戳就够了，别存冗余字段

常见误区是存 ZADD rate:login:ip 1672531200 "1672531200:uuid4" 这种带结构的字符串，以为方便 debug 或扩展。其实完全没必要——滑动窗口只关心数量，不关心具体哪次请求；而且成员值在 ZCARD 统计时根本没用，纯属浪费内存和序列化开销。

正确做法就是让 score 和 member 都等于当前时间戳：

ZADD rate:login:192.168.1.1 1672531200 1672531200

这样做的好处：

节省约 40% 内存（避免重复存储时间戳+额外字符串）
避免 member 字符串过长导致 ZADD 命令变慢（Redis 对大 value 有性能惩罚）
万一要查具体记录（比如审计），直接用 ZRANGE rate:login:192.168.1.1 -10 -1 WITHSCORES 就能拿到最近 10 次的时间戳