从0到1开发go-tcp框架【4实战片— — 开发MMO之玩家聊天篇】

从0到1开发go-tcp框架【实战片— — 开发MMO】

MMO（MassiveMultiplayerOnlineGame）：大型多人在线游戏（多人在线网游）

1 AOI兴趣点的算法

游戏中的坐标模型：

在这里插入图片描述
场景相关数值计算

● 场景大小： 250*250 ， w(x轴宽度) = 250，l(y轴长度) = 250
● x轴格子数量：nx = 5
● y轴格子数量：ny = 5
● 格子宽度: dx = w / nx = 250 / 5 = 50
● 格子长度: dy = l / ny = 250 / 5 = 50
● 格子的x轴坐标：idx
● 格子的y轴坐标：idy
● 格子编号：id = idy *nx + idx (利用格子坐标得到格子编号)
● 格子坐标：idx = id % nx , idy = id / nx (利用格子id得到格子坐标)
● 格子的x轴坐标: idx = id % nx (利用格子id得到x轴坐标编号)
● 格子的y轴坐标: idy = id / nx (利用格子id得到y轴坐标编号)

1.1 定义AOI格子（Grid）

AOI格子：

  • 格子ID
  • 格子的左边界坐标
  • 格子的右边界坐标
  • 格子的上边界坐标
  • 格子的下边界坐标
  • 当前格子内玩家/物体成员的ID集合
  • 保护当前集合的锁

AOI格子应该有的方法：

  • 初始化当前格子
  • 给格子添加一个玩家
  • 从格子中删除一个玩家
  • 得到当前格子中所有的玩家
  • 调试使用：打印出格子的基本信息

mmo_game_zinx/core/grid.go

package coreimport ("fmt""sync"
)/*
一个AOI地图中的格子类型
*/
type Grid struct {//格子IDGID int//格子的左边界坐标MinX int//格子的右边界坐标MaxX int//格子的上边界坐标MinY int//格子的下边界坐标MaxY int//当前格子内玩家或物体成员对的ID集合playerIDs map[int]bool//保护当前集合的锁pIDLock sync.RWMutex
}//初始化当前格子的方法
func NewGrid(gId, minX, maxX, minY, maxY int) *Grid {return &Grid{GID:       gId,MinX:      minX,MaxX:      maxX,MinY:      minY,MaxY:      maxY,playerIDs: make(map[int]bool),}
}//给格子添加一个玩家
func (g *Grid) Add(playerId int) {g.pIDLock.Lock()defer g.pIDLock.Unlock()g.playerIDs[playerId] = true
}//从格子中删除一个玩家
func (g *Grid) Remove(playerId int) {g.pIDLock.Lock()defer g.pIDLock.Unlock()delete(g.playerIDs, playerId)
}//得到当前格子中所有玩家的id
func (g *Grid) GetPlayerIds() (playerIds []int) {g.pIDLock.RLock()defer g.pIDLock.RUnlock()for k, _ := range g.playerIDs {playerIds = append(playerIds, k)}return
}func (g *Grid) String() string {return fmt.Sprintf("Grid id: %d, minX: %d, maxX: %d, minY: %d, maxY: %d, playerIds: %v",g.GID, g.MinX, g.MaxX, g.MinY, g.MaxY, g.playerIDs)
}

1.2 AOI管理模块

AOIManager：

  • 初始化一个AOI管理区域模块
  • 得到每个格子在X轴方向的宽度
  • 通过横纵轴得到GID
  • 添加一个PlayerId到一个格子中
  • 移除一个格子中的playerId
  • 通过GID获取全部的PlayerID
  • 通过坐标将Player添加到一个格子中
  • 通过坐标把一个Player从一个格子中删除
  • 通过Player坐标得到当前Player周边九宫格内全部的PlayerIDs
  • 通过坐标获取对应玩家所在的GID
  • 通过横纵轴得到周围的九宫格
  • 根据GID获取GID周围的九宫格
    在这里插入图片描述
    • 获取思路：先求x，再求y。先根据GID判断该GID左边和右边是否有格子 。然后将X轴上的格子添加到集合中，再遍历集合判断集合中的上下是否有格子。

mmo_game_zinx/core/aoi.go

