标签：
IO在计算机中指Input/Output，也就是输入和输出。由于程序和运行时数据是在内存中驻留，由CPU这个超快的计算核心来执行，涉及到数据交换的地方，通常是磁盘、网络等，就需要IO接口。
比如你打开浏览器，访问新浪首页，浏览器这个程序就需要通过网络IO获取新浪的网页。浏览器首先会发送数据给新浪服务器，告诉它我想要首页的HTML，这个动作是往外发数据，叫Output，随后新浪服务器把网页发过来，这个动作是从外面接收数据，叫Input。所以，通常，程序完成IO操作会有Input和Output两个数据流。当然也有只用一个的情况，比如，从磁盘读取文件到内存，就只有Input操作，反过来，把数据写到磁盘文件里，就只是一个Output操作。
通常情况，有一下几种情况模型:
综上普遍认为第三种方式为大多数网络服务器采用的方式。
例如在UI编程中，常常用到鼠标点击进行操作，那么如何，何时去获得鼠标的点击进行处理呢？
所以此方式是不可取的
目前大部分的UI编程都是事件驱动模型。如很多UI平台都会提供onClick()事件，这个事件就代表鼠标按下事件。事件驱动模型大体思路如下：
简单的代码示例如下
<!DOCTYPE html>
<html lang="en">
<head>
<meta charset="UTF-8">
<title>Title</title>
</head>
<body>
<p onclick="func()">点我</p>
<script>
function func() {
alert("你好")
}
</script>
</body>
</html>
图形讲解
事件驱动编程是一种编程范式，这里程序的执行流由外部事件来决定。它的特点是包含一个事件循环，当外部事件发生时使用回调机制来触发相应的处理。另外两种常见的编程范式是（单线程）同步以及多线程编程。
用个简单的图例来讲解三者关系
图中灰色部分表示I/O操作阻塞的时间
于CPU和内存的速度远远高于外设的速度，所以，在IO编程中，就存在速度严重不匹配的问题。举个例子来说，比如要把100M的数据写入磁盘，CPU输出100M的数据只需要0.01秒，可是磁盘要接收这100M数据可能需要10秒，怎么办呢？有两种办法：
同步和异步的区别就在于是否等待IO执行的结果。举个例子来说。
好比你去麦当劳点餐，你说“来个汉堡”，服务员告诉你，对不起，汉堡要现做，需要等5分钟，于是你站在收银台前面等了5分钟，拿到汉堡再去逛商场，这是同步IO。
你说“来个汉堡”，服务员告诉你，汉堡需要等5分钟，你可以先去逛商场，等做好了，我们再通知你，这样你可以立刻去干别的事情（逛商场），这是异步IO。
异步IO模型
异步IO全程过程没有阻塞状态。
注: 异步IO模块3.0才有，叫asyncio
就上面的例子你去麦当劳点汉堡，但此时没有了，要5分钟后才出来，而你咬着等5分钟，此刻的5分钟就浪费了，这就是典型的阻塞IO。大概流程可以这样表示
假设你不想在那等，就出去办其他的事了，但是你又担心你点的汉堡被别人拿走了，你就来来回回好多趟，最后终于做好了。大概流程如下
需要注意，拷贝数据整个过程，进程仍然是属于阻塞的状态
它的基本原理就是select/epoll这个function会不断的轮询所负责的所有socket，当某个socket有数据到达了，就通知用户进程。就如我们点好餐后，不用每次都去问服务员了，看专门的显示屏即可知道，那样每个顾客都知道自己的等待时间了。它的流程如图：
注意：当用户进程调用了select时，那么整个进程就会阻塞住。看似和阻塞IO没有太大的区别，但是这可以同时监听处理多个connection。整个用户的process其实是一直被block的。只不过process是被select这个函数block，而不是被socket IO给block。
综上所述，对几种IO模型进行比较如下：
select 函数监视的文件描述符分3类，分别是writefds、readfds、和exceptfds。调用后select函数会阻塞，直到有描述符就绪（可读、可写、或except），或超时（timeout等待时间，如立即返回设为null即可），函数返回。当select函数返回后，可以通过遍历fdset，来找到就绪的描述符。
select优势在于几乎支持所有平台。
缺点在于
相当于是select和epoll之间的过度，唯一的改动就是没有了文件描述符的数量限制
epoll有两种模式，区别在当epoll_wait检测到描述符事件发生并将此事件通知应用程序。
最后举个并发聊天的例子如
import socket import select sk = socket.socket() sk.bind((‘127.0.0.1‘, 8080)) sk.listen(3) sk_list = [sk, ] while True: r_list, w_list, x_list = select.select(sk_list, [], [],) for i in r_list: if i == sk: conn, addr = i.accept() #接收第一个传进来的也就是sk,之后开始执行conn了 sk_list.append(conn) elif i == conn: data = conn.recv(1024) data = data.decode(‘utf8‘) try: # data is False if data is not False: print(data) inp = input("回复客户端 %s >>>>" % sk_list.index(i)) conn.sendall(inp.encode(‘utf8‘)) except Exception: # print(e) sk_list.remove(i)
import socket sk = socket.socket(socket.AF_INET, socket.SOCK_STREAM) sk.connect((‘127.0.0.1‘, 8080)) while True: inp = input(">>>>") sk.sendall(inp.encode(‘utf8‘)) data = sk.recv(1024) print(data.decode(‘utf8‘))
标签：
原文地址：http://www.cnblogs.com/flash55/p/5974286.html
