Python學(xué)習(xí)之a(chǎn)syncore模塊用法實(shí)例教程
本文以實(shí)例分析了Python中asyncore模塊的原理及用法,分享給大家供大家參考。具體分析如下:
asyncore庫(kù)是python的一個(gè)標(biāo)準(zhǔn)庫(kù),它是一個(gè)異步socket的包裝。我們操作網(wǎng)絡(luò)的時(shí)候可以直接使用socket等底層的庫(kù),但是asyncore使得我們可以更加方便的操作網(wǎng)絡(luò),避免直接使用socket,select,poll等工具時(shí)需要面對(duì)的復(fù)雜。
這個(gè)庫(kù)很簡(jiǎn)單,包含了一個(gè)函數(shù)和一個(gè)類
* loop()函數(shù)
* dispatcher基類
需要注意的是,loop函數(shù)是全局的,不是dispatcher的方法
每一個(gè)從dispatcher繼承的類的對(duì)象,都可以看作我們需要處理的一個(gè)socket,可以是TCP連接或者UDP,甚至是其它不常用的。使用容易,我們需要定義一個(gè)類,它繼承dispatcher,然后我們重寫(xiě)(覆蓋)一些方法就可以了。
我們需要重寫(xiě)的方法一般都以handle_打頭。
class refuse(dispatcher): def handle_accept(): #do nothing ... pass
loop()函數(shù)負(fù)責(zé)檢測(cè)一個(gè)dict,dict中保存dispatcher的實(shí)例,這個(gè)字典被稱為channel。每次創(chuàng)建一個(gè)dispatcher對(duì)象,都會(huì)把自己加入到一個(gè)默認(rèn)的dict里面去(當(dāng)然也可以自己指定channel)。當(dāng)對(duì)象被加入到channel中的時(shí)候,socket的行為都已經(jīng)被定義好,程序只需要調(diào)用loop(),一切功能就實(shí)現(xiàn)了。
asyncore是python標(biāo)準(zhǔn)庫(kù)中的一個(gè)良好的設(shè)計(jì)
在python的標(biāo)準(zhǔn)文檔中,有一個(gè)asyncore的例子
import asyncore, socket class 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()
運(yùn)行這個(gè)函數(shù),發(fā)現(xiàn)python.org的首頁(yè)被下載下來(lái)了,也就是說(shuō)我們實(shí)現(xiàn)了一個(gè)http層的協(xié)議?但是我們用的僅僅是socket級(jí)別的API…那么來(lái)看看這幾行代碼的奧妙吧!
writable和readable在檢測(cè)到一個(gè)socket可以寫(xiě)入或者檢測(cè)到數(shù)據(jù)到達(dá)的時(shí)候,被調(diào)用,并返回一個(gè)bool來(lái)決定是否handle_read或者h(yuǎn)andle_write
打開(kāi)asyncore.py可以看到,dispatcher類中定義的方法writable和readable的定義相當(dāng)?shù)暮?jiǎn)單:
def readable(self): return True def writable(self): return True
就是說(shuō),一旦檢測(cè)到可讀或可寫(xiě),就直接調(diào)用handle_read/handle_write,但是在上面的例子中,我們卻看到了一個(gè)重載(看上去像C++的虛函數(shù),不是嗎?)
def writable(self): return (len(self.buffer) > 0)
很明顯,當(dāng)我們有數(shù)據(jù)需要發(fā)送的時(shí)候,我們才給writable的調(diào)用者返回一個(gè)True,這樣就不需要在handle_write中再做判斷了,邏輯很明確,代碼很清晰,美中不足的是理解需要一點(diǎn)時(shí)間,但是不算困難吧!
其余的代碼看起來(lái)就很清晰了,有一種兵來(lái)將擋的感覺(jué)。當(dāng)一個(gè)http服務(wù)器發(fā)送處理完成你的請(qǐng)求,close socket的時(shí)候,我們的handle_close()也相應(yīng)完成自己的使命。close()將對(duì)象自身從channel中刪除,并且負(fù)責(zé)銷毀socket對(duì)象。
def close(self): self.del_channel() self.socket.close()
loop()函數(shù)檢測(cè)到一個(gè)空的channel,將退出循環(huán),程序完成任務(wù),exit。
希望本文所述對(duì)大家的Python程序設(shè)計(jì)有所幫助。
相關(guān)文章
詳解Pytorch+PyG實(shí)現(xiàn)GCN過(guò)程示例
這篇文章主要為大家介紹了Pytorch+PyG實(shí)現(xiàn)GCN過(guò)程示例詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪2023-04-04python數(shù)學(xué)建模之Matplotlib?實(shí)現(xiàn)圖片繪制
這篇文章主要介紹了python數(shù)學(xué)建模之Matplotlib?實(shí)現(xiàn)圖片繪制,文章圍繞主題展開(kāi)詳細(xì)的內(nèi)容介紹,具有一定的參考價(jià)值,需要的小伙伴可以參考一下2022-07-07python實(shí)現(xiàn)PyEMD經(jīng)驗(yàn)?zāi)B(tài)分解殘差量分析
這篇文章主要為大家介紹了PyEMD經(jīng)驗(yàn)?zāi)B(tài)分解及變體殘余量分析,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪2022-05-05python多線程http下載實(shí)現(xiàn)示例
python多線程http下載實(shí)現(xiàn)示例,大家參考使用吧2013-12-12Python+ChatGPT實(shí)現(xiàn)5分鐘快速上手編程
最近一段時(shí)間chatGPT火爆出圈!無(wú)論是在互聯(lián)網(wǎng)行業(yè),還是其他各行業(yè)都賺足了話題。俗話說(shuō):“外行看笑話,內(nèi)行看門(mén)道”,今天從chatGPT個(gè)人體驗(yàn)感受以及如何用的角度來(lái)分享一下2023-02-02