debug.ini

 [DATABASE]
-MYSQL_HOST=47.244.34.27:3306
-MYSQL_USERNAME=root
-MYSQL_PASSWORD=yX0jPAhO0I4s2zlA
+MYSQL_HOST=hk-cynosdbmysql-grp-a3wqck8p.sql.tencentcdb.com:22303
+MYSQL_USERNAME=hilo_test
+MYSQL_PASSWORD=cPsTMSA9szQ6B9Y2zFXSvpDdduB8kZxC
 MYSQL_DB=hilo
 [DATABASECODE]
-MYSQL_HOST=47.244.34.27:3306
-MYSQL_USERNAME=root
-MYSQL_PASSWORD=yX0jPAhO0I4s2zlA
+MYSQL_HOST=hk-cynosdbmysql-grp-a3wqck8p.sql.tencentcdb.com:22303
+MYSQL_USERNAME=hilo_test
+MYSQL_PASSWORD=cPsTMSA9szQ6B9Y2zFXSvpDdduB8kZxC
 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
+REDIS_HOST=172.19.0.2:6379
+REDIS_PASSWORD=yPyZH1DYMJhrVQgr
+REDIS_CLUSTER_HOST=172.19.0.2:6379
+REDIS_CLUSTER_PASSWORD=yPyZH1DYMJhrVQgr
 [JWT]
 SECRET=hilo1632
 ISSUER_API=hiloApi

local.ini

 [DATABASE]
-MYSQL_HOST=47.244.34.27:3306
-MYSQL_USERNAME=root
-MYSQL_PASSWORD=yX0jPAhO0I4s2zlA
+MYSQL_HOST=hk-cynosdbmysql-grp-a3wqck8p.sql.tencentcdb.com:22303
+MYSQL_USERNAME=hilo_test
+MYSQL_PASSWORD=cPsTMSA9szQ6B9Y2zFXSvpDdduB8kZxC
 MYSQL_DB=hilo
 [DATABASECODE]
-MYSQL_HOST=47.244.34.27:3306
-MYSQL_USERNAME=root
-MYSQL_PASSWORD=yX0jPAhO0I4s2zlA
+MYSQL_HOST=hk-cynosdbmysql-grp-a3wqck8p.sql.tencentcdb.com:22303
+MYSQL_USERNAME=hilo_test
+MYSQL_PASSWORD=cPsTMSA9szQ6B9Y2zFXSvpDdduB8kZxC
 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
+REDIS_HOST=172.19.0.2:6379
+REDIS_PASSWORD=yPyZH1DYMJhrVQgr
+REDIS_CLUSTER_HOST=172.19.0.2:6379
+REDIS_CLUSTER_PASSWORD=yPyZH1DYMJhrVQgr
 [JWT]
 SECRET=hilo1632
 ISSUER_API=hiloApi

main.go

