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. }