多路复用的分析实例:服务端、客户端

#服务端配置
from socket import *
import time
import select server = socket(AF_INET, SOCK_STREAM)
server.bind(('127.0.0.1',8080))
server.listen(5)
server.setblocking(False)
'''
select/epoll的优势并不是对于单个连接能处理得更快,而是在于能处理更多的连接。
当任何一个socket中的数据准备好了,select就会返回,会从操作系统将数据拷贝到应用程序中 1.select.select(read_list,write_list,[],5)是由应用程序发起的,发送给操作系统,让操作系统去找有数据的套接字socket
5:可以不用写,意思是5秒如果有数据连接进来会执行,如果没有回执行下一行代码(不用写是因为如果没数据执行下面的也没意义,
能执行下面的代码,肯定是上面有数据过来已经成功建立了连接) 重点:是没有数据过来才阻塞
有数据过来会一直运行,不会阻塞 2.异步IO:
发送之后不用管,会自动把结果发给你,发一个给操作系统就不用管了(用于爬虫,效率最高) '''
data_dic={} #设置一个空字典,目的是用于将conn:data 一一绑定
read_list=[server,] #放和收消息有关的套接字 conn.recv() server.accept(),是被检测的一些套接字
write_list=[] #send写数据,存放建立好的一些套接字服务端
print('start....')
while True:
#select执行的返回结果是维护的列表里面,哪个有数据过来了
rl,wl,xl=select.select(read_list,write_list,[]) #这里select在指定的时间段内不停的去问操作系统要数据,如果没有数据就会执行下面一行代码
print(read_list) #read_list=[server,conn1,conn2,conn3,conn4]
print(rl,len(rl)) #重点理解:上面循环每次得到r1只时包换操作系统询问到的有数据的套接字[conn1,conn2..]
#r1就是select返回的有
# print('read_list:%s rl:%s wl:%s ' %(len(read_list),len(rl),len(wl))) #rl=[conn1,conn2] #注意: #1.刚开始循环r1里面只有server,read_list=[server]里面也只有server,此时r1和read_list里面内筒一样
#2.刚开始read_list=[server,conn] server是负责建立新连接的,conn是负责收消息的 #3.当服务端accept()收到新的连接并加入到read_list[server,conn]里面,
# 问到结果之后此时 rl,wl,xl=select.select(read_list,write_list,[]),得到的r1里面只包含已经有数据过来的连接 #read_list里面的连接请求不会取走,只要有数据就不会阻塞,阻塞的情况是列表里面没有数据拿
#r1里面去依次for循环取数据,如果是server套接字对象就是accept(),否则就负责recv()数据
for sk in rl: #初始状态read_list里面放的的是server套接字,需要执行accept操作
if sk == server: #判断for循环,首先只有server服务端负责accept()接收
conn,addr=sk.accept()
read_list.append(conn) #后面并发的数量多了时要往read_list里面放一些有数据的套接字对象
else:
# sk.recv(1024)
# print(sk)
data=sk.recv(1024)
write_list.append(sk) #有消息往外回所以加进去了
data_dic[sk]=data #制作字典绑定send的对象和数据:格式为发送的对象conn:对应发送的数据 data #因为conn占用了应用程序的资源、对应操作系统还有维持连接 for sk in wl:
sk.send(data_dic[sk].upper()) #根据字典里面对应的socket套接字对象拿到,拿到
data_dic.pop(sk) #发完之后字典里面就没必要存放消息了,所以就回收
write_list.remove(sk) #回完之后没有了,所以就删除 #write_list还没满的情况下会返回w1
#read_list占应用程序的资源 # 因为conn占用了应用程序的资源、对应操作系统还要维持链接
#客户端配置
from socket import *
import os client=socket(AF_INET,SOCK_STREAM)
client.connect(('127.0.0.1',8080)) while True:
msg=input('输入要操作的命令:')
client.send(msg.encode('utf-8'))
data=client.recv(1024)
print(data.decode('utf-8'))
05-28 05:28