package coreimport "fmt"// 定义AOI地图大小
const (AOI_MIN_X  int = 85AOI_MAX_X  int = 410AOI_CNTS_X int = 10AOI_MIN_Y  int = 75AOI_MAX_Y  int = 400AOI_CNTS_Y int = 20
)type AOIManager struct {//区域的左边界坐标MinX int//区域的右界坐标MaxX int//X方向格子的数量CountsX int//区域的上边界坐标MinY int//区域的下边界坐标MaxY int//Y方向上格子的数量CountsY int//当前区域中有哪些格子map-key=格子的IDgrids map[int]*Grid
}func NewAOIManager(minX, maxX, countsX, minY, maxY, countsY int) *AOIManager {aoiMgr := &AOIManager{MinX:    minX,MaxX:    maxX,CountsX: countsX,MinY:    minY,MaxY:    maxY,CountsY: countsY,grids:   make(map[int]*Grid),}//给AOI初始化区域的所有格子进行编号和初始化for y := 0; y < countsY; y++ {for x := 0; x < countsX; x++ {//计算格子的ID 根据x，y编号//格子的编号：id = idy * countsX + idxgid := y*countsX + x//初始化gid格子aoiMgr.grids[gid] = NewGrid(gid,aoiMgr.MinX+x*aoiMgr.gridXWidth(),aoiMgr.MinX+(x+1)*aoiMgr.gridXWidth(),aoiMgr.MinY+y*aoiMgr.gridYLength(),aoiMgr.MinY+(y+1)*aoiMgr.gridYLength())}}return aoiMgr
}// 得到每个格子在x轴方向的宽度
func (m *AOIManager) gridXWidth() int {return (m.MaxX - m.MinX) / m.CountsX
}// 得到每个格子在y轴方向的宽度
func (m *AOIManager) gridYLength() int {return (m.MaxY - m.MinY) / m.CountsY
}// 打印信息方法
func (m *AOIManager) String() string {s := fmt.Sprintf("AOIManagr:\nminX:%d, maxX:%d, cntsX:%d, minY:%d, maxY:%d, cntsY:%d\n Grids in AOI Manager:\n",m.MinX, m.MaxX, m.CountsX, m.MinY, m.MaxY, m.CountsY)for _, grid := range m.grids {s += fmt.Sprintln(grid)}return s
}// 根据格子的gID得到当前周边的九宫格信息
func (m *AOIManager) GetSurroundGridsByGid(gID int) (grids []*Grid) {//判断gID是否存在if _, ok := m.grids[gID]; !ok {return}//将当前gid添加到九宫格中grids = append(grids, m.grids[gID])//根据gid得到当前格子所在的X轴编号idx := gID % m.CountsX//判断当前idx左边是否还有格子if idx > 0 {grids = append(grids, m.grids[gID-1])}//判断当前的idx右边是否还有格子if idx < m.CountsX-1 {grids = append(grids, m.grids[gID+1])}//将x轴当前的格子都取出，进行遍历，再分别得到每个格子的上下是否有格子//得到当前x轴的格子id集合gidsX := make([]int, 0, len(grids))for _, v := range grids {gidsX = append(gidsX, v.GID)}//遍历x轴格子for _, v := range gidsX {//计算该格子处于第几列idy := v / m.CountsX//判断当前的idy上边是否还有格子if idy > 0 {grids = append(grids, m.grids[v-m.CountsX])}//判断当前的idy下边是否还有格子if idy < m.CountsY-1 {grids = append(grids, m.grids[v+m.CountsX])}}return
}// 通过横纵坐标获取对应的格子ID
func (m *AOIManager) GetGIDByPos(x, y float32) int {gx := (int(x) - m.MinX) / m.gridXWidth()gy := (int(y) - m.MinY) / m.gridYLength()return gy*m.CountsX + gx
}// 通过横纵坐标得到周边九宫格内的全部PlayerIDs
func (m *AOIManager) GetPIDsByPos(x, y float32) (playerIDs []int) {//根据横纵坐标得到当前坐标属于哪个格子IDgID := m.GetGIDByPos(x, y)//根据格子ID得到周边九宫格的信息grids := m.GetSurroundGridsByGid(gID)for _, v := range grids {playerIDs = append(playerIDs, v.GetPlayerIds()...)fmt.Printf("===> grid ID : %d, pids : %v  ====\n", v.GID, v.GetPlayerIds())}return
}// 添加一个PlayerId到一个格子中
func (m *AOIManager) AddPidToGrid(pId, gId int) {m.grids[gId].Add(pId)
}// 移除一个格子中的playerID
func (m *AOIManager) RemovePidFromGrid(pId, gId int) {m.grids[gId].Remove(pId)
}// 通过GID获取全部的playerID
func (m *AOIManager) GetPidsByGid(gId int) (playerIds []int) {playerIds = m.grids[gId].GetPlayerIds()return
}// 通过坐标将一个Player添加到一个格子中
func (m *AOIManager) AddToGridByPos(pId int, x, y float32) {gId := m.GetGIDByPos(x, y)grid := m.grids[gId]grid.Add(pId)
}// 通过一个坐标把一个player从一个格子中删除
func (m *AOIManager) RemoveFromGridByPos(pId int, x, y float32) {gId := m.GetGIDByPos(x, y)grid := m.grids[gId]grid.Remove(pId)
}

mmo_game_zinx/core/aoi_test.go

