现在的位置: 首页 > 综合 > 正文

epoll的一点思考(1)

2012年12月10日 ⁄ 综合 ⁄ 共 2426字 ⁄ 字号 评论关闭

最近在学习epoll用法,一直没太搞明白。

网上提到 “ET(edge-triggered)是高速工作方式,只支持no-block socket。在这种模式下,当描述符从未就绪变为就绪时,内核通过epoll告诉你。然后它会假设你知道文件描述符已经就绪,并且不会再为那个文件描述符发送更多的就绪通知,直到你做了某些操作导致那个文件描述符不再为就绪状态了”。

编写代码测试了一下:

如果客户端发送100字节,服务器每次只读取10字节,如果epoll_wait设置了超时并且客户端没有再发送数据,到达超时时间后还会有IN事件触发,如果设置了永不超时(epoll_wait(epfd,events,20,-1)),并且客户端不再发送数据就不会产生IN事件。如果客户端继续发送数据会产生IN事件或者服务器再次mod
IN事件就会有IN事件到达,这样可以读取没有读完的数据。


在IN事件后设置OUT,但是OUT中不再设置IN,如果客户端发送数据,则会触发OUT事件。

if(events[i].events&EPOLLIN)
 {                
        ev.data.fd=sockfd;             
        ev.events=EPOLLOUT|EPOLLET;              
        epoll_ctl(epfd,EPOLL_CTL_MOD,sockfd,&ev);
             
}  else if(events[i].events&EPOLLOUT)
 {
       cout << "EPOLLOUT" << endl;            
       //ev.data.fd=sockfd;
        //设置用于注测的读操作事件
        // ev.events=EPOLLIN|EPOLLET;
       //修改sockfd上要处理的事件为EPOLIN
       // epoll_ctl(epfd,EPOLL_CTL_MOD,sockfd,&ev);
}

如果客户端多次发送了数据,server单线程在第一次触发IN事件后server在一直读取直到错误,就算客户端多次发送只要服务器收取到就不会再次触发IN事件。

单线程代码如下:

if(events[i].events&EPOLLIN)
{
       printf("EPOLLIN\n);    
        sockfd = events[i].data.fd;
        char buf;
        sleep(3);
         while (read(sockfd, &buf, 1) > 0) 
        {
            printf("%c\n",buf);
        }

}


对于客户端程序关闭socket或异常关闭,会触发IN事件,recv返回0。

需要补充关机、拔掉网线、断电等情况,考虑设置keep-alive与不设置keep-alive分别测试。

阻塞socket情况下:

(1)无Keep-alive情况下,断电与拔网线不会收到IN事件;关机与程序退出一样会触发IN事件,read返回0;

(2)在客户端设置keep-alive,对服务器没有影响,不会产生in事件。

(3)在服务器设置keep-alive,如果拔掉网线,在TCP_KEEPINTVL*TCP_KEEPCNT左右会产生in事件,如果没有有数据,recv返回-1,错误信息为Connect time out(ETIMEDOUT);如果内核接收队列还有数据只会触发一次in事件,recv返回读出的字节数,如果继续读取会得到Connect
time out。

非阻塞socket情况:

(1)不拔掉网线,接受in事件后循环读,如果再没有数据可读会返回EAGAIN Resource temporarily unavailable (may be the same value as EWOULDBLOCK)

(2)其他情况同阻塞socket


设置keep-alive代码如下:

int socket_set_keepalive( int fd)
{
    int ret, error, flag, alive, idle, cnt, intv;
    
    /* Set: use keepalive on fd */
    alive = 1;
    if (setsockopt (fd, SOL_SOCKET, SO_KEEPALIVE, &alive, sizeof alive) != 0)
    {
        printf ("Set keepalive error: %s.\n" , strerror (errno));
        return -1;
    }
    
    /* 10秒钟无数据,触发保活机制,发送保活包 */
    idle = 10;
    if (setsockopt(fd, SOL_TCP, TCP_KEEPIDLE , &idle, sizeof idle) != 0)
    {
        printf ("Set keepalive idle error: %s.\n" , strerror (errno));
        return -1;
    }
    
    /* 如果没有收到回应,则5秒钟后重发保活包 */
    intv = 5;
    if (setsockopt(fd, SOL_TCP, TCP_KEEPINTVL , &intv, sizeof intv) != 0)
    {
        printf ("Set keepalive intv error: %s.\n", strerror (errno));
        return -1;
    }
    
    /* 连续3次没收到保活包,视为连接失效 */
    cnt = 3;
    if (setsockopt(fd, SOL_TCP, TCP_KEEPCNT , &cnt, sizeof cnt) != 0)
    {
        printf ("Set keepalive cnt error: %s.\n", strerror (errno));
        return -1;
    }
    
    return 0;
}

 keep-alive参考:http://blog.csdn.net/guomsh/article/details/8484222

抱歉!评论已关闭.