游戏服务器之多线程发送(上)

inline CGateSendPacket& allocSendPacket() { return m_pGate->AllocSendPacket(m_nGateUserIndex); }  
 
CGateSendPacket& ExecSockDataMgr::AllocSendPacket(const int nUserIndex)//nUserIndex 是网关里的用户的索引 
{  
    PRUNGATEUSERSESSION pSession = m_SessionList[nUserIndex];//每个逻辑网关有一个会话列表，每个玩家相对应的会有一个用户索引 
    assert(pSession != NULL);  
    PEXECDATASENDTHREAD pSendThread = &m_SendThreads[nUserIndex % m_nSendThreadCount];//哈希发送线程（发送线程的个数是配置的,目前单逻辑网关有2个发送线程，因为游戏服务器发送的数据比接受的数据要多些） 
    CGateSendPacket *pPacket = pSendThread->pSendPacketPool->allocPacket();  
    pPacket->setSendInfo(pSendThread, nUserIndex, pSession->nVerifyIdx);//设置发送线程指针 
 return *pPacket;  
}  

typedef struct structExecDataSendThread  
{  
    ...  
 int nThreadIdx; //线程id 
    CRITICAL_SECTION SendQueueLock;//互斥锁（临界区） 
    CBList<CGateSendPacket*> *pSendAppendList;//发送添加列表 
    CBList<CGateSendPacket*> *pSendProcList;//发送处理列表 
    CGateSendPacketPool *pSendPacketPool;//发送数据包池 
}EXECDATASENDTHREAD, *PEXECDATASENDTHREAD;  

CGateSendPacket &pack = ((CPlayer*)viewList->pEntity)->allocSendPacket();  
pack.writeCmd(sysBattle, sStartRun);  
pack << data;//写入字节流 
pack.flush();  
//提交网络数据包到发送队列 
inline void flush()  
{  
 if (m_pSendThread)  
    {  
        EnterCriticalSection( &m_pSendThread->SendQueueLock );  
        m_pSendThread->pSendAppendList->add(this);//添加到该线程的发送添加队列 
        LeaveCriticalSection( &m_pSendThread->SendQueueLock );  
        m_pSendThread = NULL;//置空避免重复提交 
    }  
}  
3、发送数据线程例程
把发送队列的数据拷贝到发送缓冲区。
发送发送缓冲区中的数据。
发送时需要验证发送包的验证码（nVerifyIdx）跟会话的验证码是否是一样的(发送的验证码（主要适用于服务器之间的连接的安全验证，对于客户端的连接可考虑去掉)。

[cpp] view plain copy 
void *ExecSockDataMgr::SendDataProcessRoutine(PEXECDATASENDTHREAD pRunThread)  
{  
    TICKCOUNT dwProcStartTick;  
    ExecSockDataMgr *pRunData;  
 int nLockSendBufQLockFail = 0;  
    pRunData = pRunThread->pRunData;  
 while ( !pRunData->m_boStoping )  
    {  
        dwProcStartTick = _getTickCount();  
 if ( pRunData->CopyWaitSendBuffers( pRunThread, TRUE ) )//交换发送队列和添加队列,拷贝会话的发送队列的数据到会话的发送缓冲区 
        nLockSendBufQLockFail = 0;  
 else nLockSendBufQLockFail++;  
        pRunData->CheckSendSessionBuffers( pRunThread );//发送会话的的发送缓冲区的数据 
 //循环小于指定时间则休眠一次（16ms），避免频繁io发送（发送可缓存在队列和发送缓存中） 
        pRunThread->dwProcTick = _getTickCount() - dwProcStartTick;  
 
 if ( pRunThread->dwProcTick < 16 )  
        {  
            dwProcStartTick = _getTickCount();  
            moon::OS::osSleep( 1 );  
        }  
    }  
    ExitThread( 0 );  
}