package coreimport ("fmt""testing"
)func TestNewAOIManager(t *testing.T) {//初始化AOIManageraoiMgr := NewAOIManager(0, 250, 5, 0, 250, 5)//打印AOIManagerfmt.Println(aoiMgr)
}//根据GID获取九宫格
func TestAOIManager_GetSurroundGridsByGid(t *testing.T) {//初始化AOIManageraoiMgr := NewAOIManager(0, 250, 5, 0, 250, 5)for gid, _ := range aoiMgr.grids {grids := aoiMgr.GetSurroundGridsByGid(gid)fmt.Println("gid : ", gid, " grids len = ", len(grids))gIds := make([]int, 0, len(grids))for _, grid := range grids {gIds = append(gIds, grid.GID)}fmt.Println("surrounding grid IDs are : ", gIds)}
}

2 数据传输协议的选择（protobuf）

常见的传输格式：json、xml、protobuf

  1. json：可读性比较强；编解码比较耗时【web领域】
  2. xml：基于标签【前端/网页】
  3. protobuf（Google开发的）：编解码很快、体积小、跨平台；可读性不强，传输过程中不是明文，是二进制（已经序列化完毕的）【后端应用/微服务/服务器】

2.1 安装

我这里以mac安装为例，其他os自行百度即可

# 安装protobuf
brew install protobuf# 安装用于编译生成go文件的插件
brew install protoc-gen-go
brew install protoc-gen-go-grpc# 查看版本
protoc --version
protoc-gen-go --version# 安装golang插件
go get github.com/golang/protobuf/protoc-gen-go
go get -u -v github.com/golang/protobuf/protoc-gen-go

2.2 profobuf语法及使用

①语法

person.proto

syntax = "proto3"; 						//指定版本信息，不指定会报错
package pb;						//后期生成go文件的包名option go_package = "./;proto"; //配置包依赖路径
//message为关键字，作用为定义一种消息类型
message Person {string	name = 1;					//姓名int32	age = 2;					//年龄repeated string emails = 3; 		//电子邮件（repeated表示字段允许重复）【类比go中的切片】repeated PhoneNumber phones = 4;	//手机号
}//enum为关键字，作用为定义一种枚举类型
enum PhoneType {MOBILE = 0;HOME = 1;WORK = 2;
}//message为关键字，作用为定义一种消息类型可以被另外的消息类型嵌套使用
message PhoneNumber {string number = 1;PhoneType type = 2;
}

②使用步骤

  • 定义一个go的与protobuf对应的结构体
  • proto.Marshal进行编码序列化，得到二进制数据data
  • 将data进行传输，或者发送给对方
  • 对方收到data数据，将data通过proto.UnMarshal得到person结构体数据

1. 编写.proto文件

2. 执行protoc编译出对应go代码

通过如下方式调用protocol编译器，把 .proto 文件编译成代码

 protoc --proto_path=IMPORT_PATH --go_out=DST_DIR path/to/file.proto

其中：

  1. –proto_path，指定了 .proto 文件导包时的路径，可以有多个，如果忽略则默认当前目录。
  2. –go_out， 指定了生成的go语言代码文件放入的文件夹
  3. 允许使用protoc --go_out=./ *.proto的方式一次性编译多个 .proto 文件 【.proto中需要添加option go_package选项】，否则会报：protoc-gen-go: unable to determine Go import path for “xxx.proto”
option go_package = "./;proto"; //配置包依赖路径

在这里插入图片描述

  1. 编译时，protobuf 编译器会把 .proto 文件编译成 .pd.go 文件
    在这里插入图片描述

3. 通过proto.Marshal进行序列化（发数据）

data, err := proto2.Marshal(person)

4. 通过proto.UnMarshal进行反序列话（收数据）

err = proto2.Unmarshal(data, &newPerson)

③测试传输

在myDemo/protobuf文件夹下编写main.go进行测试

main.go

package mainimport ("fmt"proto2 "google.golang.org/protobuf/proto"pb "myTest/myDemo/protobuf/pb"
)func main() {person := &pb.Person{Name:   "ziyi",Age:    18,Emails: []string{"ziyi.atgmai.com", "ziyi_at163.com"},Phones: []*pb.PhoneNumber{&pb.PhoneNumber{Number: "181234567",Type:   pb.PhoneType_MOBILE,},&pb.PhoneNumber{Number: "33331111",Type:   pb.PhoneType_HOME,},},}//编码：将person对象编码，将protobuf的message进行序列化，得到一个[]byte数组data, err := proto2.Marshal(person)if err != nil {fmt.Println("protobuf marshal err =", err)return}//解码newPerson := pb.Person{}err = proto2.Unmarshal(data, &newPerson)if err != nil {fmt.Println("protobuf unmarshal err =", err)return}fmt.Println("传输的数据：", person)fmt.Println("接收到的数据：", &newPerson)
}

在这里插入图片描述

3 游戏相关业务

3.1 业务消息格式定义

在这里插入图片描述

MsgID：1（同步玩家本地登录ID）

  1. MsgID:1
  • 同步玩家本地登录的ID（用来标识玩家），玩家登录之后，由Server端主动生成玩家ID发送给客户端
  • 发起者：Server
  • Pid：玩家ID

