Epoll Reactor模型的部分代码[选自gxc]

发布时间：2020-12-15 04:57:52 所属栏目：百科来源：网络整理

导读：之前写过的一个Linux下Select模型也是采取类似的方法，在另外的线程里面使用循环来执行update. 文章经验实在太重要了：epoll的一些补充提到几个Epoll的关键问题，这里借鉴作者的说法，记录一下，感谢作者的文章。默认使用的是ET模式，即，边沿触发，类似于

之前写过的一个Linux下Select模型也是采取类似的方法，在另外的线程里面使用循环来执行update.
文章经验实在太重要了：epoll的一些补充提到几个Epoll的关键问题，这里借鉴作者的说法，记录一下，感谢作者的文章。

默认使用的是ET模式，即，边沿触发，类似于电平触发，epoll中的边沿触发的意思是只对新到的数据进行通知，而内核缓冲区中如果是旧数据则不进行通知，所以在do_use_fd函数中应该使用如下循环，才能将内核缓冲区中的数据读完。

view plain print ?

while(1){
len=recv(*******);
if(len==-1){
if(errno==EAGAIN)
break;
perror("recv");
break;
}
dosomethingwiththerecveddata........
}

在上面例子中没有说明对于listen socket fd该如何处理，有的时候会使用两个线程，一个用来监听accept另一个用来监听epoll_wait，如果是这样使用的话，则listen socket fd使用默认的阻塞方式就行了，而如果epoll_wait和accept处于一个线程中，即，全部由epoll_wait进行监听，则，需将listen socket fd也设置成非阻塞的，这样，对accept也应该使用while包起来（类似于上面的recv），因为，epoll_wait返回时只是说有连接到来了，并没有说有几个连接，而且在ET模式下epoll_wait不会再因为上一次的连接还没读完而返回，这种情况确实存在，我因为这个问题而耗费了一天多的时间，这里需要说明的是，每调用一次accept将从内核中的已连接队列中的队头读取一个连接，因为在并发访问的环境下，有可能有多个连接“同时”到达，而epoll_wait只返回了一次。

Reactor模型关键处理代码如下：

view plain print ?

while(_run){
update();
}

view plain print ?

voidCEpollReactor::update()
{
intepret=epoll_wait(_epollHandle,_epollEvents,EVENT_COUNT,200);
if(epret==-1)
{
debug::send(NETWORK,"epoll_waiterrorerrno=%d.",errno);
debug::send(NETWORK,"%s.",strerror(errno));
//break;
return;
}
updateTimerList();
if(epret==0)
{
//debug::send(NETWORK,"EPOLLtimeouted.");
//timeout
}
if(epret>0)
{
for(inti=0;i<epret;++i)
{
CSocket*socket=(CSocket*)(_epollEvents[i].data.ptr);
if(_epollEvents[i].events&(EPOLLERR|EPOLLHUP))
{
debug::send(NETWORK,"EPOLLERRonfd%d.",socket->getHandle());
socket->handleClose();
socket->setReactor(NULL);
socket->close();
continue;
}
intret=0;
if(_epollEvents[i].events&EPOLLIN)
{
debug::send(NETWORK,"EPOLLINonfd%d.",socket->getHandle());
ret=socket->handleRead();
}
if(ret==-1)
{
socket->handleClose();
socket->setReactor(NULL);
socket->close();
continue;
}
if(_epollEvents[i].events&EPOLLOUT)
{
debug::send(NETWORK,"EPOLLOUTonfd%d",socket->getHandle());
ret=socket->handleWrite();
}
if(ret==-1)
{
socket->handleClose();
socket->setReactor(NULL);
socket->close();
continue;
}
}
}
}

很多函数并不存在，但是从代码中我们就可以大致了解该类如何开发，扩展性会比较好！我将尽快完成该类，并在博客放出，希望大家喜欢。

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!