架构优化
This commit is contained in:
parent
bd96bfa29e
commit
123f4d2e1c
@ -292,13 +292,12 @@ func PlayerLoginHandler(data *msg.Msg) (interface{}, error) {
|
|||||||
messagesToSend := make([]*msg.Msg, len(messages.Messages))
|
messagesToSend := make([]*msg.Msg, len(messages.Messages))
|
||||||
copy(messagesToSend, messages.Messages)
|
copy(messagesToSend, messages.Messages)
|
||||||
messages.mu.Unlock()
|
messages.mu.Unlock()
|
||||||
|
ReplyPlayerMsgASync(data, nil)
|
||||||
// 在锁外发送离线消息
|
// 在锁外发送离线消息
|
||||||
for _, message := range messagesToSend {
|
for _, message := range messagesToSend {
|
||||||
SendMsgToNodeAsync(message, node)
|
SendMsgToNodeAsync(message, node)
|
||||||
}
|
}
|
||||||
log.Debug("[Middleware] Player sync logout message player id: %v, len: %d", data.From, len(messagesToSend))
|
log.Debug("[Middleware] Player sync logout message player id: %v, len: %d", data.From, len(messagesToSend))
|
||||||
ReplyPlayerMsgASync(data, nil)
|
|
||||||
return nil, nil
|
return nil, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user