开发笔记:28Python初学（事件驱动模型）

篇首语：本文由编程笔记#小编为大家整理，主要介绍了28 Python初学（事件驱动模型）相关的知识，希望对你有一定的参考价值。

参考文章地址：http://www.cnblogs.com/yuanchenqi/articles/5722574.html

两个步骤：

recvfrom 系统调用 ； 拷贝数据 从kernel到数据

1. 阻塞IO：在IO执行两个阶段进程都被阻塞（1. kernel 准备数据，等待数据到来  2. kernel 将数据拷贝到用户态）


2. 非阻塞IO：第一步不阻塞，第二部拷贝数据阻塞（弊端：1. 多次询问 2. 数据不能及时同步）


3. IO 多路复用（IO multiplexing）：

        又叫 ‘事件驱动IO’

        select、epoll 的好处是单个 process 可以同时处理多个网络连接的IO。它的基本原理是select、epoll这个function会不断地轮询所有的socket，当某个socket有数据到达了，就通知用户进程。

       select 是一个函数，进行数据监听。当调用这个函数时，他会发一个系统调用，监听数据是否到达。（进程会被阻塞，这个过程是 select 这个函数阻塞的）

       当 select 告诉进程数据到达之后，进程需要多做一件事情，仍然要使用 recvfrom 进行 system call：告诉内核将数据拷贝到进程（此过程进程也会被阻塞）

       好处：select 可以监听多个描述符，完成并发的效果。   跨平台

   4. 异步IO：

        完全没有阻塞，用户进程发起read 操作之后，kernel如果还没有将数据准备好，会立即返回。这个时候进程可以去做其他的事情，当数据准备好并且kernel将数据拷贝到内存时，kernal会给进程发一个singal信号，告诉他read操作已经完成。

select、poll、epoll  IO多路复用：

epoll 真正解决了 select 的轮询问题，但它是同步IO

server：

# _author: lily
# _date: 2019/2/1
import socket
import time
sk = socket.socket()
adress = (\'127.0.0.1\', 8080)
sk.bind(adress)
sk.listen(3)
sk.setblocking(False)
while 1:
try:
conn, addr = sk.accept()
while 1:
data = conn.recv(1024)
print(data.decode(\'utf8\'))
conn.sendall(data)
conn.close()
except Exception as e:
print(\' no data: \', e)
time.sleep(3)

View Code

client：

# _author: lily
# _date: 2019/2/1
import socket
sk = socket.socket()
adress = (\'127.0.0.1\', 8080)
sk.connect(adress)
while 1:
# inp = input(\'>>\')
sk.sendall(\'hello\'.encode(\'utf8\'))
data = sk.recv(1024)
print(data.decode(\'utf8\'))
sk.close()

View Code