//一个发包的流程第一个包就是客户端的心跳包，现在加了版本的包再来看看这个发包打包过程，过程坚持，但理解费劲void NGP::OnliveTimer()//客户端心跳，5s发一次{    SendCmd(c2s_on_live, NULL, 0);}bool NGP::SendCmd(int nCmd, void* pData, int nLen){    //std::wstring msg = L"发送命令：";    //msg += boost::lexical_cast<std::wstring>(cmd);    //m_share->log(msg.c_str());    //发送获取游戏列表请求    Protocol rpt = {0};    rpt.cmd_type = nCmd;    rpt.content = pData;    rpt.size    = nLen;    std::vector<char> buffer;    buffer.resize(nLen + sizeof(Protocol));//这个长度个人感觉可以-sizeof(void*)，这个位置其实是被覆盖的    int send_len = rpt.to_buffer(&buffer[0], buffer.size());    for (;;)    {         bool b = m_spTcpLink->Send(&buffer[0], send_len);        if (b)            break;        std::this_thread::sleep_for(std::chrono::milliseconds(5));    }    return true;}//包的格式（这个就是初始包发送的格式）-(一个字节的协议)----(四个字节的长度表示后面内容的大小)-----------------(包发的内容)struct Protocol{    unsigned char    cmd_type;    int                size;//content的长度, 不包含本协议头    void*            content;    int to_buffer(void* buffer, int buffer_len)//挺难理解的    {        if(!buffer)            return -1;        int total_size = size + sizeof(Protocol) - sizeof(void*);//- sizeof(void*)是因为到时就是从这个指针的位置开始复制的        if(buffer_len < total_size)//buffer_len是提供的内存大小,total_size是打包后的总大小            return -1;        Protocol* p = (Protocol*)buffer;//把内存模型看成Protocol模型        p->cmd_type = this->cmd_type;        p->size = this->size;        if (content)        {            memcpy(&p->content, content, size);//从指针开始位置复制内容        }        return total_size;    }}//此包在libevent又进行了一次打包过程----(4个字节，表示后面包的总长度)-(一个字节的协议)----(四个字节的长度表示后面内容的大小)-----------------(包发的内容)所以对于心跳包的长度是9个字节//服务端接受到这个包的流程线程的读事件被调用/* 读数据流 */void Channel::read_datastream(struct bufferevent* bev){    //bufferevent_read每次会将输入缓冲中的数据读出来，好像最多读4096个字节，那这么大的数据有可能是多个包，还有可能一个包都不到，这是个问题    size_t len = bufferevent_read(bev, m_buf, sizeof(m_buf));/** * [测试]：先解锁再加锁，防止此线程在分配内存失败的时候死循环等待时，main_thread的send_data陷入阻塞。 */        evbuffer_unlock(bev->output);     //auto& in = bev->input;    lock一样    //auto& out = bev->output;    m_readStream.Push(m_buf, len);//datastream相当于一个缓冲的作用，这个过程看懂废我好大劲，最后还是在同时的帮助下才了解    read_pack();    evbuffer_lock(bev->output);}void Push(const void * pBuf, int nLen){    char* pBuf2 = (char*)pBuf;        m_StreamBuffer.insert(m_StreamBuffer.end(), pBuf2, pBuf2 + nLen);//每次将包插入最后一个位置的地方}/* 读包 */void Channel::read_pack(){    if(m_readStream.Size() < 4)//如果其大小小于4就表示读完了，不可能存在小于4个字节的包，有可能是不完整的包        return;    size_t len = *(size_t*)m_readStream.Peek();//获取前四个字节，表示包内容的长度    if( m_readStream.Size() < 4 + len)//表示包不符合规则，应该>=，当然也有可能是因为这个包是不完整的包，等下次再解析        return;    m_event->on_receive_data(m_id, m_readStream.Peek() + 4, len); //对包进行处理    m_readStream.Pop(4 + len);//每个包逃过下次读取位置    read_pack();//一直读到完为止}void Pop(int nLen){    m_head_size += nLen;//将头标记移动    if(m_head_size > m_buff_len)    {        //可以将这个数组当成循环队列进行使用，循环队列还有种方式就是两个游标        m_StreamBuffer.erase(m_StreamBuffer.begin(), m_StreamBuffer.begin() + m_head_size);//删掉重新预留，个人理解有可能是防止读取错误，具体不是太清楚        m_head_size = 0;        m_StreamBuffer.reserve(m_buff_len);    }}