1. 什么是IO？

IO：表示 输入 输出

---

当对方把连接建立好，但是不发数据
而我是一个线程，正在调用 read 来读，就会阻塞，一直等数据发送过来
即读取条件不满足的情况下，read或recv 只会等待

---

无论是有数据时的拷贝 ，还是没有数据时的等待
两者的时间成本，全都算到了用户头上

在用户的角度，IO= 等+数据拷贝

什么是高效 IO?

单位时间内， 等的比重越低， IO效率越高

当IO条件满足时，称为 IO事件就绪

2. IO的五种模型

五种IO模型的概念理解

如：钓鱼假设分为两步 ， 钓鱼 = 等 + 钓

在鱼竿的钩子上挂一个鱼漂，浮在水面上，用来恒定鱼竿下水的深度
当鱼漂上下摆动时，就可以知道当前有鱼上钩了

---

1. 张三一般喜欢专注于一件事， 所以当张三钓鱼等待时，就会一直盯着鱼漂看 是否有鱼上钩
过了一段时间，鱼漂动了，张三拉动鱼竿，将鱼钓上来了，放入桶中
继续刚才钓鱼的动作
张三在钓鱼的过程中，只盯着鱼漂看，不干其他事情

---

2. 李四天生好动， 所以当李四钓鱼时，就不怎么看鱼漂，会左顾右看的张望
当发现鱼咬钩后，就把鱼钓上来，放入桶中
继续刚才钓鱼的动作
李四在钓鱼的过程中，除了看鱼漂，还做其他事情

---

3. 王五比较特别， 当王五钓鱼时，在鱼竿的顶部放上一个铃铛，等待鱼上钩
等待过程中，王五做着自己的事情
当王五听到铃铛响了时，就拉动鱼竿，将鱼钓上来了，放入桶中
继续刚才钓鱼的动作
王五在钓鱼的过程中，不看鱼漂，只听铃铛来判断是否有鱼上钩

---

4. 赵六是周围的首富，开皮卡来钓鱼，皮卡上装了10根鱼竿 (首富是来体验生活的)
使用10根鱼竿一起钓鱼，赵六就从前往后 依次查看 是否有鱼漂在动

---

5. 田七是方圆500公里的首富 (田七比赵六有钱)
田七很忙，每天都有各种会议要开，而且田七并不是想钓鱼，而是喜欢吃鱼
所以就 让司机小王帮忙去钓鱼
当鱼桶满了后，给田七打电话，就会来人把鱼带走
小王在钓鱼时，田七也正在开会

---

张三和李四钓是一样的，差别在等待鱼上钩的方式不同
张三为 鱼漂不动，他不动
李四为 鱼漂不动，会立马返回去做其他事情

---

张三的钓鱼方式 称为 阻塞IO
(数据没有就绪，调用的read接口不会返回)

---

李四的钓鱼方式 称为 非阻塞IO
(检测一次若没有数据，则会立马返回，过一段时间可以再次检测)

---

王五在鱼还没有钓上来之前，就知道当铃铛响了，就应该拉动鱼竿
王五的钓鱼方式 称为 信号驱动IO

---

赵六一次管理多个鱼竿，赵六的钓鱼方式称为 多路复用或多路转接

在这几个人中，赵六的钓鱼效率比较高
因为赵六的鱼竿比较多，所以鱼上钩的概率大 即等待时间比较短
所以赵六的钓鱼效率比较高

---

同步IO与异步IO

前四个人都要钓鱼的过程，所以都称为 同步IO

田七没有参与钓鱼的过程，没有等 ，也没有钓，只是 发起钓鱼的过程
田七的钓鱼方式 称为 异步IO

---

整体理解

钓 可以看作 数据拷贝
张三 李四 等人 可以看作 进程
田七可以看作是一个进程，司机小王可以看作是操作系统
鱼竿可以看作 文件描述符
鱼 可以看作是 数据
鱼咬钩 或 鱼漂动 、铃铛响 可以看作 IO事件就绪

---

一个进程 在文件描述符上读取数据时，若数据没有就绪，当前进程只能挂起等待
直到有IO时间就绪，数据才可以拷贝到对应的上层

3. 阻塞IO

阻塞IO：数据没有就绪，调用的read接口不会返回

---

通过使用 read 函数 从键盘中读，当代码写好时，若什么也不输入，则什么也不显示 则为阻塞IO

输入 man 2 read

从一个文件描述符 中 去读count个数据 到 buf缓冲区中
若获取成功，则返回 字节数据
若获取 为0，则表示读到文件结尾
若获取为-1，则表示失败，并设置错误码

---

0表示标准输入流
从标准输入流中 读buffer数组大小的数据 发送到 buffer中

运行可执行程序后，一直不输入，则导致read在等待，直到有数据输入才进行数据拷贝

4. 非阻塞IO

