基于select的IO多路复用并发模型

Posted yongqi-wang

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了基于select的IO多路复用并发模型相关的知识,希望对你有一定的参考价值。

服务端:

from  socket import *
from select import *

HOST=0.0.0.0
PORT=8585
ADDR=(HOST,PORT)


tcp_socket=socket()
tcp_socket.bind(ADDR)
tcp_socket.listen(5)
print(tcp_socket)
#监听读IO列表
rlist=[tcp_socket]
#监听写IO列表
wlist=[]
#监听异常IO列表 ps:linux中这个列表不用 因为linux不会主动处理异常
xlist=[]


while True:
    #监听IO
    #rs,ws,xs分别为读、写、异常事件IO的返回列表
    rs, ws, xs = select(rlist,wlist,xlist)
    for r in rs:
        #当rs列表中r与tcp_socket为同一对象时
        if r is tcp_socket:
            connfd,addr=rs[0].accept()
            print(connect from,addr)
            rlist.append(connfd)
        else:
            data=r.recv(1024)
            if not data:
                print(退出,r)
                r.close()
                rlist.remove(r)
                continue
            else:
                print(data.decode())
                wlist.append(r)
    for w in ws:
        w.send(bok)

 

 

客户端:

"""
/etc/python3
@File     : tcp_conecter.py
@Time     : 2020/7/17 下午2:43
@Author   : wangyongqi
@Email    : 92644827@qq.com
@SOftware : PyCharm 
"""
from socket import socket



sockfd=socket()
sockfd.connect((0.0.0.0,9548))
while True:
    sockfd.send(input(">>").encode())

 

以上是关于基于select的IO多路复用并发模型的主要内容,如果未能解决你的问题,请参考以下文章

Python并发编程-IO模型-IO多路复用实现SocketServer

基于select类型多路IO复用,实现简单socket并发

多路复用IO模型 IO multiplexing

网络I/O模型--05多路复用I/O

39.IO多路复用(用select实现伪并发)

python并发编程-多路复用IO