diff --git a/src/dbmanager/redismanager/redismanager.go b/src/dbmanager/redismanager/redismanager.go index 31234d495b8b919256870c410f03985d81237d9c..cff88ace8f1208d0b43a45347a119134bd14904b 100644 --- a/src/dbmanager/redismanager/redismanager.go +++ b/src/dbmanager/redismanager/redismanager.go @@ -15,6 +15,7 @@ package redismanager import ( + "context" "crypto/tls" "time" @@ -50,19 +51,20 @@ func RedisInit(redisConn, redisPwd string, defaultDB int, dialTimeout time.Durat } global_redis = redis.NewClient(cfg) + timeoutCtx, cancelFunc := context.WithTimeout(context.Background(), dialTimeout) // 使用超时上下文,验证redis go func() { <-stopCh global_redis.Close() + cancelFunc() klog.Warning("global_redis success exit") }() - // timeoutCtx, cancelFunc := context.WithTimeout(context.Background(), dialTimeout) - // defer cancelFunc() - // _, err := global_redis.Ping(timeoutCtx).Result() - // if err != nil { - // return err - // } + defer cancelFunc() + _, err := global_redis.Ping(timeoutCtx).Result() + if err != nil { + return err + } DialTimeout = dialTimeout EnableRedis = enableRedis return nil