Python實(shí)現(xiàn)異步IO的示例

第Python實(shí)現(xiàn)異步IO的示例2.多路復(fù)用io監(jiān)聽內(nèi)核事件，事件觸發(fā)通過回調(diào)函數(shù)；

3.用戶態(tài)代碼采取事件循環(huán)的方式獲取事件，執(zhí)行事件的回調(diào)函數(shù)；

importselectors

importsocket

importtime

#fromasynrequestimportParserHttp

classasynhttp:

def__init__(self):

self.selecter=selectors.DefaultSelector()

defget(self,url,optiondict=None):

globalreqcount

reqcount+=1

s=socket.socket()

s.setblocking(False)

try:

s.connect(('',5555))

exceptBlockingIOError:

pass

requset='GET%sHTTP/1.0\r\n\r\n'%url

callback=lambda:self.send(s,requset)

self.selecter.register(s.fileno(),selectors.EVENT_WRITE,callback)

defsend(self,s,requset):

self.selecter.unregister(s.fileno())

s.send(requset.encode())

chunks=[]

callback=lambda:self.recv(s,chunks)

self.selecter.register(s.fileno(),selectors.EVENT_READ,callback)

defrecv(self,s,chunks):

self.selecter.unregister(s.fileno())

chunk=s.recv(1024)

ifchunk:

chunks.append(chunk)

callback=lambda:self.recv(s,chunks)

self.selecter.register(s.fileno(),selectors.EVENT_READ,callback)

else:

globalreqcount

reqcount-=1

request_first,request_headers,request_content,_=ParserHttp.parser(b''.join(chunks))

print("解析數(shù)據(jù)：",request_first,request_headers,request_content)

print((b''.join(chunks)).decode())

return(b''.join(chunks)).decode()

starttime=time.time()

reqcount=0

asynhttper=asynhttp()

asynhttper.get('/bar')

asynhttper.get('/foo')

whilereqcount:

events=asynhttper.selecter.select()

forevent,maskine