国产探花免费观看_亚洲丰满少妇自慰呻吟_97日韩有码在线_资源在线日韩欧美_一区二区精品毛片,辰东完美世界有声小说,欢乐颂第一季,yy玄幻小说排行榜完本

首頁 > 編程 > Python > 正文

Python學習之asyncore模塊用法實例教程

2019-11-25 18:10:14
字體:
來源:轉載
供稿:網友

本文以實例分析了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)

很明顯,當我們有數據需要發送的時候,我們才給writable的調用者返回一個True,這樣就不需要在handle_write中再做判斷了,邏輯很明確,代碼很清晰,美中不足的是理解需要一點時間,但是不算困難吧!

其余的代碼看起來就很清晰了,有一種兵來將擋的感覺。當一個http服務器發送處理完成你的請求,close socket的時候,我們的handle_close()也相應完成自己的使命。close()將對象自身從channel中刪除,并且負責銷毀socket對象。

def close(self):  self.del_channel()  self.socket.close()

loop()函數檢測到一個空的channel,將退出循環,程序完成任務,exit。

希望本文所述對大家的Python程序設計有所幫助。

發表評論 共有條評論
用戶名: 密碼:
驗證碼: 匿名發表
主站蜘蛛池模板: 涞源县| 汪清县| 宣恩县| 出国| 修水县| 上林县| 临城县| 页游| 三亚市| 启东市| 广水市| 吉安县| 多伦县| 盈江县| 霍州市| 徐汇区| 澄江县| 灵璧县| 仁怀市| 遂溪县| 旬阳县| 通辽市| 多伦县| 龙海市| 和顺县| 武安市| 东丽区| 绥江县| 杨浦区| 邻水| 淮阳县| 梅河口市| 南郑县| 武威市| 会同县| 武威市| 团风县| 泰和县| 阿拉善右旗| 肇东市| 张家口市|