标签：style os io 使用 ar for 文件 数据 art
# -*- coding: utf-8 -*-
# python:2.x
__author__ = ‘Administrator‘
import select,socket,sys,Queue
#作用：等待输入或者输出通道已经准备就绪的通知
#select模块允许访问特定平台的IO监视函数，可移植接口是POSIX函数select(),unix和windows都支持这个函数，poll()只支持unix,还有一些适用于unix特定变种选项
#select()是底层操作系统实现一个直接接口，会监视套接字，打开文件和管道（可以是任何有filen()方法对象，它会返回一个合法的文件描述符），这个是可读，可写的，或者出现一个通信错误，select()可以高效的同时监视多个连接
#select()服务器端例子学习
serve=socket.socket(socket.AF_INET,socket.SOCK_STREAM)
serve.setblocking(0)#如果套接字为0，设置为非阻塞,阻塞模式
serer_address=(‘localhost‘,10000)
print >>sys.stderr,‘starting up on%s port %s‘%serer_address
serve.bind(serer_address)
serve.listen(5)
"""
select()原型是(rlist,wlist,xlist[,timeout])
rlist等待读取对象，wlist等待定稿对象,xlist等待异常对象，最后一个可选对象，指定等待时间，单位是s,select()方法返回值准备好的对象是三元组，若在timeout时间内，没有对象准备好，那么返回值是空的列表
"""
inputs=[serve]#读取
outputs=[]#写入
#服务器主循环向这些列表添加或者删除连接，由于版本服务器在发送数据之前要等待一个套接字变为可写（不是马上发出相应），所以每个输出连接都需要一个队列，作为通过这个套接字发送的数据缓冲区
message_queues={}
#服务器程序主要部分是循环，调用 select()来阻塞，并等待网络活动
while inputs:
print >>sys.stderr,‘waiting for the next event‘
readable,writable,exceptional=select.select(inputs,outputs,inputs)
#可读的套接字表示3种可能情况，如果套接字是主服务器套接字，即用来监听连接的套接字，意味它已经准备就绪，可以接受另一个到来的连接，除了将新连接添加到要监视的输入列表之外，这一部分还将客户端设置为非阻塞
for s in readable:
if s is serve:
connectiuon,client_addre=s.accept()
print >>sys.stderr,‘connection from‘,client_addre
connectiuon.setblocking(0)
inputs.append(connectiuon)
message_queues[connectiuon]=Queue.Queue()
#下一种情况是已经连接了，客户已经发数据，数据使用recv()读取，然后旋转在队列中，进行返回
else:
data=s.recv(1024)
if data:
print >>sys.stderr,‘received%s form %s‘%(data,s.getpeername())
message_queues[s].put(data)
if s not in outputs:
outputs.append(s)
#没有数据可用的可读套接字来自已经断开连接端，可以关闭流
else:
print >>sys.stderr,‘closeing‘,client_addre
if s in outputs:
outputs.append(s)
inputs.append(s)
s.close()
del message_queues[s]
#对于可写连接，情况要少一些，如果对应一个连接队列中有数据，则发送下一个消息，否则，将这个连接从输出连接删除，下一次循环,select()不再指示这个套接字已经准备就绪发送数据
for s in writable:
try:
next_msg=message_queues[s].get_nowait()
except Queue.Empty:
print >>sys.stderr,‘ ‘,s.getpeername(),‘queue empty‘
outputs.remove(s)
else:
print >>sys.stderr,‘ sending %s to %s‘%(next_msg,s.getpeername())
s.send(next_msg)
#最后，如果一个套接字有错误，则关闭
for s in exceptional:
print >>sys.stderr,‘exception condition on‘,s.getpeername()
inputs.remove(s)
if s in outputs:
outputs.remove(s)
s.close()
#select()客户端程序
message=[‘this is the message‘,‘it will be sent,‘
‘in parts.‘]
serer_address=(‘localhost‘,10000)
socks=[socket.socket(socket.AF_INET,socket.SOCK_STREAM),
socket.socket(socket.AF_INET,socket.SOCK_STREAM),]
print >>sys.stderr,‘connection to%s and %s‘%(serer_address)
for s in socks:
s.connect(serer_address)
#通过各个套接字发送一次信息，写新数据之后再得到所有相应数据
for m in message:
if s in socks:
print >>sys.stderr,‘%s:sending%s‘%(s.getsockname(),m,s.send(m))
for s in socks:
data=s.recv(1024)
print ‘%s:%s‘%(s.getpeername(),data)
if not data:
print >>sys.stderr,‘closeing socket‘,s.getsockname()
s.close()
python select和socket配合使用基础学习，是python标准库例子
标签：style os io 使用 ar for 文件 数据 art
原文地址：http://www.cnblogs.com/mhxy13867806343/p/3958515.html
