epoll 的accept , read, write
http://www.ccvita.com/515.html
在一个非阻塞(fcntl)的socket上调用read/write函数, 返回EAGAIN或者EWOULDBLOCK(注: EAGAIN就是EWOULDBLOCK)
这个错误表示资源暂时不够, 可能read时, 读缓冲区没有数据, 或者, write时,写缓冲区满了. (此处读写缓冲区指的是socket的缓冲区,而不是read或write调用形参中的buffer)
遇到这种情况, 如果是阻塞socket, read/write就要阻塞掉.而如果是非阻塞socket, read/write立即返回-1, 同 时errno设置为EAGAIN.所以, 对于阻塞socket, read/write返回-1代表网络出错了.但对于非阻塞socket, read/write返回-1不一定网络真的出错了.可能是Resource temporarily unavailable. 这时你应该再试, 直到Resource available.
综上, 对于non-blocking的socket, 正确的读写操作为:
读: 忽略掉errno = EAGAIN的错误, 下次继续读
写: 忽略掉errno = EAGAIN的错误, 下次继续写
对于select和epoll的LT模式, 这种读写方式是没有问题的. 但对于epoll的ET模式, 这种方式还有漏洞.
epoll的两种模式 LT 和 ET
二者的差异在于 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
正确的读:
n = 0; while ((nread = read(fd, buf + n, BUFSIZ-1)) > 0) { n += nread; } if (nread == -1 && errno != EAGAIN) { perror("read error"); }
正确的写:
int nwrite, data_size = strlen(buf); n = data_size; while (n > 0) { nwrite = write(fd, buf + data_size - n, n); if (nwrite < n) { if (nwrite == -1 && errno != EAGAIN) { perror("write error"); } break; } n -= nwrite; }
我的理解:LT模式下,read、write不需要while循环了,即使这次系统调用没有处理完所有数据,下次调用epoll_wait时也会返回该就绪事件(上述write相关代码感觉不对)
ssize_t read(int fd,void *buf,size_t nbyte)
ssize_t write(int fd,const void *buf,size_t nbytes)
write函数将buf中的nbytes字节内容写入文件描述符fd.成功时返回写的字节数.失败时返回-1. 并设置errno变量. 在网络程序中,当我们向套接字文件描述符写时有俩种可能.
1)write的返回值大于0,表示写了部分或者是全部的数据.
2)返回的值小于0,此时出现了错误.我们要根据错误类型来处理. 如果错误为EINTR表示在写的时候出现了中断错误.
如果为EPIPE表示网络连接出现了问题(对方已经关闭了连接)
正确的accept,accept 要考虑 2 个问题
(1) 阻塞模式 accept 存在的问题
accept每次都是从已经完成三次握手的tcp队列中取出一个连接
考虑这种情况: TCP 连接被客户端夭折,即在服务器调用 accept 之前,客户端主动发送 RST 终止连接,导致刚刚建立的连接从就绪队列中移出,如果套接字被设置成阻塞模式,服务器就会一直阻塞在 accept 调用上(即此时没有客户端连接给accept),直到其他某个客户建立一个新的连接为止(即accept接受新的连接,返回)。但是在此期间,服务器单纯地阻塞在accept 调用上,就绪队列中的其他描述符都得不到处理(我的理解:其他fd读写事件就绪但得不到处理).
解决办法是把监听套接口设置为非阻塞,当客户在服务器调用 accept 之前中止某个连接时,accept 调用可以立即返回 -1, 这时源自 Berkeley 的实现会在内核中处理该事件,并不会将该事件通知给 epoll,而其他实现把 errno 设置为 ECONNABORTED 或者 EPROTO 错误,我们应该忽略这两个错误。
(2) ET 模式下 accept 存在的问题
考虑这种情况:多个连接同时到达,服务器的 TCP 就绪队列瞬间积累多个就绪连接,由于是边缘触发模式,epoll 只会通知一次,accept 只处理一个连接,导致 TCP 就绪队列中剩下的连接都得不到处理。
解决办法是用 while 循环抱住 accept 调用,处理完 TCP 就绪队列中的所有连接后再退出循环。如何知道是否处理完就绪队列中的所有连接呢? accept 返回 -1 并且 errno 设置为 EAGAIN 就表示所有连接都处理完。
综合以上两种情况,服务器应该使用非阻塞地 accept, accept 在 ET 模式下 的正确使用方式为:
while ((conn_sock = accept(listenfd,(struct sockaddr *) &remote, (size_t *)&addrlen)) > 0) { handle_client(conn_sock); } if (conn_sock == -1) { if (errno != EAGAIN && errno != ECONNABORTED && errno != EPROTO && errno != EINTR) perror("accept"); }
我的总结:当epoll在ET模式下,read、write、accept操作都在while循环中执行,使得所有数据或者连接都处理完,因为ET模式下,epoll_wait只返回一次
一道腾讯后台开发的面试题
使用Linux epoll模型,水平触发模式,当socket可写时,会不停的触发 socket 可写的事件,如何处理?
第一种最普遍的方式:
需要向 socket 写数据的时候才把 socket 加入 epoll ,等待可写事件。接受到可写事件后,调用 write 或者 send 发送数据。当所有数据都写完后,把 socket 移出 epoll。
这种方式的缺点是,即使发送很少的数据,也要把 socket 加入 epoll,写完后在移出 epoll,有一定操作代价。
一种改进的方式:
开始不把 socket 加入 epoll,需要向 socket 写数据的时候,直接调用 write 或者 send 发送数据。如果返回 EAGAIN,把 socket 加入 epoll,在 epoll 的驱动下写数据,全部数据发送完毕后,再移出 epoll。
这种方式的优点是:数据不多的时候可以避免 epoll 的事件处理,提高效率。
转载于:https://www.cnblogs.com/ljygoodgoodstudydaydayup/p/5655984.html
epoll 的accept , read, write相关推荐
- linux内核线程socket,从Linux源码看Socket(TCP)的accept
从Linux源码看Socket(TCP)的accept 前言 笔者一直以为若是能知道从应用到框架再到操做系统的每一处代码,是一件Exciting的事情. 今天笔者就从Linux源码的角度看下Serve ...
- 计算机科学精彩帖子收集
linux源码 LXR 源自"the Linux Cross Referencer",中间的"X"形象地代表了"Cross".与 Sourc ...
- C++实现即时通信软件
1.1 实验内容 本实验使用 C++ 实现一个具备服务器端和客户端的即时通信聊天室. 这个项目会学习C++网络开发的基本概念,同时可以熟悉Linux下的C++程序编译方法及简单的Makefile编写. ...
- Nginx学习之Nginx高性能的实现原理
Nginx 采用的是多进程(单线程) & 多路IO复用模型,使用了 I/O 多路复用技术的 Nginx,就成了"并发事件驱动"的服务器,同时使用sendfile等技术,最终 ...
- redis、memcached、Nginx组件中的TCP
Redis.memcached.Nginx组件 一.网络编程需要关注的问题 二.网络io职责 1.操作io 2.检测io 3.epoll结构 三.reactor原理 四.Redis.memcached ...
- 一、重写muduo网络库之服务器编程及测试
目录 一.基于muduo网络库开发服务器程序的基本步骤 1.组合TcpServer对象 2.创建EventLoop事件循环对象的指针 3.明确TCPServer构造函数需要的参数,输出ChatServ ...
- 从0开始,在Linux中配置Nginx反向代理、负载均衡、session共享、动静分离
写这篇文章花费了我近一周的时间,参考网上许多优秀的博客文章,我不敢说写的很好,至少很全很详细.本文先介绍原理部分,然后再进行实战操作,我认为这样才会有更深的理解,不过这也导致了文章篇幅很长.但是,如果 ...
- linux epoll用法
epoll 是 linux 特有的 I/O 复用函数.它是把用户关心的文件描述符事件放在内核的一个事件列表中,故而,无须像select和poll一样每次调用都重复传入文件描述符或事件集.但是, epo ...
- epoll ET模式服务器和客户端源码例子
关于epoll替代select作为高性能服务器的事件通知机制的资料相当多,我就不在这里班门弄斧了,有兴趣的同学可以参考末尾的文献链接. 这里说明如下: 1.epoll是linux下高并发服务器的完美方 ...
最新文章
- 获取注解中的属性信息
- 他入狱10年自学数学,如今凭借手稿发了篇论文,被同行评价“足以开辟数论新领域”...
- 用Font Awesome代替网页icon小图标
- hdu5452(2015沈阳网络赛C题)
- 访问Mysql数据库,连接字符串配置
- Genymotion 下载一直失败的解决办法
- 2016年印度公有云服务市场将达13亿美元
- python sort怎么用,Linux Sort命令详细用法(有实例)
- MySQL 多表查询、连接查询(内连接、外连接)
- Unity Shader: 优化GPU代码--用step()代替if else等条件语句。
- 菜鸟涂鸦作品展_No.1
- xd使用技巧_真香!3个技巧,帮你获得面试机率提升300%
- 知了课堂项目part1
- Linux系统安全基本措施及应用(关于账户安全以及sudo权限,安全认证等)
- filp/whoops初体验
- openssl开发库安装时的踩坑指南
- html设置ios状态栏颜色,ios 显示html标签,超链接颜色以及下划线的处理
- openwrt源码分析_Luci流程分析(openwrt下)
- eclipse java1.8_不同版本Eclipse对JDK版本要求
- 酿酒知识-年会喝酒?你打算如何安排你的酒桌呢?
热门文章
- Redfield.Sketch.Master中文版
- springboot配置内部配置类
- angularjs与后台传值接收值
- P4048 [JSOI2010]冷冻波
- 二、python基础(列表、元组、字符串、集合、字典、文件操作,函数基本语法及特性)...
- Live回顾 | 松鼠AI智适应教育首席科学家崔炜:人工智能如何变革教育产业
- 定时任务:Java中Timer和TimerTask的使用
- 十七UML核心视图动态视图之时序图
- VS2010 连接SQLSERVER数据库步骤
- java的循环中try catch的一点小技巧