对应proto：

message SyncPid{int32 Pid=1;
}

MsgID：2（世界聊天）

● 同步玩家本次登录的ID(用来标识玩家), 玩家登陆之后，由Server端主动生成玩家ID发送给客户端
● 发起者： Client
● Content: 聊天信息

message Talk{string Content=1;
}

MsgID：3（移动信息）

● 移动的坐标数据
● 发起者： Client
● P: Position类型，地图的左边点

message Position{float X=1;float Y=2;float Z=3;float V=4;
}

MsgID：200（广播聊天、坐标、动作）

● 广播消息
● 发起者： Server
● Tp: 1 世界聊天, 2 坐标, 3 动作, 4 移动之后坐标信息更新
● Pid: 玩家ID

message BroadCast{int32 Pid=1;int32 Tp=2;//oneof表示只能选三个中的一个oneof Data {string Content=3;Position P=4;int32 ActionData=5;}
}

MsgID：201

● 广播消息 掉线/aoi消失在视野
● 发起者： Server
● Pid: 玩家ID

message SyncPid{int32 Pid=1;
}

MsgID：202（同步位置信息）

● 同步周围的人位置信息(包括自己)
● 发起者： Server
● ps: Player 集合,需要同步的玩家

message SyncPlayers{repeated Player ps=1;
}message Player{int32 Pid=1;Position P=2;
}

3.2 项目模块搭建

mmo_game_zinx

  • apis:存放基本用户的自定义路由业务，一个msgId对应一个业务
  • conf：存放zinx.json（自定义框架的配置文件）
  • pb：protobuf相关文件
  • core：存放核心功能
  • main.go:服务器的主入口
  • game_client:unity客户端

最终项目结构

.
└── mmo_game_zinx├── apis├── conf│   └── zinx.json├── core│   ├── aoi.go│   ├── aoi_test.go│   ├── grid.go├── game_client│   └── client.exe├── pb│   ├── build.sh│   └── msg.proto├── README.md└── server.go

在这里插入图片描述

①玩家上线

在这里插入图片描述

  • 创建一个玩家的方法：
  1. 编写proto文件
  2. 定义玩家对象player.go
  • 玩家可以和客户端通信的发送消息的方法：
  1. 将msg的proto格式进行序列化改成二进制
  2. 通过zinx框架提供的sendMsg将数据进行TLV格式的打包发包
  • 实现上线业务功能：
  1. 给server注册一个创建连接之后的hook函数
  2. 给Player提供两个方法：将PlayerID同步给客户端、将Player上线的初始位置同步给客户端
1. mmo_game_zinx/pb/msg.proto

定义proto文件（消息类型）

syntax = "proto3";                //Proto协议
package pb;                     //当前包名
option csharp_namespace = "Pb";   //给C#提供的选项[因为我们的游戏画面采用unity3D，基于C#的]
option go_package = "./;pb"; //配置包依赖路径//同步客户端玩家ID
message SyncPid{int32 Pid=1;
}//玩家位置
message Position{float X=1;float Y=2;float Z=3;float V=4;
}//玩家广播数据
message BroadCast{int32 Pid=1;int32 Tp=2;//1 世界聊天, 2 坐标, 3 动作, 4 移动之后坐标信息更新oneof Data {string Content=3;Position P=4;int32 ActionData=5;}
}

为了方便后续更新proto文件，我们这里直接编写一个脚本

mmo_game_zinx/pb/build.sh:

