GS发包到MS(GS,MS包交互过程)

例:人物上线

首先看看其实如何确定是哪张地图的

数据库首先只保存一个mapid

在share初始化的时候已经初始化了所有map，并保存了map的指针信息，其key就是mapid

if(rActorEx.GetMapID() <= )

    rActorEx.SetMapID();

int mapID = rActorEx.GetMapID();

rActorEx.m_nBodyID = m_pShare->TGetnBodyId(rActorEx.GetProf(), rActorEx.GetSex());//现在那个bodyid用到了

m_pMap = m_pShare->GetMapByMapId(mapID);//通过mapid就能获得map指针信息

if(!m_pMap)

{

    m_ActorId = ;

    return;

}

m_pMap->Gs2MsData(gs2ms_add_player, m_nChannelId, (void*)&rActorEx, sizeof(rActorEx));//传入MS,m_pMap即玩家所在地图指针

void Map::Gs2MsData(int cmd, int channel_id, void* data, int len)

{

    MapPkt pkt;

    pkt.channelId = channel_id;

    pkt.data = m_memPool.popPkt(len);//从内存池中分配一块内存出来，以前用的new，然后这个new很容易失败的

    memcpy(pkt.data, data, len);

    pkt.len = len;

    pkt.cmd = cmd;

    PushPkt(pkt);

}

//接下来就是起的线程的作用了

void ThrTransData::PushPkt(MapPkt Pkt)

{

#ifdef BOOST_LOCKFREE

    for (;;)

    {

        if(m_gs2msPkts2.push(Pkt))//将这个包放入无锁队列中

            break;

        cxx11::this_thread::interruptible_wait();

    }

#else

    {

        cxx11::lock_guard lock(m_mtxGs2Ms);

        m_queGs2MsPkts.push(Pkt);

    }

#endif

};

void ThrTransData::ThreadLoop()

{

    //SetThreadPriority(GetCurrentThread(), THREAD_PRIORITY_HIGHEST);

    MapPkt Pkt;

    try

    {

        int nCount = ;

        while (true)

        {

            if(GetDataFromQueue(&Pkt))//从无锁队列中取包

            {

                ProcessPkt(Pkt);

                m_memPool.pushPkt(Pkt.data, Pkt.len);

                nCount++;

                if(nCount > )

                {

                    nCount = ;

                    m_spTimerFactory->driveTimer();

                }

                continue;

            }

            {

                m_spTimerFactory->driveTimer();

                if (m_bStopWork)

                    break;

                cxx11::this_thread::interruptible_wait();

            }

        }

    }

    catch(...)

    {

        char szMsg[] = {};

        sprintf(szMsg, "【%s】线程%dMap :Pkt.cmd = %d",

            __FUNCTION__, ::GetCurrentThreadId(), Pkt.cmd);

        safe::error_msg(szMsg);

    }

}

void Map::ProcessPkt(MapPkt pkt)

{

    //...

    //gs2ms_add_player属于GS与MS通信的内部协议，内部协议采用树的形式，平行关系就太多了管理不方便

    else if(gs2ms_add_player == pkt.cmd)//玩家进入地图消息，仅仅是个小例子

    {

        PlayerChannel* pPC = new PlayerChannel(this);//这个PlayerChannel是很大的一个模块，玩家信息，回头再看

        //加到地图中，但是并未激活该玩家

        int nChannelId = pPC->OnPlayerEnter(pkt.data, pkt.len);

        m_vecPlayerChannel[nChannelId] = pPC;

        AddPlayer(nChannelId);

    }

    //...

}