diff --git a/src/server/cluster/cluster_func.go b/src/server/cluster/cluster_func.go index 5108b1eb..5f6d63d8 100644 --- a/src/server/cluster/cluster_func.go +++ b/src/server/cluster/cluster_func.go @@ -74,7 +74,7 @@ func ClusterJoin(a *Agent, m *msg.Msg) error { return nil } log.Debug("ClusterJoin ServerId %v", clusterJoin.ServerId) - connectRemote(clusterJoin.RemoteAddr, clusterJoin.ServerId, "server") + //connectRemote(clusterJoin.RemoteAddr, clusterJoin.ServerId, "server") return nil } @@ -104,6 +104,7 @@ func connectRemote(RemoteAddr string, ConnType int, ConnLabel string) error { client.Start() Center = client clients = append(clients, client) + log.Debug("connet remote to addr:%s", RemoteAddr) return nil } diff --git a/src/server/game/message_mgr.go b/src/server/game/message_mgr.go index 27e4987d..10158eed 100644 --- a/src/server/game/message_mgr.go +++ b/src/server/game/message_mgr.go @@ -379,7 +379,7 @@ func NewWorkerPool(workers, maxQueue int) *WorkerPool { } pool.start() // 启动监控协程,负责动态扩缩容 - pool.monitorTick = time.NewTicker(500 * time.Millisecond) + pool.monitorTick = time.NewTicker(3000 * time.Millisecond) go pool.monitor() return pool }