修改缓存驱动,第二个参数支持选择不同的缓存配置

This commit is contained in:
ayflying
2025-08-21 10:30:43 +08:00
parent 0628882533
commit 27435b57b7
2 changed files with 22 additions and 12 deletions

View File

@@ -7,19 +7,22 @@ import (
"github.com/gogf/gf/v2/os/gctx"
)
var adapterRedisClient gcache.Adapter
var adapterRedisCache = gcache.New()
var adapterRedisClient = make(map[string]gcache.Adapter)
var adapterRedisCache = make(map[string]*gcache.Cache)
func NewAdapterRedis() gcache.Adapter {
if adapterRedisClient == nil {
_cfg, _ := g.Cfg().Get(gctx.New(), "redis.default")
func NewAdapterRedis(name string) gcache.Adapter {
if adapterRedisClient[name] == nil {
_cfg, err := g.Cfg().Get(gctx.New(), "redis."+name)
if err != nil {
panic("当前redis配置不存在")
}
var cfg *gredis.Config
_cfg.Scan(&cfg)
redisObj, _ := gredis.New(cfg)
//adapterRedisClient = gcache.NewAdapterRedis(g.Redis("default"))
adapterRedisClient = gcache.NewAdapterRedis(redisObj)
adapterRedisCache.SetAdapter(adapterRedisClient)
//adapterRedisClient[name] = gcache.NewAdapterRedis(g.Redis(name))
adapterRedisClient[name] = gcache.NewAdapterRedis(redisObj)
adapterRedisCache[name] = gcache.New()
adapterRedisCache[name].SetAdapter(adapterRedisClient[name])
}
return adapterRedisCache
return adapterRedisCache[name]
}