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