- 简化 ClientData 结构体,移除不必要的方法 - 优化 Player 结构体,调整 Conn 类型 - 更新 wscodec.go 中的 Conn 结构体 - 删除未使用的 XML 相关文件和代码 - 调整 ServerEvent 和 controller 中的相关逻辑
49 lines
1.2 KiB
Go
49 lines
1.2 KiB
Go
package service
|
||
|
||
import (
|
||
"blazing/common/data/socket"
|
||
"blazing/common/socket/errorcode"
|
||
"blazing/common/socket/handler"
|
||
)
|
||
|
||
func GetPlayer(c *socket.Conn, userid uint32) *socket.Player { //TODO 这里待优化,可能存在内存泄漏问题
|
||
c.Mu.Lock()
|
||
defer c.Mu.Unlock()
|
||
//检查player初始化,是否为conn初始后取map,防止二次连接后存在两个player
|
||
|
||
clientdata := c.MainConn.Context().(*socket.ClientData)
|
||
if clientdata.Player != nil {
|
||
return clientdata.Player
|
||
}
|
||
|
||
clientdata.Player = socket.NewPlayer(
|
||
|
||
socket.WithConn(c), //注入conn
|
||
)
|
||
|
||
// gff := socket.NewClientData()
|
||
|
||
// gff.Player = clientdata.Player
|
||
// c.MainConn.SetContext(gff)
|
||
socket.Mainplayer.Store(userid, clientdata.Player)
|
||
|
||
return clientdata.Player
|
||
// return nil
|
||
}
|
||
func KickPlayer(userid uint32) { //踢出玩家
|
||
//TODO 返回错误码
|
||
//var player *entity.Player
|
||
if player1, ok := socket.Mainplayer.Load((userid)); ok {
|
||
//取成功,否则创建
|
||
head := handler.NewTomeeHeader(1001, userid)
|
||
head.Result = uint32(errorcode.ErrorCodes.ErrAccountLoggedInElsewhere)
|
||
|
||
player1.SendPack(head.Pack(nil))
|
||
player1.MainConn.MainConn.Close()
|
||
// clientdata.Player = player
|
||
}
|
||
|
||
//return player
|
||
// return nil
|
||
}
|