diff --git a/common/config/config.go b/common/config/config.go
index c7742866444683314262222b550e0a9b853dc11c..67baa4eeccbdbc35cf2ed614dcd527b9ee46917c 100644
--- a/common/config/config.go
+++ b/common/config/config.go
@@ -26,8 +26,10 @@ type MysqlCodeConfig struct {
 
 //redis配置
 type RedisConfig struct {
-	REDIS_HOST     string
-	REDIS_PASSWORD string
+	REDIS_HOST             string
+	REDIS_PASSWORD         string
+	REDIS_CLUSTER_HOST     string
+	REDIS_CLUSTER_PASSWORD string
 }
 
 //jwt
diff --git a/common/redisCli/redis.go b/common/redisCli/redis.go
index b55ab0e6d88e94175a2eccb618b7bb0465eb0e40..a2b1e3dc0ef28d6cda4991ae826c7720b14d1428 100644
--- a/common/redisCli/redis.go
+++ b/common/redisCli/redis.go
@@ -8,52 +8,27 @@ import (
 	"log"
 )
 
-var RedisClient *redis.Client
-
-var RedisClient1 *redis.Client
+var RedisCluster *redis.Client
 
 func init() {
-	RedisClient = redis.NewClient(&redis.Options{
-		Addr:         config.GetConfigRedis().REDIS_HOST,
-		Password:     config.GetConfigRedis().REDIS_PASSWORD, // no password set
-		DB:           0,                                      // use default DB
-		PoolSize:     2000,
-		MinIdleConns: 200,
-	})
-	mylogrus.MyLog.Infoln(config.GetConfigRedis().REDIS_HOST)
-	mylogrus.MyLog.Infoln(config.GetConfigRedis().REDIS_PASSWORD)
-	pong, err := RedisClient.Ping(context.Background()).Result()
-	if err != nil {
-		mylogrus.MyLog.Warn(err)
-		mylogrus.MyLog.Fatal("redis db0 connect fail")
-	} else {
-		mylogrus.MyLog.Info("redis db0 connection success - ", pong)
-	}
-
-	RedisClient1 = redis.NewClient(&redis.Options{
-		Addr:         config.GetConfigRedis().REDIS_HOST,
-		Password:     config.GetConfigRedis().REDIS_PASSWORD, // no password set
-		DB:           1,                                      // use default DB
+	RedisCluster = redis.NewClient(&redis.Options{
+		Addr:         config.GetConfigRedis().REDIS_CLUSTER_HOST,
+		Password:     config.GetConfigRedis().REDIS_CLUSTER_PASSWORD, // no password set
+		DB:           0,                                              // use default DB
 		PoolSize:     200,
 		MinIdleConns: 20,
 	})
-	mylogrus.MyLog.Infoln(config.GetConfigRedis().REDIS_HOST)
-	mylogrus.MyLog.Infoln(config.GetConfigRedis().REDIS_PASSWORD)
-	pong, err = RedisClient1.Ping(context.Background()).Result()
+	pong, err := RedisCluster.Ping(context.Background()).Result()
 	if err != nil {
 		mylogrus.MyLog.Warn(err)
-		mylogrus.MyLog.Fatal("redis db1 connect fail")
+		mylogrus.MyLog.Fatal("redis db0 connect fail")
 	} else {
-		log.Println("redis db1 connection success - " + pong)
+		log.Println("redis db0 connection success - " + pong)
 	}
 	// log hook
 	//RedisClient.AddHook(redisHook{})
 }
 
-func GetRedis() *redis.Client {
-	return RedisClient
-}
-
-func GetRedis1() *redis.Client {
-	return RedisClient1
+func GetRedisCluster() *redis.Client {
+	return RedisCluster
 }
diff --git a/common/redisCli/util.go b/common/redisCli/util.go
deleted file mode 100644
index cfa5becfd8d561e19e26530856e1068cea945818..0000000000000000000000000000000000000000
--- a/common/redisCli/util.go
+++ /dev/null
@@ -1,56 +0,0 @@
-package redisCli
-
-import (
-	"context"
-	"hilo-micCenter/common/mylogrus"
-	"strconv"
-	"time"
-)
-
-//这个用户避免多个服务器并发问题。
-func SetNX(key string, value interface{}, expiration time.Duration, callBack func()) {
-	flag, err := RedisClient.SetNX(context.Background(), key, value, expiration).Result()
-	if err != nil {
-		mylogrus.MyLog.Errorf("key:%v lock start setNx err: %v", key, err)
-	}
-	if !flag {
-		mylogrus.MyLog.Infof("key:%v lock setNx has lock", key)
-		return
-	}
-	mylogrus.MyLog.Infof("key:%v lock setNx begin", key)
-	callBack()
-	//执行结束之后，移除key
-	//RedisClient.Del(context.Background(), key)
-	mylogrus.MyLog.Infof("key:%v lock setNx end", key)
-}
-
-//setNx没有，结束后，没有移除
-/*func SetNxNoDel(key string, value interface{}, expiration time.Duration, callBack func()) {
-	flag, err := RedisClient.SetNX(context.Background(), key, value, expiration).Result()
-	if err != nil {
-		mylogrus.MyLog.Errorf("key:%v lock start setNx err: %v", key, err)
-	}
-	if !flag {
-		mylogrus.MyLog.Infof("key:%v lock setNx has lock", key)
-		return
-	}
-	mylogrus.MyLog.Infof("key:%v lock setNx begin", key)
-	callBack()
-	mylogrus.MyLog.Infof("key:%v lock setNx end", key)
-}*/
-
-func ClearExpired(key string, expireSec int64) error {
-	return GetRedis().ZRemRangeByScore(context.Background(), key,
-		"0", strconv.FormatInt(time.Now().Unix()-expireSec, 10)).Err()
-}
-
-func Lock(key string, expiration time.Duration) bool {
-	flag, err := RedisClient.SetNX(context.Background(), key, 1, expiration).Result()
-	if err != nil {
-		return false
-	}
-	if !flag {
-		return false
-	}
-	return true
-}
diff --git a/debug.ini b/debug.ini
index 696fef9c6411a031fdf849389161d0c75fa3b4d4..fc7ab8fef6dbc5bac298ff1a56ed4406590e1207 100644
--- a/debug.ini
+++ b/debug.ini
@@ -11,6 +11,8 @@ MYSQL_DB=hilo_code
 [REDIS]
 REDIS_HOST=47.244.34.27:6379
 REDIS_PASSWORD=8QZ9JD1zLvPR3yHf
+REDIS_CLUSTER_HOST=47.244.34.27:6379
+REDIS_CLUSTER_PASSWORD=8QZ9JD1zLvPR3yHf
 [JWT]
 SECRET=hilo1632
 ISSUER_API=hiloApi
diff --git a/local.ini b/local.ini
index 65d129829059055cba01617aaed3c857c77bbbc0..f97ca1a49dcae3dc950cd582cc3521bb6710e6b1 100644
--- a/local.ini
+++ b/local.ini
@@ -11,6 +11,8 @@ MYSQL_DB=hilo_code
 [REDIS]
 REDIS_HOST=47.244.34.27:6379
 REDIS_PASSWORD=8QZ9JD1zLvPR3yHf
+REDIS_CLUSTER_HOST=47.244.34.27:6379
+REDIS_CLUSTER_PASSWORD=8QZ9JD1zLvPR3yHf
 [JWT]
 SECRET=hilo1632
 ISSUER_API=hiloApi
diff --git a/main.go b/main.go
index 896226db1e75be18963903708d28c60b9a386226..4491e3366996e531ca939af491c89a52d2aa6ebf 100644
--- a/main.go
+++ b/main.go
@@ -44,7 +44,7 @@ func check() {
 	for {
 		select {
 		case <-tick.C:
-			l, err := redisCli.GetRedis().LLen(context.Background(), micInfoChange).Result()
+			l, err := redisCli.GetRedisCluster().LLen(context.Background(), micInfoChange).Result()
 			if err != nil {
 				mylogrus.MyLog.Errorf("cron micChangeSys msg error,left %v-%v", l, err)
 			}
@@ -65,7 +65,7 @@ func check() {
 func deal() {
 	for true {
 		//不需要加锁，注意，阻塞。
-		strs, err := redisCli.GetRedis().BLPop(context.Background(), time.Second, micInfoChange).Result()
+		strs, err := redisCli.GetRedisCluster().BLPop(context.Background(), time.Second, micInfoChange).Result()
 		if err != nil {
 			if err != redis.Nil {
 				mylogrus.MyLog.Errorf("cron micChangeSys redisCli.GetRedis().BLPop err:+%v", err)
@@ -127,7 +127,7 @@ func SendSignalMsg(groupId string, msg GroupSystemMsg) {
 
 		if err = tencentyun.SendSystemMsg(logger, groupId, []string{}, str); err != nil {
 			mylogrus.MyLog.Errorf("cron micChangeSys SendSignalMsg sync failed for %s, msgId = %d, content:%v, err:%+v", groupId, msg.MsgId, str, err)
-			content := fmt.Sprintf("腾讯云推送失败,content:%v,err:%v", str, err.Error())
+			content := fmt.Sprintf("腾讯云推送失败,group:%v,msgId:%v,err:%v", groupId, msg.MsgId, err.Error())
 			if err := dingding.SendDingRobot(dingding.ROBOTWEBHOOK, content, true); err != nil {
 				mylogrus.MyLog.Errorf("cron micChangeSys SendSignalMsg send dingding fail%s", err.Error())
 			}
diff --git a/release.ini b/release.ini
index 5897408046dcb6cff6e8a098d0ef2ab8c0d6de4e..0b67f890443379f88fe319b7362a4b64fe8b9d53 100644
--- a/release.ini
+++ b/release.ini
@@ -11,6 +11,8 @@ MYSQL_DB=hilo_code
 [REDIS]
 REDIS_HOST=r-eb3btxn8vfdsuwdbuf.redis.dubai.rds.aliyuncs.com:6379
 REDIS_PASSWORD=
+REDIS_CLUSTER_HOST=r-eb3yt6k8zgxs62kjjs.redis.dubai.rds.aliyuncs.com:6379
+REDIS_CLUSTER_PASSWORD=
 [JWT]
 SECRET=hilo1504
 ISSUER_API=hiloApi