添加获取连接的接口,优化事件参数
This commit is contained in:
parent
32f28fb457
commit
30848faebc
|
@ -11,7 +11,7 @@ func init() {
|
||||||
Server.RegConnectionReceivePacketEvent(onConnectionReceivePacket)
|
Server.RegConnectionReceivePacketEvent(onConnectionReceivePacket)
|
||||||
}
|
}
|
||||||
|
|
||||||
func onConnectionReceivePacket(conn *server.Conn, packet []byte) {
|
func onConnectionReceivePacket(srv *server.Server, conn *server.Conn, packet []byte) {
|
||||||
player := Game.World.GetPlayerWithConnID(conn.GetID())
|
player := Game.World.GetPlayerWithConnID(conn.GetID())
|
||||||
if player == nil {
|
if player == nil {
|
||||||
return
|
return
|
||||||
|
@ -31,7 +31,7 @@ func onConnectionClosed(player *Player) {
|
||||||
player.Close()
|
player.Close()
|
||||||
}
|
}
|
||||||
|
|
||||||
func onConnectionOpened(conn *server.Conn) {
|
func onConnectionOpened(srv *server.Server, conn *server.Conn) {
|
||||||
player := NewPlayer(sole.GetSync(), conn)
|
player := NewPlayer(sole.GetSync(), conn)
|
||||||
if err := Game.World.Join(player); err != nil {
|
if err := Game.World.Join(player); err != nil {
|
||||||
panic(err)
|
panic(err)
|
||||||
|
|
|
@ -267,6 +267,11 @@ func (slf *Server) IsDev() bool {
|
||||||
return !slf.prod
|
return !slf.prod
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// GetConnections 获取所有在线的连接
|
||||||
|
func (slf *Server) GetConnections() synchronization.MapReadonly[string, *Conn] {
|
||||||
|
return slf.connections
|
||||||
|
}
|
||||||
|
|
||||||
// Shutdown 停止运行服务器
|
// Shutdown 停止运行服务器
|
||||||
func (slf *Server) Shutdown(err error) {
|
func (slf *Server) Shutdown(err error) {
|
||||||
if slf.initMessageChannel {
|
if slf.initMessageChannel {
|
||||||
|
|
Loading…
Reference in New Issue