• 7.1 世界管理模块

    7.1 世界管理模块

    现在需要一个管理当前世界所有玩家的一个管理器，管理器应该拥有全部的当前在线玩家信息和当前世界的AOI划分规则。方便玩家与玩家之间进行聊天，同步位置等功能。

    首先，在创建一个world_manager.go文件作为世界管理器模块。

    mmo_game/core/world_manager.go

    1. package core
    3. import (
    4.     "sync"
    5. )
    7. /*
    8.     当前游戏世界的总管理模块
    9. */
    10. type WorldManager struct {
    11.     AoiMgr  *AOIManager       //当前世界地图的AOI规划管理器
    12.     Players map[int32]*Player //当前在线的玩家集合
    13.     pLock   sync.RWMutex      //保护Players的互斥读写机制
    14. }
    16. //提供一个对外的世界管理模块句柄
    17. var WorldMgrObj *WorldManager
    19. //提供WorldManager 初始化方法
    20. func init() {
    21.     WorldMgrObj = &WorldManager{
    22.         Players: make(map[int32]*Player),
    23.         AoiMgr:  NewAOIManager(AOI_MIN_X, AOI_MAX_X, AOI_CNTS_X, AOI_MIN_Y, AOI_MAX_Y, AOI_CNTS_Y),
    24.     }
    25. }
    27. //提供添加一个玩家的的功能，将玩家添加进玩家信息表Players
    28. func (wm *WorldManager) AddPlayer(player *Player) {
    29.     //将player添加到 世界管理器中
    30.     wm.pLock.Lock()
    31.     wm.Players[player.Pid] = player
    32.     wm.pLock.Unlock()
    34.     //将player 添加到AOI网络规划中
    35.     wm.AoiMgr.AddToGridByPos(int(player.Pid), player.X, player.Z)
    36. }
    38. //从玩家信息表中移除一个玩家
    39. func (wm *WorldManager) RemovePlayerByPid(pid int32) {
    40.     wm.pLock.Lock()
    41.     delete(wm.Players, pid)
    42.     wm.pLock.Unlock()
    43. }
    45. //通过玩家ID 获取对应玩家信息
    46. func (wm *WorldManager) GetPlayerByPid(pid int32) *Player {
    47.     wm.pLock.RLock()
    48.     defer wm.pLock.RUnlock()
    50.     return wm.Players[pid]
    51. }
    53. //获取所有玩家的信息
    54. func (wm *WorldManager) GetAllPlayers() []*Player {
    55.     wm.pLock.RLock()
    56.     defer wm.pLock.RUnlock()
    58.     //创建返回的player集合切片
    59.     players := make([]*Player, 0)
    61.     //添加切片
    62.     for _, v := range wm.Players {
    63.         players = append(players, v)
    64.     }
    66.     //返回
    67.     return players
    68. }

    该模块主要是将AOI和玩家做了一层统一管理，起到协调其他模块的中间功能。其中有一个全局变量WorldMgrObj是对外开放的管理模块句柄。供其他模块使用。

    现在我们应该在玩家上线的时候，也将玩家添加到WorldMgrObj中。

    mmo_game/server.go

    2. //当客户端建立连接的时候的hook函数
    3. func OnConnecionAdd(conn ziface.IConnection)  {
    4.     //创建一个玩家
    5.     player := core.NewPlayer(conn)
    6.     //同步当前的PlayerID给客户端， 走MsgID:1 消息
    7.     player.SyncPid()
    8.     //同步当前玩家的初始化坐标信息给客户端，走MsgID:200消息
    9.     player.BroadCastStartPosition()
    11.     //========将当前新上线玩家添加到worldManager中
    12.     core.WorldMgrObj.AddPlayer(player)
    13.     //========================================
    15.     fmt.Println("=====> Player pidId = ", player.Pid, " arrived ====")
    16. }