本文以實(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ì)有所幫助。

最新評(píng)論