I/O多路复用之epoll

2019独角兽企业重金招聘Python工程师标准>>> hot3.png

在上一章,我们对select进行了大致的描述,知道了它相对传统的阻塞式服务提高了并发度,但是它也由于轮询而导致效率底下。本文对epoll进行讲解,相比select它的并发度更高,现代高负载服务器很多都采用这种模型。
在讲解epoll的具体用法之前,我们先看看采用 epoll模型主要用到的三个函数以及一个数据结构
epoll中三个主要的函数:
(1)int epoll_create(int size);
功能 :生成一个epoll专用的文件描述符。
参数 :size:在该epoll fd上关注的最大socket fd数。
返回值:生成的文件描述符。
(2)int epoll_ctl(int epfd, int op, int fd, struct epoll_event *event);
功能 :控制某个epoll文件描述符上的事件,可以注册事件,修改事件,删除事件。
参数 :epfd :由 epoll_create 生成的epoll专用的文件描述符;
op :EPOLL_CTL_ADD 注册、EPOLL_CTL_MOD 修 改、EPOLL_CTL_DEL 删除;
fd :关联的文件描述符;
event:指向epoll_event的指针;
返回值:0:成功;
-1:失败;
(3)int epoll_wait(int epfd,struct epoll_event * events,int maxevents,int timeout);
功能 :轮询I/O事件的发生。
参数 :epfd :由 epoll_create 生成的epoll专用的文件描述符;
events :用于回传待处理事件的数组;
maxevents:每次能处理的事件数;
timeout :等待I/O事件发生的超时值;-1相当于阻塞,0相当于非阻塞;
返回值:>=0 :返回发生事件数;
-1 :错误;

epoll中的主要数据结构:
view source
print ?
01typedef union epoll_data {
02 void *ptr;
03 int fd;
04 __uint32_t u32;
05 __uint64_t u64;
06} epoll_data_t;
07
08struct epoll_event {
09 __uint32_t events; /* Epoll events */
10 epoll_data_t data; /* User data variable */
11};

其中,events的类型有:
EPOLLIN :文件描述符可以读;
EPOLLOUT:文件描述符可以写;
EPOLLPRI:文件描述符有紧急的数据可读;
EPOLLERR:文件描述符发生错误;
EPOLLHUP:文件描述符被挂断;
EPOLLET :文件描述符有事件发生;
epoll的使用还是很简单的,请看下面一个简单的采用epoll提供并发服务的服务端程序(注:为了简洁,都没有进行错误处理,实际使用时,一定要记住进行错误处理。):
view source
print ?
01#include <errno.h>
02#include <string.h>
03#include <sys/types.h>
04#include <netinet/in.h>
05#include <sys/socket.h>
06#include <sys/wait.h>
07#include <unistd.h>
08#include <arpa/inet.h>
09#include <sys/epoll.h>
10#include <sys/time.h>
11
12#define MAXBUF 1024
13#define MAX_EPOLL_SIZE 10000
14#define SERVICE_PORT 8888
15
16
17int main(int argc, char **argv)
18{
19 int server_fd, new_fd;
20 struct sockaddr_in server_addr, client_addr;
21
22 struct epoll_event ev;
23 struct epoll_event events[MAX_EPOLL_SIZE];
24
25 socklen_t len = sizeof(struct sockaddr_in);
26 server_fd = socket(AF_INET, SOCK_STREAM, 0);
27
28 bzero(&server_addr, sizeof(server_addr));
29 server_addr.sin_family = AF_INET;
30 server_addr.sin_port = htons(SERVICE_PORT);
31 server_addr.sin_addr.s_addr = INADDR_ANY;
32
33 bind(server_fd, (struct sockaddr *) &server_addr, sizeof(struct sockaddr));
34 listen(server_fd, 1000);
35
36 //create epoll fd, and register the server listening fd
37 int epoll_fd = epoll_create(MAX_EPOLL_SIZE);
38 ev.events = EPOLLIN | EPOLLET;
39 ev.data.fd = server_fd;
40 epoll_ctl(epoll_fd, EPOLL_CTL_ADD, server_fd, &ev);
41
42 int active_fd_count = 1;
43 while (1)
44 {
45 //wait for some events to happen
46 int event_active_fd_count = epoll_wait(epoll_fd, events, active_fd_count, -1);
47
48 // process all events
49 for (int i = 0; i < event_active_fd_count; ++i)
50 {
51 if (events[i].data.fd == server_fd)
52 {
53 new_fd = accept(server_fd, (struct sockaddr *) &client_addr,&len);
54
55 //register new fd to epoll
56 ev.events = EPOLLIN | EPOLLET;
57 ev.data.fd = new_fd;
58 epoll_ctl(epoll_fd, EPOLL_CTL_ADD, new_fd, &ev);
59 active_fd_count++;
60 }
61 else
62 {
63 handle message on events[i].data.fd
64 if (client close the connection)
65 {
66 epoll_ctl(epoll_fd, EPOLL_CTL_DEL, events[i].data.fd,&ev);
67 active_fd_count--;
68 }
69 }
70 }
71 }
72 close(server_fd);
73 return 0;
74}

