IO模型

2020-04-28 23:51:15 阅读：190 来源： 互联网

标签：obj recv 模型 list server IO data conn

一、概述

　　1、指的是针对网络的IO。

　　2、常见的会产生网络IO阻塞的状态：accept，recv（recvfrom）。

　　3、接收数据的两个阶段：操作系统等待对方数据传过来的wait_data（waiting for the data to be ready）和操作系统将数据从内核拷贝到进程的copy_data（copying the data from the kernel to the process）。

二、阻塞IO模型：对IO不做特殊处理。

import socket

server = socket.socket()
server.bind(('127.0.0.1', 3333))
server.listen(5)

while 1:
    print('等待客户端连接...')
    conn, client_addr = server.accept()
    while 1:
        print('等待客户端发送数据...')
        try:
            recv_data = conn.recv(1024)
            if len(recv_data) == 0:
                break
            send_data = '收到：'.encode('utf-8') + recv_data
            conn.send(send_data)
        except ConnectionResetError:
            print('客户端已经断开')
            break
    conn.close()

三、非阻塞IO模型：通过不断询问操作系统实现的无阻塞，但是如此会长时间占用cpu使之空转。

import socket

server = socket.socket()
server.bind(('127.0.0.1', 3333))
server.listen(5)
server.setblocking(False)  # 如此声明，可以将所有网络阻塞变为异常 BlockingIOError

r_list = []  # 初始化可用连接列表
del_list = []  # 初始化待清除列表

while 1:
    try:
        conn, client_addr = server.accept()
        r_list.append(conn)
    except BlockingIOError:
        print('跳过等待客户端连接')
        for conn in r_list:
            try:
                recv_data = conn.recv(1024)
                if len(recv_data) == 0:
                    conn.close()  # 关闭无用连接
                    del_list.append(conn)  # 将无用连接加入待清除列表
                    continue
                send_data = '收到：'.encode('utf-8') + recv_data
                conn.send(send_data)
            except BlockingIOError:
                print('跳过等待客户端发送数据')
                continue
            except ConnectionResetError:
                print('客户端已断开')
                conn.close()  # 关闭无用连接
                del_list.append(conn)  # 将无用连接加入待清除列表
        for conn in del_list:
            r_list.remove(conn)  # 从可用连接列表中清除无用连接
        del_list.clear()  # 初始化待清除列表

四、多路复用IO模型：通过导入select模块，将可能产生IO阻塞的对象交给操作系统的监管机制select，一个监管者可以同时监管多个对象，通过不断轮询这些对象来获悉这些对象是否脱离了IO阻塞，若脱离，则返回给程序执行。除了select机制，还有只能在linux系统上用的poll机制，poll机制能监管的对象数量更多，但是select和poll因为都是轮询的方式，所以都会产生较大的响应延迟，所以在linux系统上衍生了epoll机制，给每个监管对象绑定了回调机制，实现了即时响应，但是该机制不兼容windos系统最。终产生了selector模块，可以识别不同系统，选择对应的监管机制。

import socket
import select

server = socket.socket()
server.bind(('127.0.0.1', 3333))
server.listen(5)
server.setblocking(False)
read_list = [server]  # 把服务端对象加入读操作列表
while 1:
    select_obj = select.select(read_list, [], [])  # 把读操作列表和另外两个空列表加入监管名录
    r_list = select_obj[0]  # 监管对象脱离阻塞才会返回到可操作列表
    for obj in r_list:  # 遍历可操作列表
        if obj is server:  # 是服务端对象的情况
            print('只有当有客户端连接才会执行到本处')
            conn, client_addr = obj.accept()
            read_list.append(conn)
        else:  # 是连接对象的情况
            try:
                print('只有当客户端发来数据才会执行到本处')
                recv_data = obj.recv(1024)
                if len(recv_data) == 0:
                    obj.close()  # 关闭无效连接
                    read_list.remove(obj)  # 将无效连接移除可操作列表
                    continue
                send_data = '收到：'.encode('utf-8') + recv_data
                obj.send(send_data)
            except ConnectionResetError:
                print('客户端已断开连接')
                obj.close()  # 关闭无效连接
                read_list.remove(obj)  # 将无效连接移除可操作列表

五、异步IO模型：是IO模型发展至目前最优模型，避开了前面几代的诸多缺点，是目前效率最高的，广泛的引用于相关的模块与框架中。

　　1、模块：asyncio。

　　2、框架：sanic，tronado，twisted。

标签：obj,recv,模型,list,server,IO,data,conn
来源： https://www.cnblogs.com/caoyu080202201/p/12799184.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

ICode9

IO模型