Fix redis pub/sub connection

lingmiaotech · Feb 8, 2018 · 5e99016 · 5e99016
1 parent 13f38ba
commit 5e99016
Showing 1 changed file with 10 additions and 6 deletions.
diff --git a/redis/redis.go b/redis/redis.go
@@ -34,11 +34,13 @@ func GetPub() *redis.Client {
 	host := configs.GetString("redis.host")
 	port := configs.GetInt("redis.port")
 	db := configs.GetInt("redis.db")
+	password := configs.GetDynamicString("redis.password")
 
 	PubClient := redis.NewClient(&redis.Options{
-		Addr:     fmt.Sprintf("%s:%d", host, port),
-		Password: "",
-		DB:       db,
+		Addr:       fmt.Sprintf("%s:%d", host, port),
+		Password:   password,
+		DB:         db,
+		MaxRetries: 3,
 	})
 
 	return PubClient
@@ -48,11 +50,13 @@ func GetSub() *redis.Client {
 	host := configs.GetString("redis.host")
 	port := configs.GetInt("redis.port")
 	db := configs.GetInt("redis.db")
+	password := configs.GetDynamicString("redis.password")
 
 	SubClient := redis.NewClient(&redis.Options{
-		Addr:     fmt.Sprintf("%s:%d", host, port),
-		Password: "",
-		DB:       db,
+		Addr:       fmt.Sprintf("%s:%d", host, port),
+		Password:   password,
+		DB:         db,
+		MaxRetries: 3,
 	})
 
 	return SubClient