讲完epoll的常规使用方法,这里需要注意的是epoll有两种工作方式:
(1)ET:Edge Triggered,边缘触发。仅当状态发生变化时才会通知,需要细致的处理每个请求,否则容易发生丢失事件的情况。只支持非阻塞的socket。
(2)LT:Level Triggered,水平触发(默认工作方式)。只要还有没有处理的事件就会一直通知,因此不用担心事件丢失的情况。效率会低于ET触发,尤其在大并发,大流量的情况下。支持阻塞和非阻塞的socket。

最后讲讲 为什么epoll会比select高效,主要从三方面来进行论述。
(1)elect对描述符状态的改变是通过轮询来进行查找的;而epoll是当描述符状态发生改变时主动进行通知内核,这就是所谓的Reactor事件处理机制。可以用“好莱坞原则”进行描述:不要打电话给我们,我们会打电话通知你。相比之下,select的机制就好比面试结束后不停给面试官打电话询问面试结果。效率孰高孰低,可见一 斑。
(2)select的文件描述符是使用链表进行组织的;而epoll是使用红黑树这一高效数据结构组织的。
(3)select从内核到用户空间传递文件描述符上发送的信息是使用内存复制的方式进行的;而epoll是采用共享内存的方式。

转载于:https://my.oschina.net/u/581475/blog/73195

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/403753.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

Xtreme TaskPanel

原文来自方案网 http://www.fanganwang.com/Product-detail-item-1230.html&#xff0c;欢迎转载。 关键字&#xff1a;TaskPanel Codejock Xtreme TaskPanel为Windows开发者提供了一个非常熟悉的任务栏&#xff0c;与Windows资源管理器类似。该任务面板可以像VS.NET工具一样被…

vscode tab键快捷生成元素html标签

按照上图在设置中找到对应的文件夹&#xff0c; 直接加上"emmet.triggerExpansionOnTab": true,这段代码保存 重新打开vscode即可

解决vscode格式化代码html属性换行问题; ctrl+s格式化去除分号,格式化自动单引号;解决js格式化换行问题;mac上的settings.json完整配置

右键格式化文档或者ctrl s保存 html不换行 1.安装两个插件①vetur ②Prettier - Code formatter 2.在vetur的settings.json中设置 配置ctrls触发格式化去除分号和单引号&#xff1b;配置格式化js换行&#xff1b;配置解决html属性换行 将最后一部分的设置&#xff0c;修改…

uniapp使用iconfont字体图标

vue引入字体图标看这篇 本文介绍两种方案&#xff1a;一、使用iconfont字体图标 二、使用icon图片 情景1&#xff1a;使用灰色的字体图标 方案一&#xff1a;使用iconfont字体图标 步骤1&#xff1a;下载iconfont 步骤2&#xff1a;解压后只需要将ifonfont.css这一个文件 &am…

socket选项: SO_REUSEADDR, SO_RCVBUF, SO_SNDBUF

From: http://blog.csdn.net/jasonliuvip/article/details/22591531 最近在看《linux高性能服务器编程》&#xff0c;在此做个日记&#xff0c;以激励自己&#xff0c;同时分享于有需要的朋友。 1. 读取和设置socket文件描述符属性&#xff1a; [cpp] view plaincopy#include …

VScode配置eslint保存自动格式化,eslint格式化去掉分号和双引号。vscode自动保存去掉分号和双引号;““

本文是开启eslint检验和配置eslint格式化&#xff1b;如果想要关闭eslint&#xff0c;查看这篇关闭eslint方法&#xff1b; 1.必须安装的三个插件eslint&#xff0c; prettier-Code formatter &#xff0c;vetur 2.配置setting.json 3.直接将下方代码复制&#xff0c;黏…

uniapp网络请求封装;小程序请求接口封装;uni.request接口封装

