GS与MS之间通信

注意GS与MS是两个线程，现在是每个map一个线程，他们之间是内部协议进行通信的，那既然是两个线程那如何通信呢，看了net进程通信这个就比较简单了

举个例子

m_pMap->Gs2MsData(gs2ms_add_player, m_nChannelId, (void*)&rActorEx, sizeof(rActorEx));//发送玩家上线包

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

{

    MapPkt pkt;

    pkt.channelId = channel_id;

    pkt.data = m_memPool.popPkt(len);注意这个m_memPool是线程安全的队列,内部是boost无锁队列实现的

    memcpy(pkt.data, data, len);//不同线程需要内存拷贝，不可能使用同一块地址

    pkt.len = len;

    pkt.cmd = cmd;

    PushPkt(pkt);

}

void ThrTransData::PushPkt(MapPkt Pkt)

{

    for (;;)

    {

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

            break;

        cxx11::this_thread::interruptible_wait();

    }

}

那看看MS这边是如何取的

在share初始化的时候开启了一个线程，这个线程可以说整个map的数据都是这里面处理的

bool ThrTransData::GetDataFromQueue(MapPkt* pPkt)

{

    if(m_gs2msPkts2.empty())

        return false;

    {

        MapPkt tmpPkt;

        if(m_gs2msPkts2.pop(tmpPkt))//从GS到MS这端的无锁队列中取包

        {

            *pPkt = tmpPkt;

            return true;

        }

        return false;

    }

    return true;

}

if(GetDataFromQueue(&Pkt))

{

    ProcessPkt(Pkt);//解析包调用相应函数

    m_memPool.pushPkt(Pkt.data, Pkt.len);//将内存池归还

    nCount++;

    if(nCount > )

    {

        nCount = ;

        m_spTimerFactory->driveTimer();

    }

    continue;

}

//至此从GS到MS这边的包就是这样处理的

那从MS到GS的包

从Map需要发到GS的包也不多，还有一种通过GS转到map的

SendCmd2Gs(ms2gs_prop_mgr, nChannelID, pData, nLen);

void SendCmd2Gs(int nCmd, int nChannelId, void* pData, int nLen)

{

    MapPkt Pkt;

    Pkt.cmd = nCmd;

    Pkt.channelId = nChannelId;

    char* pszNewBuffer = new char[nLen];//这个是自己new的，发送到MS是从内存池中获取的

    memcpy(pszNewBuffer, pData, nLen);

    Pkt.data = pszNewBuffer;

    Pkt.len = nLen;

    PushData2GS(Pkt);

};

void PushData2GS(const MapPkt& Pkt)

{

    while()

    {

        if(m_quePkts2Gs.push(Pkt))//从MS发送到GS的队列

    }

}

那GS是如何去的呢

void Share::ProcMapSendData()//这个是GS驱动的

{

    if(!itMap.second->RecvData(Pkt))//从无锁队列中取包

        break;

    if(Pkt.cmd == ms2gs_转client_cmd)//针对包进行处理

    {

        OnTurnToClient(Pkt.channelId, Pkt.data, Pkt.len);

    }

}

//开来发包都是双向的，需要两个队列，这个在net那边也是的

//其次就是需要额外的内存放到队列中，因为不可能去操作同一块内存的，要么自己new，要么从内存池中分配

//MS与GS之间通过MapPkt进行通信，对于客户端和服务器通过protocol通信，通常是自己定义一块buf，然后打包到BUF中，net那块也是在内存池中分配一块然后存储这个buf，因为这个buf也是公用的

//刚开始不懂程序就是这些内存问题没有搞清楚