#!/bin/bash
protoc --go_out=. *.proto
2. mmo_game_zinx/core/player.go
package coreimport ("fmt""google.golang.org/protobuf/proto""math/rand"pb "myTest/mmo_game_zinx/pb""myTest/zinx/ziface""sync"
)// 玩家
type Player struct {Pid  int32              //玩家IDConn ziface.IConnection //当前玩家的连接（用于和客户端的连接）X    float32            //平面的X坐标Y    float32            //高度Z    float32            //平面y坐标（注意：Z字段才是玩家的平面y坐标，因为unity的客户端已经定义好了）V    float32            //旋转的0-360角度
}var PidGen int32 = 1  //用于生成玩家id
var IdLock sync.Mutex //保护PidGen的锁func NewPlayer(conn ziface.IConnection) *Player {IdLock.Lock()id := PidGenPidGen++IdLock.Unlock()p := &Player{Pid:  id,Conn: conn,X:    float32(160 + rand.Intn(10)), //随机在160坐标点，基于X轴若干便宜Y:    0,Z:    float32(140 + rand.Intn(20)), //随机在140坐标点，基于Y轴若干偏移V:    0,}return p
}/*
提供一个发送给客户端消息的方法
主要是将pb的protobuf数据序列化后，再调用zinx的sendMsg方法
*/
func (p *Player) SendMsg(msgId uint32, data proto.Message) {//将proto Message结构体序列化 转换成二进制msg, err := proto.Marshal(data)if err != nil {fmt.Println("marshal msg err: ", err)return}//将二进制文件 通过zinx框架的sendMsg将数据发送给客户端if p.Conn == nil {fmt.Println("connection in player is nil")return}if err := p.Conn.SendMsg(msgId, msg); err != nil {fmt.Println("player send msg is err, ", err)return}
}// 告知客户端玩家的pid，同步已经生成的玩家ID给客户端
func (p *Player) SyncPid() {//组件MsgID：0的proto数据proto_msg := &pb.SyncPid{Pid: p.Pid,}//将消息发送给客户端p.SendMsg(1, proto_msg)
}// 广播玩家自己的出生地点
func (p *Player) BroadCastStartPosition() {//组建MsgID：200 的proto数据proto_msg := &pb.BroadCast{Pid: p.Pid,Tp:  2, //Tp2 代表广播位置的坐标Data: &pb.BroadCast_P{P: &pb.Position{X: p.X,Y: p.Y,Z: p.Z,V: p.V,},},}//将消息发送给客户端p.SendMsg(200, proto_msg)
}
3. mmo_game_zinx/main.go
package mainimport ("fmt""myTest/mmo_game_zinx/core""myTest/zinx/ziface""myTest/zinx/znet"
)// 当前客户端建立连接之后的hook函数
func OnConnectionAdd(conn ziface.IConnection) {//创建一个player对象player := core.NewPlayer(conn)//给客户端发送MsgID：1的消息，同步当前的playerID给客户端player.SyncPid()//给客户端发送MsgID：200的消息，同步当前Player的初始位置给客户端player.BroadCastStartPosition()fmt.Println("======>Player pid = ", player.Pid, " is arrived ====")
}func main() {//创建服务句柄s := znet.NewServer("MMO Game Zinx")s.SetOnConnStart(OnConnectionAdd)s.Serve()
}
测试效果
  1. 启动服务端
  2. 启动客户端（client.exe）
    在这里插入图片描述

连续启动多个查看效果：

在这里插入图片描述
服务端控制台打印：
在这里插入图片描述

②世界聊天

在这里插入图片描述

  1. proto3聊天协议的定义
  2. 聊天业务的实现：
  • 解析聊天的proto协议
  • 将聊天数据广播给全部在线玩家->创建一个世界管理模块
    - 初始化管理模块
    - 添加一个玩家
    - 删除一个玩家
    - 通过玩家ID查询Player对象
    - 获取全部的在线玩家
1. mmo_game_zinx/pb/msg.proto

在之前的基础上，在末尾追加：

message Talk{string Content=1;
}

执行build.sh脚本重新编译

