28 Python初学(事件驱动模型)

Posted mlllily

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了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

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

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

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

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

   4. 异步IO

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

 

selectpollepoll  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

 

以上是关于28 Python初学(事件驱动模型)的主要内容,如果未能解决你的问题,请参考以下文章

11.python并发入门(part13 了解事件驱动模型))

python入门第三十四天--事件驱动模型

Python并发编程-事件驱动模型

python实现事件驱动模型

python基础学习日志day10-事件驱动模型

事件驱动模型实例详解(Java篇)