另一篇全面封装文章 资源文章下载地址 1.正常使用uni.request()发送请求(未封装) get() {uni.request({url: http://192.168.1.191/abc//main/jiekouming/abclist?workType2,data: {},header: {Token: b042b36fwq909qwe9iiidsai2323sd232dw3},method: GET,success: (res) &…

Nginx_lua

首先让我们来了解一下Nginx_lua的设计指导思想&#xff1a; 1、基于Nginx 快速开发高性能、大并发的网络服务。 2、提供“同步非阻塞” 的I/O 访问接口简化I/O 多路复用体系中的业务逻辑开发&#xff1a; ■“同步”的主体是用户代码与其发起的I/O 请求处理流程之间的时序关系&…

MyTask4

最近稍微做了点修改&#xff0c;把几处bug修复了下&#xff0c;另外新增了授权码功能和数据缓冲功能 先看看效果图 1. 如果要把软件做的高大上一些&#xff0c;你可以加一个授权验证&#xff0c;授权码以字符串形式存放在程序里面&#xff0c;当然你也可以另外开一个窗体&#…

2015年第六届蓝桥杯C/C++程序设计本科B组决赛

1.积分之谜&#xff08;枚举&#xff09; 2.完美正方形 3.关联账户&#xff08;并查集&#xff09; 4.密文搜索 5.居民集会 6.模型染色 1.积分之迷 小明开了个网上商店&#xff0c;卖风铃。共有3个品牌&#xff1a;A&#xff0c;B&#xff0c;C。为了促销&#xff0c;每件商品都…

js上传文件;input上传文件;

html原生上传文件方式1&#xff1a; <!DOCTYPE html> <html><head><meta charset"utf-8" /><title>Document</title><script></script></head><body><div>选择文件(可多选):<input type&quo…

vuex随记

1.下载vue 2.引入封装 import Vue from vue import Vuex from vuex import getters from ./gettersVue.use(Vuex)const modulesFiles require.context(./modules, true, /\.js$/)const modules modulesFiles.keys().reduce((modules, modulePath) > {// set ./app.js &g…

接口报Provisional headers are shown原因和解决方法

1.前端访问后端接口报has been blocked by CORS policy: Request header field authorization is not allowed by Access-Control-Allow-Headers in preflight response. 2.原因&#xff1a;可能是你的接口请求头没有设置token

Android开发用到的几种常用设计模式浅谈(一):组合模式

1&#xff1a;应用场景 Android中对组合模式的应用&#xff0c;可谓是泛滥成粥&#xff0c;随处可见&#xff0c;那就是View和ViewGroup类的使用。在android UI设计&#xff0c;几乎所有的widget和布局类都依靠这两个类。组合模式&#xff0c;Composite Pattern&#xff0c;是一…

分页存储过程

View Code --------------------------------------用途&#xff1a;支持任意排序的分页存储过程 --说明&#xff1a;------------------------------------CREATE PROCEDURE [dbo].[UP_GetRecordByPageOrder]tblName varchar(255), -- 表名 fldName varchar(255), -- 显示…

vuex的使用和封装

一、Vuex基本使用 1.下载vuex依赖 npm install vuex --save2.在src/store/index.js下引入使用 import Vue from vue import Vuex from vuexVue.use(Vuex)export default new Vuex.Store({state: {},mutations: {},actions: {},modules: {} })3.在main.js内&#xff0c;将stor…

Nginx下配置小绿锁https

我用的是阿里云服务器&#xff0c;centos7.2的操作系统&#xff0c;服务器类型&#xff1a;nginx/1.12.1 这是github上的官方配置https://github.com/Neilpang/acme.sh/wiki/%E8%AF%B4%E6%98%8E 刚开始配置的时候也遇到了很多坑&#xff0c;假设你已经配置好了服务器等需要准备…

win7 删除Windows服务的方法

From: http://www.jb51.net/os/windows/25090.html 一、什么是Windows服务    Windows服务也称为Windows Service&#xff0c;它是Windows操作系统和Windows网络的基础&#xff0c;属于系统核心的一部分&#xff0c;它支持着整个Windows的各种操作。诸如DNS客户端、打印程序、…

ACM学习历程—51NOD 1685 第K大区间2(二分 树状数组 中位数)

http://www.51nod.com/contest/problem.html#!problemId1685 这是这次BSG白山极客挑战赛的E题。 这题可以二分答案t。 关键在于&#xff0c;对于一个t&#xff0c;如何判断它是否能成为第k大。 将序列中大于t的置为1&#xff0c;小于t的置为-1&#xff0c;等于t的置为0。那么区…

vue项目请求封装;axios封装使用

vue项目&#xff0c;封装axios请求方式和响应状态码&#xff1b;以及接口的api封装&#xff1b; 目录结构&#xff1a; 1.具体在src/utils/request.js下封装axios&#xff1a; ①引入axios和router ②引入element-ui是为了用提示组件 和加载组件&#xff08;可选择去掉&#…