From 136cb43cd1f718512201d47330f391ad83f6dbb5 Mon Sep 17 00:00:00 2001
From: Gordon <1432970085@qq.com>
Date: Tue, 31 May 2022 12:07:06 +0800
Subject: [PATCH] redis replace go redis

---
 pkg/common/db/model.go | 17 +++++++++++------
 1 file changed, 11 insertions(+), 6 deletions(-)

diff --git a/pkg/common/db/model.go b/pkg/common/db/model.go
index 6e2c9614a..6d1660807 100644
--- a/pkg/common/db/model.go
+++ b/pkg/common/db/model.go
@@ -30,7 +30,7 @@ type DataBases struct {
 	mgoSession  *mgo.Session
 	redisPool   *redis.Pool
 	mongoClient *mongo.Client
-	rdb         *go_redis.ClusterClient
+	rdb         *go_redis.Client
 }
 
 func key(dbAddress, dbName string) string {
@@ -114,12 +114,17 @@ func init() {
 			)
 		},
 	}
-
-	DB.rdb = go_redis.NewClusterClient(&go_redis.ClusterOptions{
-		Addrs:    []string{config.Config.Redis.DBAddress},
-		PoolSize: 100,
-		Password: config.Config.Redis.DBPassWord,
+	DB.rdb = go_redis.NewClient(&go_redis.Options{
+		Addr:     config.Config.Redis.DBAddress,
+		Password: config.Config.Redis.DBPassWord, // no password set
+		DB:       0,                              // use default DB
+		PoolSize: 100,                            // 连接池大小
 	})
+	//DB.rdb = go_redis.NewClusterClient(&go_redis.ClusterOptions{
+	//	Addrs:    []string{config.Config.Redis.DBAddress},
+	//	PoolSize: 100,
+	//	Password: config.Config.Redis.DBPassWord,
+	//})
 	ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
 	defer cancel()
 	_, err = DB.rdb.Ping(ctx).Result()