首页 > 代码库 > GS与MS之间通信

GS与MS之间通信

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(1);    }}那看看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 > 30)    {        nCount = 0;        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(1)    {        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也是公用的//刚开始不懂程序就是这些内存问题没有搞清楚

 

GS与MS之间通信