server/game2006go
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

1

Browse Source
This commit is contained in:
aozhiwei 2024-04-17 10:43:14 +08:00
parent 8471c502a4
commit bd7a68482d
2 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
server/imserver/player/player.go
View File

@ -44,11 +44,12 @@ func (this *player) SendMsg(rspMsg proto.Message) {
GetWspListener().SendProxyMsg(this.socket.Conn, this.socket.SocketHandle, rspMsg) GetWspListener().SendProxyMsg(this.socket.Conn, this.socket.SocketHandle, rspMsg)
} }
func (this *player) reBind(socket f5.WspCliConn) { func (this *player) reBind(socket f5.WspCliConn, sessionId string) {
if this.socket.IsValid() { if this.socket.IsValid() {
delete(_playerMgr.socketHash, this.socket) delete(_playerMgr.socketHash, this.socket)
} }
this.socket = socket this.socket = socket
this.sessionId = sessionId
_playerMgr.socketHash[this.socket] = this _playerMgr.socketHash[this.socket] = this
} }

6
server/imserver/player/playermgr.go
View File

@ -83,7 +83,7 @@ func (this *playerMgr) CMLogin(hdr *f5.MsgHdr, msg *cs.CMLogin) {
rspMsg.Errcode = proto.Int32(0) rspMsg.Errcode = proto.Int32(0)
rspMsg.Errmsg = proto.String("") rspMsg.Errmsg = proto.String("")
rspMsg.ServerInfo = proto.String(mt.Table.IMCluster.GetServerInfo()) rspMsg.ServerInfo = proto.String(mt.Table.IMCluster.GetServerInfo())
oldHum.reBind(hdr.GetSocket()) oldHum.reBind(hdr.GetSocket(), msg.GetSessionId())
oldHum.SendMsg(&rspMsg) oldHum.SendMsg(&rspMsg)
return return
} }
@ -95,7 +95,7 @@ func (this *playerMgr) CMLogin(hdr *f5.MsgHdr, msg *cs.CMLogin) {
rspMsg.Errcode = proto.Int32(0) rspMsg.Errcode = proto.Int32(0)
rspMsg.Errmsg = proto.String("") rspMsg.Errmsg = proto.String("")
rspMsg.ServerInfo = proto.String(mt.Table.IMCluster.GetServerInfo()) rspMsg.ServerInfo = proto.String(mt.Table.IMCluster.GetServerInfo())
oldHum.reBind(hdr.GetSocket()) oldHum.reBind(hdr.GetSocket(), msg.GetSessionId())
oldHum.SendMsg(&rspMsg) oldHum.SendMsg(&rspMsg)
return return
} }
@ -270,7 +270,7 @@ func (this *playerMgr) CMReconnect(hdr *f5.MsgHdr, msg *cs.CMReconnect) {
"session_id no valid")) "session_id no valid"))
return return
} }
hum.reBind(hdr.GetSocket()) hum.reBind(hdr.GetSocket(), msg.GetSessionId())
hum.SendMsg(rspMsg) hum.SendMsg(rspMsg)
} }