非阻塞IO：检测一次若没有数据，则会立马返回 做其他事情，过一段时间可以再次检测

---

通过使用 read 函数 从键盘中读，当代码写好时，就是不输入
通过这样的方式，模拟读取条件不满足的情况下，read只会等待的情况

在上述阻塞IO的代码的基础上 进行修改

---

setnonblock函数

输入 man fcntl

第一个参数为 文件描述符
第二个参数 表示 你要对文件描述符干什么
获得/设置文件状态标记(cmd=F_GETFL或F_SETFL)

通过设置文件状态标记，就可以将一个文件描述符 变为 非阻塞

使用 F_GETFL，将当前文件描述符的属性取出来
使用 F_SETFL，将文件描述符 状态进行设置，并加上一个 O_NONBLOCK (非阻塞) 参数

若函数返回 -1，则表示失败

---

创建一个函数 setnonblock，将文件描述符设置为非阻塞状态
先使用F_GETFL，获取对应文件描述符的属性
若获取失败，则返回错误原因和错误码
若获取成功，则使用 F_SETFL 将文件描述符状态设为非阻塞状态

---

为什么非阻塞IO会读取错误？

在主函数main中，将标准输入流改为非阻塞状态
并根据read的三种返回值，分别设置 返回提示 ： 读取成功、文件结尾 和 读取错误

---

当将标准输入流设置为非阻塞状态后
再次运行可执行程序，直接就会读取失败
在调用read时，发现数据没有就绪 (当前读取检测速度太快，还没有输入，就报错了)

所以一旦底层数据没有就绪，就以出错的形式返回，但是不算真正的出错

---

但这样就没办法区分是真正出错还是 底层没有数据了
所以就通过出错码 进行进一步判断

对错误码的进一步判断

EAGAIN 和 EWOULDBLOCK 都是系统设置的，错误码都是11
用于判断没出错，但是以出错的形式返回 的错误码
若为真，则下次继续检测即可

---

若IO被信号中断，则重新检测

---

检测数据没有就绪时，返回做一些其他事情

非阻塞IO，是可以做到 当检测数据没有就绪 时，就返回做一些其他事情

---

定义一个 包装器 其参数为void 返回值为void ，并将其重命名为 func_t 类型
定义一个vetcor数组 ，其类型为 func_t

---

设置三个任务，分别为PrintLog OperMysql CheckNet

---

在创建LoadTask函数，将任务分别插入到funcs数组中

---

在主函数main中，调用 LoadTask函数 以此加载任务

---

创建一个 HandlerALLTask函数，用于遍历 vector数组 ，数组元素为任务
当数据没有就绪时，就返回 处理任务

---

完整代码

mytest.cc

#include<iostream>
#include<unistd.h>
#include<fcntl.h>
#include<cstdio>
#include<cstring>
#include<vector>
#include<functional>
using namespace std;//任务
void PrintLog()//打印日志
{cout<<"这是一个打印日志例程"<<endl;
}void OperMysql()
{cout<<"这是一个操作数据库的例程"<<endl;
}void CheckNet()
{cout<<"这是一个检测网络状态的例程"<<endl;
}using func_t =function<void(void)>;
vector<func_t>  funcs;void LoadTask()
{funcs.push_back(PrintLog);funcs.push_back( OperMysql);funcs.push_back(CheckNet);
}void HandlerALLTask()
{//遍历vector数组for(auto& func:funcs){func();}
}void SetNonBlock(int fd)//将文件描述符设为非阻塞
{int fl=fcntl(fd,F_GETFL);//获取当前文件描述符的指定状态标志位if(fl<0)//获取失败{cerr<<"error string: "<<strerror(errno)<<"error code: "<<errno<<endl;}fcntl(fd,F_SETFL,fl | O_NONBLOCK);//将文件描述符状态设为非阻塞状态
}int main()
{char buffer[64];SetNonBlock(0);//将标准输入流 改为非阻塞状态LoadTask();//加载任务while(true){//0表示标准输入流ssize_t n=read(0,buffer,sizeof(buffer)-1);//检测条件是否就绪if(n>0)//读取成功{buffer[n-1]=0;    cout<<"echo# "<<buffer<<endl; }else if(n==0)//读到文件结尾{cout<<"end file"<<endl;}else//读取失败 {if(errno==EAGAIN || errno ==EWOULDBLOCK){//若为真，说明没出错，只是以出错返回//底层数据没有准备好，下次继续检测HandlerALLTask();//遍历数组 处理任务sleep(1);cout<<"data not  ready"<<endl;continue;}else if(errno == EINTR){//IO被信号中断，需要重新检测continue;}else //真正的错误{cout<<"read error"<<"error string: "<<strerror(errno)<<"error code: "<<errno<<endl;break;}}sleep(1);}return 0;
}

makefile

mytest:mytest.ccg++ -o $@ $^ -std=c++11.PHONY:clean
clean:rm -f mytest