转自http://blog.csdn.net/qcghdy/article/details/22791077
网络模型包括以下几种
其中,与select相比,epoll是一种的较为高效的多路复用模型。在nginx、memcached等中使用,一般我们自己设计高效http服务器也可以考虑采用这种模型。
本文主要讲述epoll模型(不完全是针对epoll)下读写数据接口使用的注意事项
Linux中 ”一切皆文件的概念“使得我们可以很方便地理解与文件相关的操作。网络编程中遇到的基本函数是 select、epoll、accept、read、write这5个,在阻塞和非阻塞模式下,对他们的调用,尤其是对返回值的判断处理很不同,下面做深入描述
- #include <unistd.h>
- ssize_t read(int filedes, void* buf, size_t nbytes)
- <span style="font-family: Arial, Helvetica, sans-serif; font-size: 12px;">ssize_t write(int filedes, const void* buf, size_t nbytes)</span>
②返回值等于0。 读取异常,读取到文件filedes结尾处了。这里逻辑上要理解为read已经读取完数据
③返回值小于0(-1)。 读取出错,在处理网络请求时可能是网络异常。着重注意当返回-1,此时errno的值EAGAIN、EWOULLDBLOCK,表示内核对应的读缓冲区为空
总之,这个错误表示资源暂时不够,可能read时读缓冲区没有数据, 或者write时写缓冲区满了。遇到这种情况,如果是阻塞socket、 read/write就要阻塞掉。而如果是非阻塞socket、 read/write立即返回-1, 同时errno设置为EAGAIN。
所以对于阻塞socket、 read/write返回-1代表网络出错了。但对于非阻塞socket、read/write返回-1不一定网络真的出错了。可能支持缓冲区空或者满,这时应该再试,直到Resource available。
综上,对于非阻塞的socket,正确的读写操作为:读: 忽略掉errno = EAGAIN的错误,下次继续读;写:忽略掉errno = EAGAIN的错误,下次继续写。对于select和epoll的LT模式,这种读写方式是没有问题的。但对于epoll的ET模式,这种方式还有漏洞。
下面来介绍下epoll事件的两种模式LT(水平触发)和ET(边沿触发),根据可以理解为,文件描述符的读写状态发生变化才会触发epoll事件,具体说来如下:二者的差异在于 level-trigger 模式下只要某个 socket 处于 readable/writable 状态,无论什么时候进行 epoll_wait 都会返回该 socket;而 edge-trigger 模式下只有某个 socket 从 unreadable 变为 readable,或从unwritable 变为writable时,epoll_wait 才会返回该 socket。如下两个示意图:
从socket读数据: 往socket写数据:
所以在epoll的ET模式下,正确的读写方式为:
- 读: 只要可读, 就一直读,直到返回0,或者 errno = EAGAIN
- 写:只要可写, 就一直写,直到数据发送完,或者 errno = EAGAIN
这里的意思是,对于ET模式,相当于我们要自己重写read和write,使其像”原子操作“一样,保证一次read 或 write能够完整的读完缓冲区的数据或者写完要写入缓冲区的数据。因此,实现为用while包住read和write即可。但是对于select或者LT模式,我们可以只使用一次read和write,因为在主程序中会一直while,而事件再下一次select时还会被获取到。但也可以实现为用while包住read和write。从逻辑上讲,一次性把数据读取完整可以保证数据的完整性。
下面来说明这种”原子操作“read和write
- int n = 0;
- while(1)
- {
- nread = read(fd, buf + n, BUFSIZ-1);//读时,用户进程指定的接收数据缓冲区大小固定,一般要比数据大
- if(nread < 0)
- {
- if(errno == EAGAIN || errno == EWOULDBLOCK)
- {
- continue;
- }
- else
- {
- break;//or return;
- }
- }
- else if(nread == 0)
- {
- break;//or return. because read the EOF
- }
- else
- {
- n += nread;
- }
- }
- int data_size = strlen(buf);
- int n = 0;
- while(1)
- {
- nwrite = write(fd, buf + n, data_size);//写时,数据大小一直在变化
- if(nwrite < data_size)
- {
- if(errno == EAGAIN || errno == EWOULDBLOCK)
- {
- continue;
- }
- else
- {
- break;//or return;
- }
- }
- else
- {
- n += nwrite;
- data_size -= nwrite;
- }
- }
- <span style="background-color: rgb(255, 255, 255); font-family: Arial, Helvetica, sans-serif;">注参考文章:</span>
http://blog.csdn.NET/ctthuangcheng/article/details/9716715
网络模型包括以下几种
其中,与select相比,epoll是一种的较为高效的多路复用模型。在nginx、memcached等中使用,一般我们自己设计高效http服务器也可以考虑采用这种模型。
本文主要讲述epoll模型(不完全是针对epoll)下读写数据接口使用的注意事项
Linux中 ”一切皆文件的概念“使得我们可以很方便地理解与文件相关的操作。网络编程中遇到的基本函数是 select、epoll、accept、read、write这5个,在阻塞和非阻塞模式下,对他们的调用,尤其是对返回值的判断处理很不同,下面做深入描述
- #include <unistd.h>
- ssize_t read(int filedes, void* buf, size_t nbytes)
- <span style="font-family: Arial, Helvetica, sans-serif; font-size: 12px;">ssize_t write(int filedes, const void* buf, size_t nbytes)</span>
②返回值等于0。 读取异常,读取到文件filedes结尾处了。这里逻辑上要理解为read已经读取完数据
③返回值小于0(-1)。 读取出错,在处理网络请求时可能是网络异常。着重注意当返回-1,此时errno的值EAGAIN、EWOULLDBLOCK,表示内核对应的读缓冲区为空
总之,这个错误表示资源暂时不够,可能read时读缓冲区没有数据, 或者write时写缓冲区满了。遇到这种情况,如果是阻塞socket、 read/write就要阻塞掉。而如果是非阻塞socket、 read/write立即返回-1, 同时errno设置为EAGAIN。
所以对于阻塞socket、 read/write返回-1代表网络出错了。但对于非阻塞socket、read/write返回-1不一定网络真的出错了。可能支持缓冲区空或者满,这时应该再试,直到Resource available。
综上,对于非阻塞的socket,正确的读写操作为:读: 忽略掉errno = EAGAIN的错误,下次继续读;写:忽略掉errno = EAGAIN的错误,下次继续写。对于select和epoll的LT模式,这种读写方式是没有问题的。但对于epoll的ET模式,这种方式还有漏洞。
下面来介绍下epoll事件的两种模式LT(水平触发)和ET(边沿触发),根据可以理解为,文件描述符的读写状态发生变化才会触发epoll事件,具体说来如下:二者的差异在于 level-trigger 模式下只要某个 socket 处于 readable/writable 状态,无论什么时候进行 epoll_wait 都会返回该 socket;而 edge-trigger 模式下只有某个 socket 从 unreadable 变为 readable,或从unwritable 变为writable时,epoll_wait 才会返回该 socket。如下两个示意图:
从socket读数据: 往socket写数据:
所以在epoll的ET模式下,正确的读写方式为:
- 读: 只要可读, 就一直读,直到返回0,或者 errno = EAGAIN
- 写:只要可写, 就一直写,直到数据发送完,或者 errno = EAGAIN
这里的意思是,对于ET模式,相当于我们要自己重写read和write,使其像”原子操作“一样,保证一次read 或 write能够完整的读完缓冲区的数据或者写完要写入缓冲区的数据。因此,实现为用while包住read和write即可。但是对于select或者LT模式,我们可以只使用一次read和write,因为在主程序中会一直while,而事件再下一次select时还会被获取到。但也可以实现为用while包住read和write。从逻辑上讲,一次性把数据读取完整可以保证数据的完整性。
下面来说明这种”原子操作“read和write
- int n = 0;
- while(1)
- {
- nread = read(fd, buf + n, BUFSIZ-1);//读时,用户进程指定的接收数据缓冲区大小固定,一般要比数据大
- if(nread < 0)
- {
- if(errno == EAGAIN || errno == EWOULDBLOCK)
- {
- continue;
- }
- else
- {
- break;//or return;
- }
- }
- else if(nread == 0)
- {
- break;//or return. because read the EOF
- }
- else
- {
- n += nread;
- }
- }
- int data_size = strlen(buf);
- int n = 0;
- while(1)
- {
- nwrite = write(fd, buf + n, data_size);//写时,数据大小一直在变化
- if(nwrite < data_size)
- {
- if(errno == EAGAIN || errno == EWOULDBLOCK)
- {
- continue;
- }
- else
- {
- break;//or return;
- }
- }
- else
- {
- n += nwrite;
- data_size -= nwrite;
- }
- }