From 2b5f0e099face20be8e680b4ca3954c5a6947849 Mon Sep 17 00:00:00 2001
From: hahwu <31872165+hahwu@users.noreply.github.com>
Date: Tue, 30 Dec 2025 16:35:59 +0800
Subject: [PATCH] =?UTF-8?q?=E8=BF=9E=E6=8E=A5=E4=BC=98=E5=8C=96?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/server/cluster/cluster_func.go | 3 ++-
 src/server/game/message_mgr.go     | 2 +-
 2 files changed, 3 insertions(+), 2 deletions(-)

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
 }