2. mmo_game_zinx/apis/world_chat.go
package apisimport ("fmt""google.golang.org/protobuf/proto""myTest/mmo_game_zinx/core"pb "myTest/mmo_game_zinx/pb""myTest/zinx/ziface""myTest/zinx/znet"
)// 世界聊天路由业务
type WorldChatApi struct {znet.BaseRouter
}// 重写handler方法
func (wc *WorldChatApi) Handler(request ziface.IRequest) {//1 解析客户端传递进来的proto协议proto_msg := &pb.Talk{}err := proto.Unmarshal(request.GetData(), proto_msg)if err != nil {fmt.Println("Talk Unmarshal err ", err)return}//2 当前的聊天数据 属于哪个玩家发送的pid, err := request.GetConnection().GetProperty("pid")//3 根据pid得到对应的player对象player := core.WorldMgrObj.GetPlayerByPid(pid.(int32))//4 将这个消息广播给其他全部在线的用户player.Talk(proto_msg.Content)
}
3. mmo_game_zinx/main.go
package mainimport ("fmt""myTest/mmo_game_zinx/apis""myTest/mmo_game_zinx/core""myTest/zinx/ziface""myTest/zinx/znet"
)// 当前客户端建立连接之后的hook函数
func OnConnectionAdd(conn ziface.IConnection) {//创建一个player对象player := core.NewPlayer(conn)//给客户端发送MsgID：1的消息，同步当前的playerID给客户端player.SyncPid()//给客户端发送MsgID：200的消息，同步当前Player的初始位置给客户端player.BroadCastStartPosition()//将当前新上线的玩家添加到WorldManager中core.WorldMgrObj.AddPlayer(player)//将playerId添加到连接属性中，方便后续广播知道是哪个玩家发送的消息conn.SetProperty("pid", player.Pid)fmt.Println("======>Player pid = ", player.Pid, " is arrived ====")
}func main() {//创建服务句柄s := znet.NewServer("MMO Game Zinx")s.SetOnConnStart(OnConnectionAdd)//注册一些路由业务s.AddRouter(2, &apis.WorldChatApi{})s.Serve()
}
4. mmo_game_zinx/core/world_manager.go
package coreimport "sync"/*
当前游戏的世界总管理模块
*/
type WorldManager struct {//AOIManager 当前世界地图AOI的管理模块AoiMgr *AOIManager//当前全部在线的players集合Players map[int32]*Player//保护Players集合的锁pLock sync.RWMutex
}// 提供一个对外的世界管理模块的句柄
var WorldMgrObj *WorldManagerfunc init() {WorldMgrObj = &WorldManager{//创建世界AOI地图规划AoiMgr: NewAOIManager(AOI_MIN_X, AOI_MAX_X, AOI_CNTS_X, AOI_MIN_Y, AOI_MAX_Y, AOI_CNTS_Y),//初始化player集合Players: make(map[int32]*Player),}
}// 添加一个玩家
func (wm *WorldManager) AddPlayer(player *Player) {wm.pLock.Lock()wm.Players[player.Pid] = playerwm.pLock.Unlock()//将player添加到AOIManager中wm.AoiMgr.AddToGridByPos(int(player.Pid), player.X, player.Z)
}// 删除一个玩家
func (wm *WorldManager) RemovePlayerByPid(pid int32) {//得到当前的玩家player := wm.Players[pid]//将玩家从AOIManager中删除wm.AoiMgr.RemoveFromGridByPos(int(pid), player.X, player.Z)//将玩家从世界管理中删除wm.pLock.Lock()delete(wm.Players, pid)wm.pLock.Unlock()
}// 通过玩家ID查询player对象
func (wm *WorldManager) GetPlayerByPid(pid int32) *Player {wm.pLock.RLock()defer wm.pLock.RUnlock()return wm.Players[pid]
}// 获取全部的在线玩家
func (wm *WorldManager) GetAllPlayers() []*Player {wm.pLock.Lock()defer wm.pLock.Unlock()players := make([]*Player, 0)//遍历集合，将玩家添加到players切片中for _, p := range wm.Players {players = append(players, p)}return players
}
5. mmo_game_zinx/core/player.go
package coreimport ("fmt""google.golang.org/protobuf/proto""math/rand"pb "myTest/mmo_game_zinx/pb""myTest/zinx/ziface""sync"
)// 玩家
type Player struct {Pid  int32              //玩家IDConn ziface.IConnection //当前玩家的连接（用于和客户端的连接）X    float32            //平面的X坐标Y    float32            //高度Z    float32            //平面y坐标（注意：Z字段才是玩家的平面y坐标，因为unity的客户端已经定义好了）V    float32            //旋转的0-360角度
}var PidGen int32 = 1  //用于生成玩家id
var IdLock sync.Mutex //保护PidGen的锁func NewPlayer(conn ziface.IConnection) *Player {IdLock.Lock()id := PidGenPidGen++IdLock.Unlock()p := &Player{Pid:  id,Conn: conn,X:    float32(160 + rand.Intn(10)), //随机在160坐标点，基于X轴若干便宜Y:    0,Z:    float32(140 + rand.Intn(20)), //随机在140坐标点，基于Y轴若干偏移V:    0,}return p
}/*
提供一个发送给客户端消息的方法
主要是将pb的protobuf数据序列化后，再调用zinx的sendMsg方法
*/
func (p *Player) SendMsg(msgId uint32, data proto.Message) {//将proto Message结构体序列化 转换成二进制msg, err := proto.Marshal(data)if err != nil {fmt.Println("marshal msg err: ", err)return}//将二进制文件 通过zinx框架的sendMsg将数据发送给客户端if p.Conn == nil {fmt.Println("connection in player is nil")return}if err := p.Conn.SendMsg(msgId, msg); err != nil {fmt.Println("player send msg is err, ", err)return}
}// 告知客户端玩家的pid，同步已经生成的玩家ID给客户端
func (p *Player) SyncPid() {//组件MsgID：0的proto数据proto_msg := &pb.SyncPid{Pid: p.Pid,}//将消息发送给客户端p.SendMsg(1, proto_msg)
}// 广播玩家自己的出生地点
func (p *Player) BroadCastStartPosition() {//组建MsgID：200 的proto数据proto_msg := &pb.BroadCast{Pid: p.Pid,Tp:  2, //Tp2 代表广播位置的坐标Data: &pb.BroadCast_P{P: &pb.Position{X: p.X,Y: p.Y,Z: p.Z,V: p.V,},},}//将消息发送给客户端p.SendMsg(200, proto_msg)
}// 玩家广播世界聊天消息
func (p *Player) Talk(content string) {//1 组建MsgID：200 proto数据proto_msg := &pb.BroadCast{Pid: p.Pid,Tp:  1, //tp-1 代表聊天广播Data: &pb.BroadCast_Content{Content: content,},}//2 得到当前世界所有在线的玩家players := WorldMgrObj.GetAllPlayers()for _, player := range players {//player分别给对应的客户端发送消息player.SendMsg(200, proto_msg)}
}
测试效果

在这里插入图片描述

