漏桶在Go中需惰性计算水位：每次Allow()按时间差×纳秒级速率更新水量，用atomic.Int64管理lastCheck（纳秒时间戳）和water，避免锁与ticker，确保恒速输出、无突发。
Leaky Bucket 在 Go 中的核心实现逻辑
Go 标准库没有内置 leakybucket，但用 time.Ticker + 原子计数器就能准确模拟漏桶行为：桶以恒定速率“漏”（即允许请求通过），新请求到达时先检查当前水量是否超过容量。关键不是“加水时判断”，而是“每次漏出后重置可用额度”——这决定了它比令牌桶更平滑、更难突发。
常见错误是把漏桶写成“每秒重置一次计数器”，这实际是滑动窗口；真正的漏桶必须持续匀速漏出，哪怕请求间隔不规则。
- 桶容量用
int64配合atomic操作，避免锁开销 - 漏速单位统一为“请求/纳秒”，便于
time.Since()计算漏出量 - 不依赖 goroutine 持续驱动 ticker，而是在每次
Allow()时按时间差计算应漏掉多少，更节省资源且无竞态
如何用 time.Since() 动态计算漏水量
每次调用 Allow() 时，先算距上次操作过了多久，再乘以漏速，得到本次可释放的请求数。这是漏桶“自适应”的核心：空闲越久，积压额度越多；连续高频请求则很快触顶。
示例片段：
func (lb *LeakyBucket) Allow() bool {
now := time.Now()
elapsed := now.Sub(lb.lastCheck)
leak := int64(elapsed.Nanoseconds()) * lb.rateNanos // rateNanos = 1e9 / capacityPerSecond
lb.water = max(0, lb.water-leak)
lb.lastCheck = now
<pre class="brush:php;toolbar:false;">if lb.water < lb.capacity {
lb.water++
return true
}
return false}
注意：rateNanos 是预计算好的常量（如每秒 100 请求 → rateNanos = 1e7），避免每次浮点除法；max 要自己定义，标准库没提供 int64 版。
Go 配置库，使用 spf13/viper — 分层优先级（flag > env >file > KV > default），提供 BindPFlag/BindPFlags、SetEnvPrefix + SetEnvKeyReplace 等功能。
并发安全必须用 atomic.Store/Load，不能只锁 water 字段
仅对 water 加互斥锁不够：lastCheck 和 water 必须原子性读写，否则在高并发下可能用旧时间戳计算漏水量，导致超额放行。
正确做法是把两个字段打包进一个结构体，用 atomic.Value 存储指针，或直接用 atomic.LoadInt64/atomic.StoreInt64 分别管理（推荐后者，更轻量）：
-
water用atomic.Int64 -
lastCheck用atomic.Int64存纳秒时间戳（time.Now().UnixNano()） - 读取时先取时间戳，再取水量，顺序不能反
若用 sync.Mutex，吞吐会掉 3–5 倍，尤其在 GOMAXPROCS > 1 时明显。
为什么不用 channel 或 ticker 实现“实时漏”
有人尝试起 goroutine 每 10ms 向 channel 发一个“漏信号”，再从 channel 消费来减水量。这看似直观，但引入三类问题：
- channel 容量有限，突发空闲后恢复时，漏信号堆积造成延迟响应
- goroutine 调度不可控，实际漏速波动大，违背“恒定速率”前提
- 每个桶都要占一个 goroutine，百万连接就百万 goroutine，内存和调度开销爆炸
真正可靠的漏桶，是“按需计算”，不是“按时驱动”。所有状态都在内存里，Allow() 是纯 CPU 操作，无阻塞、无唤醒、无上下文切换。
漏桶最难把握的是初始水位和速率单位换算——漏速设错 10%，长期下来误差会累积放大，建议上线前用 time.AfterFunc 写个校准 routine，每分钟打一次真实漏出量快照。
