NGP处理部分(主要就是这个RunOnce函数，客户单肯定是开个线程取调用这个RunOnce的)
void NGP::RunOnce()
{
m_spTimerFac->driveTimer();//客户端心跳包驱动 //先检查一下其他命令
if(m_queFunctions.size())
{
for (;;)
{
std::function<void()> fun;
{
std::lock_guard<std::mutex> lock(m_PktMutex);
fun = m_queFunctions.front();
}
fun();
{
std::lock_guard<std::mutex> lock(m_PktMutex);
m_queFunctions.pop();
}
if( == m_queFunctions.size())
break;
}
}
//检查数据包,一次最少处理10个命令
for (int i = ; i < ; i++)
{
if (m_quePktQueue.size() == )
break; date_pkt pkt;
{
std::lock_guard<std::mutex> lock(m_PktMutex);
pkt = m_quePktQueue.front();
m_quePktQueue.pop();
}
ProcessDate(pkt.date, pkt.len);
delete[] pkt.date;
}
//_TcpLink->run_one();
} 连接事件就这几个
OnConnectFailed--->直接连接失败了，在bufferevent_socket_connect，这个就相当于socket里面的connect
OnConnected--->连接成功了
OnDisconnected--->这个是服务端突然蹦了，这样客户端也能收到通知 这些事件相应的绑定函数放到m_queFunctions队列中，runonce可以直接调用传递进来的绑定函数
bool NGP::OnRec(void* pBuffer, int nSize)
{
date_pkt pkt;
pkt.len = nSize;
pkt.date = new char[nSize];//注意在runonce中释放内存
memcpy(pkt.date, pBuffer, nSize);
{
std::lock_guard<std::mutex> lock(m_PktMutex);
m_quePktQueue.push(pkt);
}
return true;
}
对于接收的包放到m_quePktQueue，在初始化的时候会创建一个map，key是协议，value是绑定好的函数对象，在runonce中
使用protocol来解析发送过来的包，这个包是符合协议的，那么第一个字节就是协议，后面是长度和内容，然后根据协议查找map，调用绑定好的函数。
根据协议类型调用绑定函数这种方法在服务器很多。
对于协议解析和中间的线程加锁理解不是太好