IO多路复用

1 from socket import *
 2 server = socket(AF_INET,SOCK_STREAM)
 3 server.setsockopt(SOL_SOCKET,SO_REUSEADDR,1)
 4 server.bind(('127.0.0.1',8080))
 5 server.listen(5)
 6 print('start runnig...')
 7 while True:
 8     conn,addr = server.accept()  #IO操作 在这accept的时候不能干recv的活
 9     print(addr)
10     while True:
11         try:
12             data = conn.recv(1024)  #IO操作
13             conn.send(data.upper())
14         except Exception:
15             break
16     conn.close()
17 server.close()
18 
19 # 我们以前写的这个就是阻塞的IO模型：一旦阻塞了就在那卡着
20 # 直到等到数据已经到了操作系统，操作系统再从内核拷贝给应用程序
21 # 阻塞IO在那两个阶段全都阻塞住了

1 from socket import *
 2 client  = socket(AF_INET,SOCK_STREAM)
 3 client.connect(('127.0.0.1',8080))
 4 while True:
 5     cmd = input('>>:').strip()
 6     if not cmd:continue
 7     client.send(cmd.encode('utf-8'))
 8     data = client.recv(1024)
 9     print('接受的是：%s'%data.decode('utf-8'))
10 client.close()

1 #服务端
 2 from socket import *
 3 import select
 4 
 5 s=socket(AF_INET,SOCK_STREAM)
 6 s.setsockopt(SOL_SOCKET,SO_REUSEADDR,1)
 7 s.bind(('127.0.0.1',8081))
 8 s.listen(5)
 9 s.setblocking(False) #设置socket的接口为非阻塞
10 read_l=[s,]
11 while True:
12     r_l,w_l,x_l=select.select(read_l,[],[])
13     print(r_l)
14     for ready_obj in r_l:
15         if ready_obj == s:
16             conn,addr=ready_obj.accept() #此时的ready_obj等于s
17             read_l.append(conn)
18         else:
19             try:
20                 data=ready_obj.recv(1024) #此时的ready_obj等于conn
21                 if not data:
22                     read_l.remove(ready_obj)
23                     continue
24                 ready_obj.send(data.upper())
25             except ConnectionResetError:
26                 read_l.remove(ready_obj)
27 
28 #客户端
29 from socket import *
30 c=socket(AF_INET,SOCK_STREAM)
31 c.connect(('127.0.0.1',8081))
32 
33 while True:
34     msg=input('>>: ')
35     if not msg:continue
36     c.send(msg.encode('utf-8'))
37     data=c.recv(1024)
38     print(data.decode('utf-8'))
39 
40 select IO模型

1 # select模块用select方法检测那个套接字准备好了，也就是收没收到数据（而我们的
 2 # 非阻塞IO你不知道那个套接字准备好了，那么用select模块就能解决
 3 # 这个问题）
 4 # select还可以检测多个套接字
 5 # 所以select比非阻塞IO的效率高
 6 from socket import *
 7 import select
 8 server = socket(AF_INET,SOCK_STREAM)
 9 server.setsockopt(SOL_SOCKET,SO_REUSEADDR,1)
10 server.bind(('127.0.0.1',8081))
11 server.setblocking(False) #设置socket的套接字为非阻塞的
12 server.listen(5)
13 print('start running....')
14 read_l = [server,]  #因为不只就那么一个列表要检测。所以不要在参数里面定死了
15 while True:
16     r_l,w_l,x_l = select.select(read_l,[],[])  #select()方法有四个参数
17     print(r_l)  #一开始服务端运行的时候，就等着，当你客户端一链接的时候，他就
18                 # 检测到有数据了(检测那个数据准备好了)
19     for obj in r_l:
20         if obj == server:
21             conn,addr = obj.accept()  #accept要经历两个阶段，但是程序如果走到这一步，那肯定是数据准备好了
22                          #当数据已经准备好的时候，accept就只经历一个copy数据的阶段了
23             # print(addr)
24             read_l.append(conn)  #在监听一下conn套接字（这时候已经监听了两个了：分别是accept,conn）
25         else:
26             data = obj.recv(1024)  # 此时的obj=conn
27             obj.send(data.upper())
28 #         obj.close()
29 # server.close()

1 from socket import *
 2 import select
 3 client = socket(AF_INET,SOCK_STREAM)
 4 client.connect(('127.0.0.1',8081))
 5 while True:
 6     cmd = input('>>:')
 7     client.send(cmd.encode('utf-8'))
 8     data = client.recv(1024)
 9     print('接收的是：%s'%data.decode('utf-8'))
10 client.close()

 1 #服务端
 2 from socket import *
 3 import selectors
 4 
 5 sel=selectors.DefaultSelector()
 6 def accept(server_fileobj,mask):
 7     conn,addr=server_fileobj.accept()
 8     sel.register(conn,selectors.EVENT_READ,read)
 9 
10 def read(conn,mask):
11     try:
12         data=conn.recv(1024)
13         if not data:
14             print('closing',conn)
15             sel.unregister(conn)
16             conn.close()
17             return
18         conn.send(data.upper()+b'_SB')
19     except Exception:
20         print('closing', conn)
21         sel.unregister(conn)
22         conn.close()
23 
24 
25 
26 server_fileobj=socket(AF_INET,SOCK_STREAM)
27 server_fileobj.setsockopt(SOL_SOCKET,SO_REUSEADDR,1)
28 server_fileobj.bind(('127.0.0.1',8088))
29 server_fileobj.listen(5)
30 server_fileobj.setblocking(False) #设置socket的接口为非阻塞
31 sel.register(server_fileobj,selectors.EVENT_READ,accept) #相当于网select的读列表里append了一个文件句柄server_fileobj,并且绑定了一个回调函数accept
32 
33 while True:
34     events=sel.select() #检测所有的fileobj，是否有完成wait data的
35     for sel_obj,mask in events:
36         callback=sel_obj.data #callback=accpet
37         callback(sel_obj.fileobj,mask) #accpet(server_fileobj,1)
38 
39 #客户端
40 from socket import *
41 c=socket(AF_INET,SOCK_STREAM)
42 c.connect(('127.0.0.1',8088))
43 
44 while True:
45     msg=input('>>: ')
46     if not msg:continue
47     c.send(msg.encode('utf-8'))
48     data=c.recv(1024)
49     print(data.decode('utf-8'))