如何在 Go 中利用 singleflight 解决热点数据的缓存击穿-Golang-PHP中文网

singleflight通过请求合并缓解缓存击穿：同一key的并发请求共享一次后端调用，其余等待结果；但它不替代缓存，需配合显式缓存写入与稳定key设计。

如何在 go 中利用 singleflight 解决热点数据的缓存击穿

为什么 `singleflight` 能缓解缓存击穿

缓存击穿本质是：某个 key 过期瞬间，大量并发请求同时发现缓存 miss，全部穿透到后端（DB 或 RPC），造成瞬时压力激增。singleflight 不是缓存，而是“请求合并”机制——它让同一时刻对相同 key 的所有 goroutine 共享一次真实后端调用，其余等待其结果，天然避免重复查询。

注意：singleflight 本身不存储数据、不处理过期、不自动回填缓存。它必须和你自己的缓存逻辑（如 map、redis）配合使用，否则每次请求仍会触发一次后端调用。

典型误用：把 `singleflight.Do` 当成缓存用

常见错误是只调用 singleflight.Do("user:123", fetchFromDB)，但没在 fetchFromDB 内部写入缓存。结果下次请求依然 cache miss，又进 Do，形成“单次防重但不防下次”的假象。

singleflight.Do 只保证「本次 key 的并发请求只执行一次函数」，不保证「下次请求能命中缓存」
必须在 fetchFromDB 成功后，显式写入本地缓存（如 sync.Map）或远程缓存（如 redis.Set）
如果后端调用失败（如 DB timeout），singleflight 默认会把 error 也返回给所有等待者——这可能导致缓存雪崩，需加兜底逻辑（如返回旧值或空结构体）

正确组合：先查缓存 → miss 则 `singleflight.Do` → 成功后双写

标准流程是三层检查：本地内存缓存 → singleflight 合并 → 后端加载 + 回填两级缓存。关键点在于「写入时机」和「key 构造一致性」。

Twitter热点监控与推文生成

每小时自动在推特搜索中国、加密货币、国际热点、美国热点、特朗普等话题的热度信息，提取前十热点，依据 X 平台真实算法权重（开源代码数据）为每个热点生成高曝光推文或线程。用户提及“推特热点”“Twitter热点”“推特搜索”“热点推文”“生成推文”“社交媒体监控”“Twitter监控”等关键词时触发。

下载

示例片段：

func GetUser(ctx context.Context, id string) (*User, error) {
    // 1. 先查本地缓存（比如 sync.Map）
    if u, ok := localCache.Load("user:" + id); ok {
        return u.(*User), nil
    }

    // 2. 使用 singleflight，key 必须和缓存 key 一致（否则无法复用）
    v, err, _ := sg.Do("user:"+id, func() (interface{}, error) {
        // 3. 真实加载：这里应包含 redis.Get + fallback 到 DB
        u, err := loadFromDB(id)
        if err != nil {
            return nil, err
        }
        // 4. 关键：成功后立即写入本地 & 远程缓存
        localCache.Store("user:"+id, u)
        redisClient.Set(ctx, "user:"+id, u, time.Minute*10)
        return u, nil
    })
    if err != nil {
        return nil, err
    }
    return v.(*User), nil
}