码迷,mamicode.com
首页 > 其他好文 > 详细

一个包的libevent流程

时间:2014-11-06 00:39:13      阅读:134      评论:0      收藏:0      [点我收藏+]

标签:style   blog   color   ar   os   使用   for   sp   数据   

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

一个包的libevent流程

标签:style   blog   color   ar   os   使用   for   sp   数据   

原文地址:http://www.cnblogs.com/zzyoucan/p/4077605.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!