配置连接redis集群

Author: mumushuiding

config.json

@@ -11,6 +11,7 @@
   "DbPassword": "123",
   "DbMaxIdleConns": "5",
   "DbMaxOpenConns": "100",
+  "RedisCluster": "false",
   "RedisHost": "localhost",
   "RedisPort": "6379",
   "RedisPassword": ""

k8s.yaml

@@ -49,8 +49,15 @@ spec:
           - name: DbUser
             value: root
           - name: DbPassword
-            value: "123
-            "
+            value: "123"
+          - name: RedisCluster # 是否是redis集群 
+            value: "true"
+          - name: RedisHost
+            value: redis-service   # redis 集群ip
+          - name: RedisPort
+            value: "6379"
+          - name: RedisPassword
+            value: ""
 ---
 apiVersion: networking.istio.io/v1alpha3
 kind: Gateway

workflow-config/config.go

@@ -22,6 +22,7 @@ type Configuration struct {
 	DbPassword     string
 	DbMaxIdleConns string
 	DbMaxOpenConns string
+	RedisCluster   string
 	RedisHost      string
 	RedisPort      string
 	RedisPassword  string

workflow-engine/model/redis.go

@@ -8,14 +8,25 @@ import (
 )
 
 // RedisClient redis客户端
-var RedisClient *redis.Client
+var RedisClient *redis.ClusterClient
 
 // SetRedis 设置redis
 func SetRedis() {
 	var err error
 	fmt.Println("-------启动redis--------")
-	RedisClient = redis.NewClient(&redis.Options{
-		Addr:     conf.RedisHost + ":" + conf.RedisPort,
+	// if conf.RedisCluster == "true" {
+	// 	RedisClient = redis.NewClusterClient(&redis.ClusterOptions{
+	// 		Addrs:    []string{conf.RedisHost + ":" + conf.RedisPort},
+	// 		Password: conf.RedisPassword,
+	// 	})
+	// }else {
+	// 	RedisClient = redis.NewClient(&redis.Options{
+	// 		Addr:     conf.RedisHost + ":" + conf.RedisPort,
+	// 		Password: conf.RedisPassword,
+	// 	})
+	// }
+	RedisClient = redis.NewClusterClient(&redis.ClusterOptions{
+		Addrs:    []string{conf.RedisHost + ":" + conf.RedisPort},
 		Password: conf.RedisPassword,
 	})
 	pong, err := RedisClient.Ping().Result()