并发下获取数据防止缓存穿透的 golang 库
go get github.com/lvwxx/go-cache-fetchcache 客户端以 redis 为例
import (
cf "github.com/lvwxx/go-cache-fetch"
cc "github.com/lvwxx/go-cache-fetch/cache_client"
redis "github.com/go-redis/redis/v8"
)
cacheCli := cc.NewRedis(redis.Client)
cache := cf.NewCache(cacheCli, "prefix")
// 优先从缓存中获取数据，如果缓存中没有，从 db 中获取数据并存入缓存，返回获取的值
ok, err := cache.Fetch(ctx, "cacheKey", &result, "time.Minute", func() (interface{}, error) {
return getDataFromDB()
})
// reslut 就是最后获取到的值如果使用其他缓存客户端，只要实现 CacheClient 的接口即可。
type CacheClient interface {
Get(ctx context.Context, key string) string
Set(ctx context.Context, key string, value interface{}, ex time.Duration) error
Del(ctx context.Context, key string) error
}使用 singleflight.Group 来防止缓存穿透，在缓存失效时，同一时间高并发下只会有 1 个 DB 的请求，从而减小 DB 的瞬时压力。