@@ -6,14 +6,11 @@ import (
 	"fmt"
 	"github.com/go-redis/redis/v8"
 	"github.com/golang/protobuf/proto"
-	"github.com/hashicorp/consul/api"
 	"google.golang.org/grpc"
 	"google.golang.org/grpc/keepalive"
 	"google.golang.org/grpc/resolver"
 	"google.golang.org/grpc/resolver/manual"
 	"hilo-socketCenter/common"
-	"hilo-socketCenter/common/consul"
-	"hilo-socketCenter/common/dingding"
 	"hilo-socketCenter/common/mylogrus"
 	"hilo-socketCenter/common/redisCli"
 	"hilo-socketCenter/domain/model/rpc_m"
@@ -43,24 +40,22 @@ var kacp = keepalive.ClientParameters{
 
 // 初始化userCenterClient
 func init() {
-	client, err := api.NewClient(api.DefaultConfig()) //非默认情况下需要设置实际的参数
+	redisKey := fmt.Sprintf("service:userCenter")
+	ipPorts, err := redisCli.GetRedisCluster().ZRangeByScore(context.Background(), redisKey, &redis.ZRangeBy{
+		Min: fmt.Sprintf("%d", time.Now().Add(-time.Second*15).Unix()), // 3倍心跳
+		Max: "+inf",
+	}).Result()
 	if err != nil {
-		mylogrus.MyLog.Fatalln(err)
+		failMsg := fmt.Sprintf("get service fail,svc:%v,err:%v", "userCenter", err)
+		mylogrus.MyLog.Errorf(failMsg)
+	} else if len(ipPorts) > 0 {
 	}
-	cataLog := client.Catalog()
-	if cataLog == nil {
-		mylogrus.MyLog.Fatalln("No catalog.")
-	}
-	addr, err := consul.GetServices(cataLog, "userCenter")
-	if err != nil {
-		mylogrus.MyLog.Fatalln(err)
-	}
-	if len(addr) == 0 {
-		mylogrus.MyLog.Fatalln("No userCenter available.")
+	if len(ipPorts) <= 0 {
+		ipPorts = []string{"127.0.0.1:50040"}
 	}
 
-	addresses := make([]resolver.Address, len(addr))
-	for i, s := range addr {
+	addresses := make([]resolver.Address, len(ipPorts))
+	for i, s := range ipPorts {
 		addresses[i].Addr = s
 		mylogrus.MyLog.Infof("address : %s", s)
 	}
@@ -117,17 +112,15 @@ func check() {
 				mylogrus.MyLog.Infof("cron sendGiftChan msg error,left %v-%v", l, err)
 			}
 			if l > MONITOR_LENGTH {
-				go func() {
-					if sErr := dingding.SendDingRobot(dingding.ROBOTWEBHOOK, fmt.Sprintf("送礼横幅变化通知延迟,队列%s长度:%d", SocketQueueSendGift, l), true); sErr != nil {
-						mylogrus.MyLog.Errorf("dingding msg fail:%v", sErr)
-					}
-				}()
+				mylogrus.MyLog.Infof("送礼横幅变化通知延迟,队列%s长度:%d", SocketQueueSendGift, l)
+				//go func() {
+				//	if sErr := dingding.SendDingRobot(dingding.ROBOTWEBHOOK, fmt.Sprintf("送礼横幅变化通知延迟,队列%s长度:%d", SocketQueueSendGift, l), true); sErr != nil {
+				//		mylogrus.MyLog.Errorf("dingding msg fail:%v", sErr)
+				//	}
+				//}()
 				n, err := redisCli.GetRedisCluster().Del(context.Background(), SocketQueueSendGift).Result()
 				mylogrus.MyLog.Infof("del sendGiftChan msg queue:%v,n:%v,err:%v", SocketQueueSendGift, n, err)
 			}
-			if l > 0 {
-				mylogrus.MyLog.Infof("cron sendGiftChan msg,left %v", l)
-			}
 		}
 	}
 }

protocol/userProxy.proto

@@ -214,6 +214,7 @@ message GlobalGiftBanner {
     uint32 cpLevel = 15; // cp等级
     string receiveUserAvatar = 16;
     uint32 nobleLevel = 17; // 贵族等级
+    string custom_effect_url = 18; // 定制特效url
 }
 
 /* id == 116 横幅的回应，用来测量RTT */

release.ini

 [DATABASE]
-MYSQL_HOST=ua4papc3hmgqf351pbej-rw4rm.rwlb.dubai.rds.aliyuncs.com
-MYSQL_USERNAME=nextvideo
-MYSQL_PASSWORD=ihlUwI4nhi9W88MI
+MYSQL_HOST=172.28.16.44
+MYSQL_USERNAME=hilo_master
+MYSQL_PASSWORD=o8NNd8F7e6On2RqIgOhsy1PsiSxROT3n
 MYSQL_DB=hilo
 [DATABASECODE]
-MYSQL_HOST=ua4papc3hmgqf351pbej-rw4rm.rwlb.dubai.rds.aliyuncs.com
-MYSQL_USERNAME=nextvideo
-MYSQL_PASSWORD=ihlUwI4nhi9W88MI
+MYSQL_HOST=172.28.16.44
+MYSQL_USERNAME=hilo_master
+MYSQL_PASSWORD=o8NNd8F7e6On2RqIgOhsy1PsiSxROT3n
 MYSQL_DB=hilo_code
 [REDIS]
-REDIS_HOST=r-eb3btxn8vfdsuwdbuf.redis.dubai.rds.aliyuncs.com:6379
+REDIS_HOST=172.28.16.31:6379
 REDIS_PASSWORD=
-REDIS_CLUSTER_HOST=r-eb3yt6k8zgxs62kjjs.redis.dubai.rds.aliyuncs.com:6379
+REDIS_CLUSTER_HOST=172.28.16.47:6379
 REDIS_CLUSTER_PASSWORD=
 [JWT]
 SECRET=hilo1504