本文以實例分析了Python中asyncore模塊的原理及用法,分享給大家供大家參考。具體分析如下:
asyncore庫是python的一個標準庫,它是一個異步socket的包裝。我們操作網絡的時候可以直接使用socket等底層的庫,但是asyncore使得我們可以更加方便的操作網絡,避免直接使用socket,select,poll等工具時需要面對的復雜。
這個庫很簡單,包含了一個函數和一個類
* loop()函數
* dispatcher基類
需要注意的是,loop函數是全局的,不是dispatcher的方法
每一個從dispatcher繼承的類的對象,都可以看作我們需要處理的一個socket,可以是TCP連接或者UDP,甚至是其它不常用的。使用容易,我們需要定義一個類,它繼承dispatcher,然后我們重寫(覆蓋)一些方法就可以了。
我們需要重寫的方法一般都以handle_打頭。
class refuse(dispatcher): def handle_accept(): #do nothing ... pass
loop()函數負責檢測一個dict,dict中保存dispatcher的實例,這個字典被稱為channel。每次創建一個dispatcher對象,都會把自己加入到一個默認的dict里面去(當然也可以自己指定channel)。當對象被加入到channel中的時候,socket的行為都已經被定義好,程序只需要調用loop(),一切功能就實現了。
asyncore是python標準庫中的一個良好的設計
在python的標準文檔中,有一個asyncore的例子
import asyncore, socketclass http_client(asyncore.dispatcher): def __init__(self, host, path): asyncore.dispatcher.__init__(self) self.create_socket(socket.AF_INET, socket.SOCK_STREAM) self.connect( (host, 80) ) self.buffer = 'GET %s HTTP/1.0/r/n/r/n' % path def handle_connect(self): pass def handle_close(self): self.close() def handle_read(self): print self.recv(8192) def writable(self): return (len(self.buffer) > 0) def handle_write(self): sent = self.send(self.buffer) self.buffer = self.buffer[sent:]c = http_client('www.python.org', '/')asyncore.loop()
運行這個函數,發現python.org的首頁被下載下來了,也就是說我們實現了一個http層的協議?但是我們用的僅僅是socket級別的API…那么來看看這幾行代碼的奧妙吧!
writable和readable在檢測到一個socket可以寫入或者檢測到數據到達的時候,被調用,并返回一個bool來決定是否handle_read或者handle_write
打開asyncore.py可以看到,dispatcher類中定義的方法writable和readable的定義相當的簡單:
def readable(self): return Truedef writable(self): return True
就是說,一旦檢測到可讀或可寫,就直接調用handle_read/handle_write,但是在上面的例子中,我們卻看到了一個重載(看上去像C++的虛函數,不是嗎?)
def writable(self): return (len(self.buffer) > 0)
新聞熱點
疑難解答