启动服务

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.rhkb.cn/news/79410.html

如若内容造成侵权/违法违规/事实不符，请联系长河编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

当向数据库导入大量数据时,mysql主键唯一键重复插入,如何丝滑操作并不导入重复数据呢

当向数据库导入大量数据时,mysql主键唯一键重复插入,如何丝滑操作并不导入重复数据呢

解决办法&#xff1a; 答案来源&#xff1a;
阅读更多...
AI 绘画Stable Diffusion 研究（四）sd文生图功能详解（上）

AI 绘画Stable Diffusion 研究（四）sd文生图功能详解（上）

大家好&#xff0c;我是风雨无阻。 通过前面几篇AI 绘画Stable Diffusion 研究系列的介绍&#xff0c;我们完成了Stable Diffusion整合包的安装、模型ControlNet1.1 安装、模型种类介绍与安装&#xff0c;相信看过教程的朋友们&#xff0c;手上已经有可以操作实践的Stable Diff…
阅读更多...
UE4查看加密PAK里边的资源Android/iOS/PC方法

UE4查看加密PAK里边的资源Android/iOS/PC方法

我们经常会需要把1个模型进行减面然后在移动端使用，有时候会出现移动端模型和PC端模型不一致的问题，这时候就需要将移动端的模型和PC端的模型进行对比，找到问题出现的原因，检查Mesh、Normal、UV0、UV1、MaterialId、碰撞等是否一致。 如何打包Pak文件，见这篇文章：UE4打包…
阅读更多...
C语言假期作业 DAY 15

C语言假期作业 DAY 15

一、选择题 1、有如下代码&#xff0c;则 *(p[0]1) 所代表的数组元素是&#xff08; &#xff09; int a[3][2] {1, 2, 3, 4, 5, 6}, *p[3]; p[0] a[1]; A: a[0][1] B: a[1][0] C: a[1][1] D: a[1][2] 答案解析 正确答案&#xff1a; C p 是一个指针数组&#xff0c; p[0] a…
阅读更多...
备忘录模式（C++）

备忘录模式（C++）

定义 在不破坏封装性的前提下&#xff0c;捕获一-个对象的内部状态&#xff0c;并在该对象之外保存这个状态。这样以后就可以将该对象恢复到原先保存的状态。 应用场景 ➢在软件构建过程中&#xff0c;某些对象的状态在转换过程中&#xff0c;可能由于某种需要&#xff0c;要…
阅读更多...
【Java设计模式】建造者模式 注解@Builder

【Java设计模式】建造者模式 注解@Builder

概念 将一个复杂对象的构造与它的表示分离&#xff0c;使同样的构建过程可以创建不同的表示。它使将一个复杂的对象分解成多个简单的对象&#xff0c;然后一步步构建而成。 每一个具体建造者都相对独立&#xff0c;而与其它的具体建造者无关&#xff0c;因此可以很方便地替换具…
阅读更多...
JavaWeb 手写Tomcat底层机制

JavaWeb 手写Tomcat底层机制

目录 一、Tomcat底层整体架构 1.简介 : 2.分析图 : 3.基于Socket开发服务端的流程 : 4.打通服务器端和客户端的数据通道 : 二、多线程模型的实现 1.思路分析 : 2.处理HTTP请求 : 3.自定义Tomcat : 三、自定义Servlet规范 1. HTTP请求和响应 : 1 CyanServletRequest …
阅读更多...
布隆过滤器，Guava实现布隆过滤器（本地内存），Redis实现布隆过滤器（分布式）

布隆过滤器，Guava实现布隆过滤器（本地内存），Redis实现布隆过滤器（分布式）

一、前言 利用布隆过滤器可以快速地解决项目中一些比较棘手的问题。如网页 URL 去重、垃圾邮件识别、大集合中重复元素的判断和缓存穿透等问题。不知道从什么时候开始&#xff0c;本来默默无闻的布隆过滤器一下子名声大噪&#xff0c;在面试中面试官问到怎么避免缓存穿透&#…
阅读更多...
Multimodal Learning with Transformer: A Survey

Multimodal Learning with Transformer: A Survey

Transformer多模态学习 Abstract1 INTRODUCTION2 BACKGROUND2.1 Multimodal Learning (MML)2.2 Transformers: a Brief History and Milestones2.3 Multimodal Big Data 3 TRANSFORMERS: A GEOMETRICALLY TOPOLOGICAL PERSPECTIVE3.1 Vanilla Transformer3.1.1 Input Tokenizat…
阅读更多...
如何免费申请SSL证书

如何免费申请SSL证书

如何免费申请SSL证书 文章目录 如何免费申请SSL证书前言1. 向域名平台申请SSL证书1.1 购买“免费证书” 2. 进一步进行创建证书设置2.1 对证书的关联域名进行补充 3. 云解析DNS3.1 进行验证信息 前言 我们可以成功地将自己购买的域名&#xff0c;绑定到连接本地群晖NAS的数据隧…
阅读更多...
【LeetCode每日一题】——85.最大矩形

