Go语言分布式限流方案_Golang Redis滑动窗口实现-Golang-PHP中文网

滑动窗口在分布式系统中必须用redis而非本地内存，因为本地计数器（如sync.map或atomic.int64）仅限单机，多实例会各自维护独立计数，彻底丧失全局限流意义；redis凭借原子性与全局可见性成为硬性前提，且必须用lua脚本或redis 6.2+的incrbyex等原子命令，禁用非原子的incr+expire组合，否则窗口内计数可能超发。

go语言分布式限流方案_golang redis滑动窗口实现

滑动窗口为什么必须用 Redis 而不是本地内存

本地计数器（比如 sync.Map 或 atomic.Int64）在单机场景下能跑通，但分布式系统里多个 Go 实例会各自维护一套计数，完全失去限流意义。Redis 的原子性 + 全局可见性是硬性前提——哪怕你只部署两台服务，也得切到 Redis。

注意：不要用 INCR + EXPIRE 分两步操作，这是经典竞态漏洞。必须用 Lua 脚本或 Redis 6.2+ 的 INCRBYEX 原子命令，否则窗口内计数可能超发。

用 `INCRBYEX` 实现滑动窗口的最小可行代码

Go 客户端推荐 github.com/redis/go-redis/v9，它原生支持 INCRBYEX（Redis >= 6.2）。关键不是“怎么写”，而是参数含义容易错：

key 必须带用户/接口维度标识，例如 "rate:uid:123:api:/order/create"，不能只用 "rate:api"
increment 固定填 1，别传变量
expiry 是窗口总时长（秒），不是“剩余过期时间”；比如 1 分钟窗口就传 60，Redis 会自动按首次写入时间对齐
返回值是本次递增后的累计值，需立刻跟阈值比对，不能先 GET 再判断

示例片段：

ctx := context.Background()
key := "rate:uid:" + uid + ":api:" + path
val, err := rdb.IncrByEX(ctx, key, 1, 60).Result()
if err != nil && !errors.Is(err, redis.Nil) {
    return false, err
}
return val 

<h3>时间精度陷阱：为什么 1 秒窗口实际会漂移</h3>
<p>Redis 的 <code>INCRBYEX</code> 按 key 首次写入时间作为窗口起点，后续所有请求都基于这个时间戳计算是否过期。这意味着：</p><div class="aritcle_card flexRow artxards">
											<div class="artcardd flexRow">
												<a class="aritcle_card_img" rel="nofollow" href="/xiazai/skill6460" title="Golang Naming"><img
														src="https://img.php.cn/upload/skill/000/000/081/179094616043400.jpg" alt="Golang Naming" onerror="this.onerror='';this.src='/static/lhimages/moren/morentu.png'" ></a>
												<div class="aritcle_card_info flexColumn">
													<a rel="nofollow" href="/xiazai/skill6460" title="Golang Naming" class="overflowclass">Golang Naming</a>
													<p class="overflowclass">Go（Golang）命名规范 — 包括包、构造函数、结构体、接口、常量、枚举、错误、布尔值、接收器、getter/setter、函数等。</p>
												</div>
												<a rel="nofollow" href="/xiazai/skill6460" title="Golang Naming" class="aritcle_card_btn flexRow flexcenter"><b></b><span>下载</span>
												</a>
											</div>
										</div>

第一个请求在 12:00:00.123 到达 → 窗口是 [12:00:00.123, 12:01:00.123)
第二个请求在 12:00:00.888 到达 → 还在同一个窗口内，但你预期的“整秒对齐”并不存在

如果业务强依赖整秒/整分钟对齐（比如监控报表），得放弃 INCRBYEX，改用 Lua 脚本手动分片：把 60 秒拆成 60 个 1 秒 key，用 ZSET 或 HASH 存各秒计数，再 ZREMRANGEBYSCORE 清过期段。复杂度陡增，非必要不碰。