生产环境推荐100ms滑动窗口切片——在捕获亚秒级抖动与控制内存/写入开销间取得平衡；QPS超10k可选200ms，但禁用1s以免P99延迟被单次慢请求拉偏500ms以上。
滑动窗口时间切片怎么选：1s 还是 100ms？
延迟统计对窗口粒度敏感，太粗（如 5s）会掩盖毛刺，太细（如 10ms）则内存和写入压力陡增。生产环境推荐 100ms 切片 —— 它在精度（能捕获亚秒级抖动）和开销（每分钟仅 600 个桶）间取得平衡。若服务 QPS 超 10k，可考虑 200ms；但绝对不要用 1s，否则 99%ile 延迟可能被单次慢请求拉偏 500ms 以上。
关键点：
-
time.Now().UnixNano()是纳秒级，但窗口计算必须对齐到切片边界，例如ts / 100_000_000 * 100_000_000（100ms = 10⁸ ns） - 避免用
time.Truncate()，它依赖本地时钟单调性，在容器或虚拟机中可能因时钟漂移导致窗口错位 - 切片长度建议设为
600（覆盖 1 分钟），过长（如 3600）会让冷数据长期占内存且无业务意义
如何原子更新延迟桶而不锁整个窗口？
用 sync/atomic 操作单个桶的计数器和延迟总和，比 sync.RWMutex 锁整个结构体快 3–5 倍。每个桶定义为：
type latencyBucket struct {
count uint64
sumMs uint64 // 累计毫秒，避免浮点运算
maxMs uint64
}
更新时只对当前桶做原子加法：
立即学习“go语言免费学习笔记（深入）”；
bucket := w.buckets[idx]
atomic.AddUint64(&bucket.count, 1)
atomic.AddUint64(&bucket.sumMs, ms)
if ms > atomic.LoadUint64(&bucket.maxMs) {
atomic.StoreUint64(&bucket.maxMs, ms)
}
注意：
Golang Uber Dig
下载
使用 uber-go/dig 在 Golang 中实现依赖注入——基于反射容器，提供 Provide/Invoke、dig.In/dig.Out 参数与结果对象，支持命名依赖等
- 不能直接赋值
w.buckets[idx] = bucket，Go 中结构体赋值会拷贝，原子操作失效 -
maxMs的更新不是严格原子的（先读再存有竞态），但统计场景允许少量误差，强一致性反而拖慢吞吐 - 如果需精确
minMs，改用atomic.CompareAndSwapUint64循环尝试，但实际极少需要
窗口滚动时怎么清理过期桶？避免 GC 压力
不主动清零或重建数组，而是用双指针维护有效范围：w.head 指向最老有效桶，w.tail 指向最新桶。每次写入前检查是否要移动 head：
now := time.Now().UnixNano()
oldestTs := now - int64(w.duration.Nanoseconds())
oldIdx := int((oldestTs / w.sliceNs) % w.size)
if oldIdx < 0 { oldIdx += w.size }
if w.head != uint64(oldIdx) {
// 重置从 head 到 oldIdx-1 的所有桶（仅计数器和 sum，不清 maxMs）
for i := w.head; i != uint64(oldIdx); i = (i + 1) % uint64(w.size) {
atomic.StoreUint64(&w.buckets[i].count, 0)
atomic.StoreUint64(&w.buckets[i].sumMs, 0)
}
w.head = uint64(oldIdx)
}
重点：
- 绝不调用
make([]latencyBucket, ...)频繁分配新切片，这会触发 GC 频繁扫描 -
maxMs不重置 —— 它代表该窗口周期内历史最大值，滚动后自然被新数据覆盖，无需干预 - 如果
w.duration = 60s且w.sliceNs = 100_000_000，那么w.size必须是 600，否则取模计算会越界
计算 P99 延迟时为什么不能简单遍历所有桶？
桶内延迟分布未知，直接按桶计数累加会高估 P99。正确做法是：先算总请求数 N，再定位第 0.99 * N 个请求落在哪个桶，最后用该桶的 maxMs 作为上界（保守估计）或结合桶内线性插值（需额外记录直方图）。
简化版（生产常用）：
total := uint64(0)
for i := 0; i < w.size; i++ {
total += atomic.LoadUint64(&w.buckets[i].count)
}
target := uint64(float64(total) * 0.99)
cnt := uint64(0)
for i := 0; i < w.size; i++ {
c := atomic.LoadUint64(&w.buckets[i].count)
cnt += c
if cnt >= target && c > 0 {
return atomic.LoadUint64(&w.buckets[i].maxMs)
}
}
return 0
坑点：
- 没加
&& c > 0判断会导致返回空桶的maxMs（初始为 0），P99 突然归零 - 桶索引顺序必须和时间顺序一致，否则
cnt累加失去意义；用(w.head + i) % w.size动态计算真实索引 - 如果总请求数
< 100，0.99 * N可能为 0，此时应返回最小非零桶的maxMs，而非默认 0
滑动窗口最难的不是实现，而是让每个桶的语义清晰：它不存原始样本，只存聚合态；不追求数学精确，而保障可观测性不崩溃。一旦开始纠结 P99 的毫秒级误差，就该检查是不是该上专用指标系统了。
