我学xingo golang服务器之

语音解读

图文解释

上一节，
http://www.jb51.cc/article/p-yxckckpk-bqm.html
学习了xingo服务器处理客户端api的流程，
这一节进行服务器下发数据，u3d进行分解处理：
unity3d c# protobuf生成:

protogen -i:msg.proto -o:msg.cs -ns:Pb
pause

如果你把protoc.exe和protogen.exe 加入了win的环境变量 保存在GenCsharpProto.bat，双击即可生成
c#和golang protobuf生成工具 xingo交流群：535378240 群里文件有
我上传这里了也可以下载：
http://download.csdn.net/download/atgczcl/9897634
protobuf message的写法上一节我已经讲过了，就不再详细讲解；

message broadCast{ int32 Pid=1; int32 Tp=2; oneof Data { string Content=3; Position P=4; int32 ActionData=5; } }

xingo_demo_unity3d 处理xingo服务器分解：
这是官方unityd demo 的地址：
https://git.oschina.net/viphxin/xingo_demo_unity3d
git clone 下来即可运行
先看一下unity里面的程序启动流程：

最终在NetLogic(int mid,byte[] bytes)函数进行了协议分解：
SocketClient.cs

//收到消息
void OnRecieveMessageDeal(ByteBuffer buffer,UInt32 len = 0)
    {
        UInt32 length = 0;
        UInt32 mainId = 0;
        if (len != 0)
        {
            length = len;
        }
        else
        {
            length = buffer.ReadUInt32(); //数据字节长度
        }
        mainId = buffer.ReadUInt32(); //msgid
        byte[] b = buffer.ReadBytes((int)length); //数据字节

        NetLogic((int)mainId,b);
        int next = (int)buffer.ReadUInt32();
        Debug.LogError("len=" + len + "|msgid=" + mainId + "|next=" + next);
        if (next != 0)
        {
            OnRecieveMessageDeal(buffer,(UInt32)next);
        }
    }

    void NetLogic(int mid,byte[] bytes)
    {
        if (mid == 1)
        {
            SyncPid pid;
            pid = SyncPid.Parser.ParseFrom(bytes);

            if (NetMgr.OnBorn != null)
            {
                NetMgr.OnBorn(pid.Pid);
                GameMgr.PlayerIDS.Add(pid.Pid);
                Debug.Log("Player: " + pid);
            }
        }


        if (mid == 200)
        {

            broadCast bc;
            bc = broadCast.Parser.ParseFrom(bytes);
            //Debug.Log("mid 200: " + bc);

            if (bc.Tp == 1)
            {
                //talk
                if (bc.Content != null)
                {
                    TalkCenter.Content = bc.Content;
                    TalkCenter.PlayerID = bc.Pid.ToString();
                    TalkCenter.TalkFlag = true;
                }
            }
            if (bc.Tp == 2)
            {
                //有玩家加入
                if (!GameMgr.PlayerIDS.Contains(bc.Pid))
                {
                    GameMgr.BornPlayer(bc);
                    GameMgr.PlayerIDS.Add(bc.Pid);
                    Debug.Log("born player: " + bc.Pid + " pos: " + bc.P);
                }
                else
                {
                    if (NetMgr.OnMove != null)
                    {
                        NetMgr.OnMove(bc);
                    }
                }
            }

            //广播位移和旋转
            if (bc.Tp == 3)
            {
                if (NetMgr.OnMove != null)
                {
                    NetMgr.OnMove(bc);
                }

            }

            //广播移动的坐标
            if (bc.Tp == 4)
            {
                if (NetMgr.OnMove != null)
                {
                    NetMgr.OnMove(bc);
                }
            }
        }

        //下线
        if (mid == 201)
        {
            SyncPid pid;
            pid = SyncPid.Parser.ParseFrom(bytes);
            if (NetMgr.OnOver != null)
            {
                NetMgr.OnOver(pid.Pid);
            }
            Debug.Log("Player: " + pid.Pid + " leave home");
        }

        //上线同步
        //不需要显示所有玩家  服务器只给周围玩家
        if (mid == 202)
        {
            SyncPlayers sPlayer;
            sPlayer = SyncPlayers.Parser.ParseFrom(bytes);
            Debug.Log("202 count:　"  + sPlayer.Ps.Count);
            ArrayList players = new ArrayList();
            for (int i = 0; i < sPlayer.Ps.Count; i++)
            {
                Player p = sPlayer.Ps[i];
                if (!GameMgr.PlayerIDS.Contains(p.Pid))
                {
                    //GameMgr.BornPlayer(p);
                    players.Add(p);
                    GameMgr.PlayerIDS.Add(p.Pid);
                }

            }
            GameMgr.BornPlayer(players);
        }
    }

这里有mid=200,201,202,
对应服务器上面的自己写的player.go里面：

协议201就是下线，

p.SendMsg(200,data)
this.SendMsg(200,pdata)

202 //上线同步
//不需要显示所有玩家 服务器只给周围玩家

//分包发送
per := 20
ps := msg.Ps
for i:=0; ;i++{
    if i*per > len(ps) - 1{
        break
    }
    if i*per + per > len(ps) - 1{
        msg.Ps = ps[i*per:]
    }else{
        msg.Ps = ps[i*per: i*per + per]
    }
    this.SendMsg(202,msg)
}

广播消息：
bc.Tp=1 聊天
bc.Tp=2 有玩家加入
bc.Tp=3 广播位移和旋转
bc.Tp=4 广播移动的坐标

可以看到最终客户端的协议分解全部都在SocketClient.cs 里面进行的，有些逻辑也在里面，协议分解就完了；

下节进行多玩家同步出生过程分解：