From 3967a2557694551189486cfdded201e6d7cf27a9 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=9E=97=E7=8E=A0=E4=BA=BA?= Date: Wed, 10 Jul 2024 10:19:23 +0800 Subject: [PATCH] fix: redis ping close MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Signed-off-by: 林玠人 --- src/dbmanager/redismanager/redismanager.go | 14 ++++++++------ 1 file changed, 8 insertions(+), 6 deletions(-) diff --git a/src/dbmanager/redismanager/redismanager.go b/src/dbmanager/redismanager/redismanager.go index 31234d49..cff88ace 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 -- Gitee