python-poll实现异步IO

#!usr/bin/python

from socket import *
from select import *
from time import ctime
s=socket()
s.bind(('127.0.0.1',6653))

d={s.fileno():s}
s.listen(5)

p=poll()
p.register(s)

while 1:
    events=p.poll()
    for fd,event in events:
        if fd==s.fileno():
            c,addr=s.accept()
            print "connect from ",addr
            p.register(c)
            d[c.fileno()]=c
        elif event & POLLIN:
            data=d[fd].recv(1024)
            if not data:
                print d[fd].getpeername(),"discponnect"
                p.unregister(fd)
                del d[fd]
            else:
                print data
                d[fd].send("[%s]%s"%(ctime(),data))
s.close()