Python IO多路复用详解编程语言

 1 #!/usr/bin/env python 
 2 # -*- coding:utf-8 -*-  
 3 import select 
 4 import sys 
 5  
 6 while True: 
 7     readable, writeable, error = select.select([sys.stdin,],[],[],1) 
 8     """ 
 9     select.select([sys.stdin,],[],[],1)就是I/O多路复用的例子，第一个参数是列表，这里放进去的是sys.stdin就是我输入 
10     进去东西的描述符.第一个参数对应的是readable这个句柄，后面两个先不考虑. 
11  
12      """ 
13     if sys.stdin in readable: 
14         print 'select get stdin',sys.stdin.readline() 
15  
16 #注意：[sys.stdin,]  这个参数不管是列表还是元组在最后的元素后面建议增加一个逗号，是一种写作习惯. 
17 #这个代码可以在linux平台执行,windows不支持select方法的epoll方法.只支持select socket 方法.

 1 #/usr/bin/env python 
 2 #-*- coding:utf-8 -*- 
 3  
 4 import socket 
 5 import select 
 6 #创建socket对象 
 7 sk = socket.socket(socket.AF_INET,socket.SOCK_STREAM) 
 8 sk.setsockopt(socket.SOL_SOCKET,socket.SO_REUSEADDR,1)      #setsockopt获得端口重用 
 9 #设置监听的IP与端口 
10 sk.bind(('127.0.0.1',8000)) 
11 #设置client最大等待连接数 
12 sk.listen(5) 
13 sk.setblocking(False)   #这里设置setblocking为Falseaccept将不在阻塞，但是如果没有收到请求就会报错 
14 while True: 
15     readable_list, writeable_list, error_list = select.select([sk,],[],[],2)  #监听第一个列表的文件描述符，如果里面有文件描述符发生改变既能捕获并放到readable_list中 
16     for r in readable_list:    #如果是空列表将不执行，如果是非空列表。将执行。 
17         conn,addr = r.accept() 
18         print addr 
19  
20 ################################################## 
21 #执行程序并打开IE输入地址：127.0.0.1:8000 输出如下： 
22 ('127.0.0.1', 52155)

 1 #/usr/bin/env python 
 2 #-*- coding:utf-8 -*- 
 3 import time 
 4 import socket 
 5 import select 
 6 #创建socket对象 
 7 sk = socket.socket(socket.AF_INET,socket.SOCK_STREAM) 
 8 sk.setsockopt(socket.SOL_SOCKET,socket.SO_REUSEADDR,1)      #setsockopt获得端口重用 
 9 #设置监听的IP与端口 
10 sk.bind(('127.0.0.1',8000)) 
11 #设置client最大等待连接数 
12 sk.listen(3) 
13 sk.setblocking(False)   #这里设置setblocking为False accept将不在阻塞，但是如果没有收到请求就会报错 
14 inputs = [sk,]          #将sk这个对象加入到列表中，并且赋值给inputs 
15 #原因：看上例conn是客户端对象，客户是一直连接着呢，连接的时候状态变了，连接上之后，还是服务端的socket 有关吗？ 
16 #是不是的把他改为动态的？ 
17  
18 while True: 
19     readable_list, writeable_list, error_list = select.select(inputs,[],[],1)  #把第一个参数设为列表动态的添加 
20     time.sleep(2)   #暂停2秒，测试使用 
21     print "inputs list :",inputs                # 打印inputs列表，查看执行变化 
22     print "file descriptor :",readable_list     #打印readable_list ，查看执行变化 
23  
24     for r in readable_list: 
25         if r == sk:  #这里判断，如果是客户端连接过来的话他不是sk，如果是服务端的socket连接过来的话是sk 
26             conn,address = r.accept() 
27             inputs.append(conn) 
28             print address 
29         else: 
30         #如果是客户端，接受和返回数据 
31             client_data = r.recv(1024) 
32             r.sendall(client_data)

 1 #!/usr/bin/env python 
 2 #-*- coding:utf-8 -*- 
 3  
 4 import socket 
 5  
 6 client = socket.socket() 
 7 client.connect(('127.0.0.1',8000)) 
 8 client.settimeout(5) 
 9  
10 while True: 
11     client_input = raw_input('please input message:').strip() 
12     client.sendall(client_input) 
13     server_data = client.recv(1024) 
14     print server_data

 1 #/usr/bin/env python 
 2 #-*- coding:utf-8 -*- 
 3 import time 
 4 import socket 
 5 import select 
 6 #创建socket对象 
 7 sk = socket.socket(socket.AF_INET,socket.SOCK_STREAM) 
 8 sk.setsockopt 
 9 #设置监听的IP与端口 
10 sk.bind(('127.0.0.1',6666)) 
11 #设置client最大等待连接数 
12 sk.listen(5) 
13 sk.setblocking(False) #这里设置setblocking为Falseaccept将不在阻塞，但是如果没有收到请求就会报错 
14 inputs = [sk,] #将sk这个对象加入到列表中，并且赋值给inputs 
15 #原因：看上例conn是客户端对象，客户是一直连接着呢，连接的时候状态变了，连接上之后，连接上之后，还是服务端的socket 有关吗？ 
16 #是不是的把他改为动态的？ 
17  
18 while True: 
19     readable_list, writeable_list, error_list = select.select(inputs,[],[],1)  #把第一个参数设为列表动态的添加 
20     time.sleep(2) #测试使用 
21     print "inputs list :",inputs     #打印inputs列表，查看执行变化 
22     print "file descriptor :",readable_list #打印readable_list ，查看执行变化 
23  
24     for r in readable_list: 
25         if r == sk:  #这里判断，如果是客户端连接过来的话他不是sk，如果是服务端的socket连接过来的话是sk 
26             conn,address = r.accept() 
27             inputs.append(conn) 
28             print address 
29         else: 
30         #如果是客户端，接受和返回数据 
31             client_data = r.recv(1024) 
32             if client_data: 
33                 r.sendall(client_data) 
34             else: 
35                 inputs.remove(r)#如果没有收到客户端端数据，则移除客户端句柄 因为，不管是正常关闭还是异常关闭，client端的系统底层都会发送一个消息 
36  
37 select socket server - server release client-connect