linux网络编程 |
您所在的位置:网站首页 › linux特有的io复用 › linux网络编程 |
Linux网络编程—— IO多路复用
1. I/O 多路复用(I/O多路转接)1.1 常见的几种I/O模型
2. select3. poll4. epoll4.1 Epoll 的两种工作模式
网络编程系列文章: 第1章 Linux系统编程入门(上) 第1章 Linux系统编程入门(下) 第2章 Linux多进程开发(上) 第2章 Linux多进程开发(下) 第3章 Linux多线程开发 第4章 Linux网络编程 4.1 网络基础4.2 socket 通信基础4.3 TCP套接字通信4.4 IO多路复用4.5 UDP 通信第5章 Web服务器 1. I/O 多路复用(I/O多路转接)I/O 多路复用 使得程序能 同时监听 多个文件描述符,能够提高程序的性能,Linux 下实现 I/O 多路复用 的 系统调用主要有 select、poll 和 epoll。 传统 I/O 输入/输出 是相对于 内存 而言的: 输入:文件 --> 内存输出:内存 --> 文件socket通信 中,每个 socket 的 文件描述符fd 对应于内核中的一块缓冲区(读缓冲区+写缓冲区)。这里的I/O则是对 缓冲区 的操作。 1.1 常见的几种I/O模型(1)阻塞等待 ![]() (2)非阻塞,忙轮询 ![]() (3)IO多路转接技术 第一种:select / poll![]() ![]() 主旨思想: 首先要构造一个关于 文件描述符的 列表,将要 监听的 文件描述符 添加 到该列表中。调用一个 系统函数,监听 该列表中的文件描述符,直到这些描述符中的一个或者多个进行 I/O操作 时,该函数才返回。 a. 这个函数是 阻塞 b. 函数对文件描述符的检测的操作是 由 内核 完成的在返回时,它会告诉进程有 多少(哪些)描述符 要进行 I/O操作。 // sizeof(fd_set) = 128(字节) (1024位 标志位) #include #include #include #include // 只需一次调用 int select(int nfds, fd_set *readfds, fd_set *writefds, fd_set *exceptfds, struct timeval *timeout); - 参数: - nfds : 委托内核检测的最大文件描述符的值 + 1 - readfds : 要检测的文件描述符的读的集合,委托内核检测哪些文件描述符的读的属性 - 一般检测读操作 - 对应的是对方发送过来的数据,因为读是被动的接收数据,检测的就是读缓冲区 - 是一个传入传出参数 - writefds : 要检测的文件描述符的写的集合,委托内核检测哪些文件描述符的写的属性 - 委托内核检测写缓冲区是不是还可以写数据(不满的就可以写) - exceptfds : 检测发生异常的文件描述符的集合(一般不会用到) - timeout : 设置的超时时间 struct timeval { long tv_sec; /* seconds */ long tv_usec; /* microseconds */ }; - NULL : 永久阻塞,直到检测到了文件描述符有变化 - tv_sec = 0 tv_usec = 0, 不阻塞 - tv_sec > 0 tv_usec > 0, 阻塞对应的时间 - 返回值 : - -1 : 失败 - >0 (n) : 检测的集合中有n个文件描述符发生了变化 // 将参数文件描述符fd 对应的标志位 设置为0 void FD_CLR(int fd, fd_set *set); // 判断fd对应的标志位是0还是1, 返回值 : fd对应的标志位的值,0,返回0, 1,返回1 int FD_ISSET(int fd, fd_set *set); // 将参数文件描述符fd 对应的标志位,设置为1 void FD_SET(int fd, fd_set *set); // fd_set一共有1024 bit, 全部初始化为0 void FD_ZERO(fd_set *set);select() 工作过程分析 ![]() select() 多路复用 select() 的缺点 客户端 client.c 不变 运行结果: 面试90%会问!⭐️⭐️⭐️ epoll() 多路复用 客户端 client.c 不变 运行结果: (1)LT 模式 (水平触发) LT(level - triggered)是 缺省(默认) 的工作方式,并且同时支持 block 和 no-block socket。在这种做法中,内核 告诉你一个文件描述符 是否就绪 了,然后你可以对这个 就绪的 fd 进行 IO 操作。如果你不作任何操作,内核 还是会 继续 通知你的。 假设委托 内核 检测读事件 -> 检测 fd 的读缓冲区 读缓冲区有数据 - > epoll 检测到了会给用户通知 a. 用户不读数据,数据一直在缓冲区,epoll 会 一直通知 b. 用户只读了一部分数据,epoll 会通知 c. 缓冲区的数据读完了,不通知(2)ET 模式(边沿触发) ET(edge - triggered)是 高速工作方式,只支持 no-block socket。在这种模式下,当描述符从 未就绪 变为 就绪 时,内核通过 epoll 告诉你。 然后它会假设你知道文件描述符已经就绪,并且不会再为那个文件描述符发送更多的就绪通知,直到你 做了某些操作 导致 那个文件描述符 不再为就绪状态 了。但是请注意,如果一直不对这个 fd 作 IO 操作(从而导致它再次变成未就绪),内核不会发送更多的通知(only once)。ET 模式在很大程度上减少了 epoll 事件被重复触发的次数,因此 效率要比 LT 模式高。epoll 工作在 ET 模式的时候,必须使用非阻塞套接口,以 避免 由于一个文件句柄 (文件描述符)的 阻塞读 / 阻塞写 操作把处理多个文件描述符的任务 饿死。 假设委托 内核 检测读事件 -> 检测 fd 的读缓冲区 读缓冲区有数据 - > epoll 检测到了会给用户通知 a. 用户不读数据,数据一致在缓冲区中,epoll 下次检测的时候就不通知了 b. 用户只读了一部分数据,epoll 不通知 c. 缓冲区的数据读完了,不通知 客户端 client.c // 改为从键盘录入 #include #include #include #include #include int main() { // 创建socket int fd = socket(PF_INET, SOCK_STREAM, 0); if(fd == -1) { perror("socket"); return -1; } struct sockaddr_in seraddr; inet_pton(AF_INET, "127.0.0.1", &seraddr.sin_addr.s_addr); seraddr.sin_family = AF_INET; seraddr.sin_port = htons(9999); // 连接服务器 int ret = connect(fd, (struct sockaddr *)&seraddr, sizeof(seraddr)); if(ret == -1){ perror("connect"); return -1; } int num = 0; while(1) { char sendBuf[1024] = {0}; // sprintf(sendBuf, "send data %d", num++); fgets(sendBuf, sizeof(sendBuf), stdin); // 键盘录入 write(fd, sendBuf, strlen(sendBuf) + 1); // 接收 int len = read(fd, sendBuf, sizeof(sendBuf)); if(len == -1) { perror("read"); return -1; }else if(len > 0) { printf("read buf = %s\n", sendBuf); } else { printf("服务器已经断开连接...\n"); break; } } close(fd); return 0; }编写服务端程序: (1)水平触发 epoll_lt.c.c #include #include #include #include #include int main() { // 创建socket int fd = socket(PF_INET, SOCK_STREAM, 0); if(fd == -1) { perror("socket"); return -1; } struct sockaddr_in seraddr; inet_pton(AF_INET, "127.0.0.1", &seraddr.sin_addr.s_addr); seraddr.sin_family = AF_INET; seraddr.sin_port = htons(9999); // 连接服务器 int ret = connect(fd, (struct sockaddr *)&seraddr, sizeof(seraddr)); if(ret == -1){ perror("connect"); return -1; } int num = 0; while(1) { char sendBuf[1024] = {0}; // sprintf(sendBuf, "send data %d", num++); fgets(sendBuf, sizeof(sendBuf), stdin); // 键盘录入 write(fd, sendBuf, strlen(sendBuf) + 1); // 接收 int len = read(fd, sendBuf, sizeof(sendBuf)); if(len == -1) { perror("read"); return -1; }else if(len > 0) { printf("read buf = %s\n", sendBuf); } else { printf("服务器已经断开连接...\n"); break; } } close(fd); return 0; } 运行结果:![]() (2)边沿触发 struct epoll_event { uint32_t events; /* Epoll events */ epoll_data_t data; /* User data variable */ }; 常见的Epoll检测事件: - EPOLLIN - EPOLLOUT - EPOLLERR - EPOLLET // 边沿触发epoll_et.c.c #include #include #include #include #include #include #include #include int main() { // 创建socket int lfd = socket(PF_INET, SOCK_STREAM, 0); struct sockaddr_in saddr; saddr.sin_port = htons(9999); saddr.sin_family = AF_INET; saddr.sin_addr.s_addr = INADDR_ANY; // 绑定 bind(lfd, (struct sockaddr *)&saddr, sizeof(saddr)); // 监听 listen(lfd, 8); // 调用epoll_create()创建一个epoll实例 int epfd = epoll_create(100); // 将监听的文件描述符相关的检测信息添加到epoll实例中 struct epoll_event epev; epev.events = EPOLLIN; epev.data.fd = lfd; epoll_ctl(epfd, EPOLL_CTL_ADD, lfd, &epev); struct epoll_event epevs[1024]; while(1) { int ret = epoll_wait(epfd, epevs, 1024, -1); if(ret == -1) { perror("epoll_wait"); exit(-1); } printf("ret = %d\n", ret); for(int i = 0; i 0) { // 打印数据 // printf("recv data : %s\n", buf); write(STDOUT_FILENO, buf, len); write(curfd, buf, len); } if(len == 0) { printf("client closed...."); }else if(len == -1) { if(errno == EAGAIN) { printf("data over....."); }else { perror("read"); exit(-1); } } } } } close(lfd); close(epfd); return 0; } 运行结果:![]() 注:仅供学习参考,如有不足,欢迎指正! |
今日新闻 |
推荐新闻 |
CopyRight 2018-2019 办公设备维修网 版权所有 豫ICP备15022753号-3 |