码迷,mamicode.com
首页 > 其他好文 > 详细

多路复用IO模型 IO multiplexing

时间:2018-11-14 22:36:33      阅读:159      评论:0      收藏:0      [点我收藏+]

标签:请求   接受   recv   bin   port   多路复用   div   高并发   res   

多路复用IO模型

就非阻塞IO模型来说,虽然使得CPU处于高并发,但是绝大部分的计算机资源被用反复检测。这样对于少量的用户绝对实在浪费资源。

这是提出多路复用IO模型

技术分享图片

多路复用IO模型的结局方案,其实用select模块作为一个检测是否有想要的数据生成,如果没有就去执行其他任务,如果有的话,之前原IO操作。将原来数个accept和recv等这种两个io操作的阻塞变成了select模块。

import select
import socket

server = socket.socket()
server.setsockopt(socket.SOL_SOCKET,socket.SO_REUSEADDR,1)
server.bind(("127.0.0.1",5555))
server.listen(5)
server.setblocking(False)


#需要检测的是否可以别读取的列表(accept,recv等操作)
rlist = [server,]#服务端需要一直被检测是否有客户端,连接
#需要检测的是否可以写入的列表,(send操作)
wlist = []
#需要发送的数据,目前是因为我们要把接受的数据在发送回去
dic = {}
while True:
    rl,wl,xl = select.select(rlist,wlist,[])
    for c in rl:
        #当检测当rlist中有可以读取的操作(即可以连接对象)
        if c == server:
            #接受到客户端的连接请求(一个读操作)
            conn,addr = c.accept()
            #创建的连接添加加入检测列表中去
            rlist.append(conn)
        else:
            #不是服务就是客户端的连接,就可以执行recv
            try:
                data = c.recv(1024)
                if not data:#linux的客户端的错误关闭的
                    c.close()
                    rlist.remove(c)#将给连接从被检测列表中移除
                wlist.append(c)#在正常开发中,不可能必须客户端先发送数据
                #服务端才给客户端发送请求
                dic[c] = data
            except ConnectionResetError:
                c.close()
                rlist.remove(c)
    
    #处理可以写的socket
    for c in wl:
        print(c)
        try:
            c.send(dic[c].upper())
            dic.pop(c)
            #从检测列表中删除已发送完成的客户端
            wlist.remove(c)
        except BlockingIOError:
            pass
        

 异步IO简单的提一下

模型

技术分享图片

其实上节课讲的异步回调就是解决异步的方案,后期会将asyncio模块。

多路复用IO模型 IO multiplexing

标签:请求   接受   recv   bin   port   多路复用   div   高并发   res   

原文地址:https://www.cnblogs.com/msj513/p/9960173.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!