From 6693bf74383846fe711610a5d27c69877265b5be Mon Sep 17 00:00:00 2001 From: sk <123456@qq.com> Date: Thu, 24 Oct 2024 10:24:47 +0800 Subject: [PATCH] no message --- dbproxy/main.go | 3 +-- worldsrv/main.go | 3 +-- 2 files changed, 2 insertions(+), 4 deletions(-) diff --git a/dbproxy/main.go b/dbproxy/main.go index 66a8db6..6a39bdf 100644 --- a/dbproxy/main.go +++ b/dbproxy/main.go @@ -12,7 +12,6 @@ import ( _ "mongo.games.com/game" "mongo.games.com/game/common" - "mongo.games.com/game/db" _ "mongo.games.com/game/dbproxy/mq" "mongo.games.com/game/dbproxy/svc" "mongo.games.com/game/model" @@ -42,7 +41,7 @@ func main() { go http.Serve(lis, nil) // grpc 服务 - go db.RunGrpcServer() + //go db.RunGrpcServer() return nil }) diff --git a/worldsrv/main.go b/worldsrv/main.go index 3b18e93..8863182 100644 --- a/worldsrv/main.go +++ b/worldsrv/main.go @@ -12,7 +12,6 @@ import ( _ "mongo.games.com/game" "mongo.games.com/game/common" - "mongo.games.com/game/db" "mongo.games.com/game/model" "mongo.games.com/game/mq" ) @@ -30,7 +29,7 @@ func main() { core.LoadPackages("config.json") // core hook core.RegisteHook(core.HOOK_BEFORE_START, func() error { - db.NewGrpcClientConn() + //db.NewGrpcClientConn() model.StartupRPClient(common.CustomConfig.GetString("MgoRpcCliNet"), common.CustomConfig.GetString("MgoRpcCliAddr"), time.Duration(common.CustomConfig.GetInt("MgoRpcCliReconnInterV"))*time.Second) mq.StartConsumer(common.CustomConfig.GetString("RabbitMQURL"), common.CustomConfig.GetString("RMQExchange"), true) mq.StartPublisher(common.CustomConfig.GetString("RabbitMQURL"), common.CustomConfig.GetString("RMQExchange"), true, common.CustomConfig.GetInt("RMQPublishBacklog"))