pet_home/pet_home_server
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

1

Browse Source
This commit is contained in:
hahwu 2025-12-18 17:17:56 +08:00
parent dd48b8354c
commit 1feed48e0f
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/server/cluster/cluster_func.go
View File

@ -107,6 +107,9 @@ func connectRemote(RemoteAddr string, ConnType int, ConnLabel string) error {
} }
func SendServerMsg(m *msg.Msg, serverId int) error { func SendServerMsg(m *msg.Msg, serverId int) error {
if m.UniKey == "" {
m.UniKey = GoUtil.UniKey(fmt.Sprintf("%v,Cluster Msg", m))
}
if v, ok := serverAgent.Load(serverId); ok { if v, ok := serverAgent.Load(serverId); ok {
data, err := GoUtil.GobMarshal(m) data, err := GoUtil.GobMarshal(m)
if err != nil { if err != nil {
@ -120,8 +123,9 @@ func SendServerMsg(m *msg.Msg, serverId int) error {
} }
func CallServerMsg(m *msg.Msg, serverId int) (*msg.Msg, error) { func CallServerMsg(m *msg.Msg, serverId int) (*msg.Msg, error) {
m.UniKey = GoUtil.UniKey(fmt.Sprintf("%v,Cluster Msg", m)) if m.UniKey == "" {
m.UniKey = GoUtil.UniKey(fmt.Sprintf("%v,Cluster Msg", m))
}
// 先注册回调通道，避免发送出去后对方快速返回导致丢失 // 先注册回调通道，避免发送出去后对方快速返回导致丢失
newChan := make(chan *msg.Msg, 1) newChan := make(chan *msg.Msg, 1)
registerChanel(m.UniKey, newChan) registerChanel(m.UniKey, newChan)