python中的asyncore

在Python中，既可直接使用socket類，也可使用socketserver，asyncore等經過封裝的類來進行編碼。asyncore這個庫中主要包含了兩個函數：

  • asyncore.loop([timeout[, use_poll[, map[, count]]]])
  • class asyncore.dispatcher

Event

description

handle_connect()

Implied by the first read or write event

handle_close()

Implied by a read event with no data available

handle_accepted()

Implied by a read event on a listening socket

該模組是事件驅動的，loop（）函數用於循環監聽網路事件，dispatcher相當於一個socket對象，用於網路事件交互。loop()函數負責檢測一個dict，dict中保存dispatcher的實例，這個字典被稱為channel。每次創建一個dispatcher對象，都會把自己加入到一個默認的dict裡面去（當然也可以自己指定channel）。當對象被加入到channel中的時候，socket的行為都已經被定義好，程式只需要調用loop()，一切功能就實現了。

我們定義一個類，它繼承dispatcher類，然後我們重寫基類的方法。每個繼承dispatcher類的對象，都可以看做我們需要處理的一個socket，可以TCP也可以是UDP，甚至是一些不常用的。

這是標準文檔中的一個例子。

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 = bytes('GET %s HTTP/1.0rnHost: %srnrn' %                              (path, host), 'ascii')      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()

dispatcher類中的writable和readable在檢測到一個socket可以寫入或者數據到達的時候被調用，並返回一個bool值，決定是否調用handle_read或者handle_write。打開asyncore.py可以看到，dispatcher類中定義的方法writable和readable的定義相當的簡單：

def readable(self):      return True  def writable()      return True

也就是說，一旦檢測到可讀或可寫，就調用handle_read/handle_write，但在這個例子中重寫了父類的writable方法，

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。

Tags:

VirMach 便宜 VPS