diff --git a/src/server/game/ClusterMgr.go b/src/server/game/ClusterMgr.go index 95a35518..6eec04b3 100644 --- a/src/server/game/ClusterMgr.go +++ b/src/server/game/ClusterMgr.go @@ -3,7 +3,6 @@ package game import ( mergeCluster "server/cluster" "server/game/mod/msg" - "server/pkg/github.com/name5566/leaf/log" ) var clusterHandler map[int]func(*msg.Msg) error @@ -22,7 +21,7 @@ func clusterHandlerProcess(m *msg.Msg) { if fun, ok := clusterHandler[m.Type]; ok { fun(m) } else { - log.Debug("clusterHandlerProcess not found handler %d", m.Type) + FriendMgrSend(m) } } diff --git a/src/server/game/FriendMgr.go b/src/server/game/FriendMgr.go index c84333aa..4860edc0 100644 --- a/src/server/game/FriendMgr.go +++ b/src/server/game/FriendMgr.go @@ -144,7 +144,13 @@ func ClusterFriendSync(m *msg.Msg) error { log.Debug("ClusterFriendSync") if v, ok := G_GameLogicPtr.FriendMgr.getData().ClusterMsg[m.To]; ok { for _, msg := range v { - mergeCluster.SendServerMsg(msg.Clone(), m.To) + if msg.H == 1 { + continue + } + err := mergeCluster.SendServerMsg(msg.Clone(), m.To) + if err == nil { + msg.H = 1 + } } } return nil