【LeetCode每日一题】——85.最大矩形

文章目录 一【题目类别】二【题目难度】三【题目编号】四【题目描述】五【题目示例】六【题目提示】七【解题思路】八【时间频度】九【代码实现】十【提交结果】 一【题目类别】 矩阵 二【题目难度】 困难 三【题目编号】 85.最大矩形 四【题目描述】 给定一个仅包含 0 …
阅读更多...
Yolov8-pose关键点检测：模型轻量化设计 | 引入Ghostnet、G_ghost、Ghostnetv2、repghost，进行性能对比

Yolov8-pose关键点检测：模型轻量化设计 | 引入Ghostnet、G_ghost、Ghostnetv2、repghost，进行性能对比

💡💡💡本文解决什么问题：Yolov8-pose关键点评估不同轻量级网络的性能，引入Ghostnet、G_ghost、Ghostnetv2、repghost等网络进行可行性分析 Yolov8-Pose关键点检测专栏介绍：https://blog.csdn.net/m0_63774211/category_12398833.html ✨✨✨手把手教你从数据标记到生…
阅读更多...
Python（Web时代）——请求钩子

Python（Web时代）——请求钩子

简介 有时在处理请求之前或之后需要执行一部分代码&#xff0c;比如&#xff1a;创建数据库链接或进行登陆权限认证等&#xff0c;在请求结束时指定数据的交互格式等。 为了避免在每个视图函数中编写重复的代码&#xff0c;flask提供了注册通用函数的功能&#xff08;请求钩子…
阅读更多...
windows永久暂停更新

windows永久暂停更新

目录 1.winr,输入regedit打开注册表 2.打开注册表的这个路径: 计算机\HKEY_LOCAL_MACHINE\SOFTWARE\Microsoft\WindowsUpdate\UX\Settings 右键空白地方新建QWORD值命名为:FlightSettingsMaxPauseDays 3.双击FlightSettingsMaxPauseDays,修改里面的值为100000,右边基数设置…
阅读更多...
17款奔驰S400升级原厂前排座椅通风系统，夏天必备的功能

17款奔驰S400升级原厂前排座椅通风系统，夏天必备的功能

通风座椅的主动通风功能可以迅速将座椅表面温度降至适宜程度&#xff0c;从而确保最佳座椅舒适性。该功能启用后&#xff0c;车内空气透过打孔皮饰座套被吸入座椅内部&#xff0c;持续时间为 8 分钟。然后&#xff0c;风扇会自动改变旋转方向&#xff0c;将更凉爽的环境空气从座…
阅读更多...
Total Variation loss

Total Variation loss

Total Variation loss 适合任务 图像复原、去噪等 处理的问题 图像上的一点点噪声可能就会对复原的结果产生非常大的影响&#xff0c;很多复原算法都会放大噪声。因此需要在最优化问题的模型中添加一些正则项来保持图像的光滑性&#xff0c;图片中相邻像素值的差异可以通过…
阅读更多...
python编写ocr识别图片汉字

python编写ocr识别图片汉字

当你需要构建一个简单的图形用户界面&#xff08;GUI&#xff09;应用程序&#xff0c;并在其中实现光学字符识别&#xff08;OCR&#xff09;功能时&#xff0c;wxPython是一个强大而灵活的选择。wxPython是一个基于Python的跨平台GUI开发框架&#xff0c;结合了wxWidgets C库…
阅读更多...
微信提示操作太频繁怎么办？

微信提示操作太频繁怎么办？

微信使用过程中&#xff0c;遇到“操作太频繁”的提示该怎么办&#xff1f; 而提示频繁最常见的两种情况&#xff1a;加好友频繁和发消息频繁。 微信为什么提示频繁&#xff1f;频繁是因为微信故意这样设置的&#xff0c;压根就不想你群发&#xff01;&#xff01;&#xff0…
阅读更多...
黑马程序员SpringMVC练手项目

黑马程序员SpringMVC练手项目

目录 1、需求 2、项目准备 pom.xml SQL jdbc.properties log4j.properties applicationContext.xml spring-mvc.xml web.xml 3、工作流程 4、难点 项目已经上传到gitee&#xff1a;https://gitee.com/xzl-it/my-projects 1、需求 SpringMVC项目练习&#xff1a;数…
阅读更多...
bagging集成与boosting集成的区别是什么？

bagging集成与boosting集成的区别是什么？

bagging集成与boosting集成的区别 区别一:数据方面 Bagging&#xff1a;对数据进行采样训练; Boosting&#xff1a;根据前一轮学习结果调整数据的重要性。 区别二:投票方面 Bagging&#xff1a;所有学习器平权投票; Boosting&#xff1a;对学习器进行加权投票。 区别三:…
阅读更多...
最新文章
推荐文章

Copyright @ 2022~2023