diff --git a/common/config/config.go b/common/config/config.go index 6b7181ee81efbbea843c5679ec3c4c7070c080eb..b390d45e0fbdfbaa4792457adba9ce6226dc1925 100644 --- a/common/config/config.go +++ b/common/config/config.go @@ -17,6 +17,10 @@ func AppIsRelease() bool { return GetMode() == RELEASE } +func AppIsLocal() bool { + return GetMode() == LOCAL +} + //数据库的配置 type MysqlConfig struct { MYSQL_HOST string diff --git a/main.go b/main.go index 03ae8f19be845e57b3c9b174eef49eeedda49444..0da8243c939993eba91b081129a906e743274fdb 100644 --- a/main.go +++ b/main.go @@ -504,6 +504,10 @@ const ( ) func RegisterToRedis(RedisClusterClient *redis.Client, port int, init bool) { + // 本地不注册 + if appConfig.AppIsLocal() { + return + } if RedisClusterClient == nil { failMsg := fmt.Sprintf("RegisterToRedis fail,redisClusterNotInit,serviceName:%v", RegisterName) _ = dingding.SendDingRobot(dingding.ROBOTWEBHOOK, failMsg, true) @@ -522,7 +526,7 @@ func RegisterToRedis(RedisClusterClient *redis.Client, port int, init bool) { if err := RedisClusterClient.ZAdd(context.Background(), redisKey, &redis.Z{ Score: float64(time.Now().Unix()), Member: ipPort, - }); err != nil { + }).Err(); err != nil { failMsg := fmt.Sprintf("RegisterToRedis fail,redis fail,err:%v,serviceName:%v", err, RegisterName) mylogrus.MyLog.Errorf(failMsg) _ = dingding.SendDingRobot(dingding.ROBOTWEBHOOK, failMsg, true)