//一个发包的流程 第一个包就是客户端的心跳包，现在加了版本的包 再来看看这个发包打包过程，过程坚持，但理解费劲 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); } }
关于这个最终到达GS还有很多东西要做，暂时分析到这。