本文以實例分析了Python中asyncore模塊的原理及用法，分享給大家供大家參考。具體分析如下：

asyncore庫是python的一個標準庫，它是一個異步socket的包裝。我們操作網(wǎng)絡(luò)的時候可以直接使用socket等底層的庫，但是asyncore使得我們可以更加方便的操作網(wǎng)絡(luò)，避免直接使用socket，select，poll等工具時需要面對的復(fù)雜。

這個庫很簡單，包含了一個函數(shù)和一個類

* loop()函數(shù)

* dispatcher基類

需要注意的是，loop函數(shù)是全局的，不是dispatcher的方法

每一個從dispatcher繼承的類的對象，都可以看作我們需要處理的一個socket,可以是TCP連接或者UDP，甚至是其它不常用的。使用容易，我們需要定義一個類，它繼承dispatcher，然后我們重寫(覆蓋)一些方法就可以了。

我們需要重寫的方法一般都以handle_打頭。

class refuse(dispatcher):

def handle_accept():

#do nothing ...

pass

loop()函數(shù)負責(zé)檢測一個dict，dict中保存dispatcher的實例，這個字典被稱為channel。每次創(chuàng)建一個dispatcher對象，都會把自己加入到一個默認的dict里面去(當(dāng)然也可以自己指定channel)。當(dāng)對象被加入到channel中的時候，socket的行為都已經(jīng)被定義好，程序只需要調(diào)用loop()，一切功能就實現(xiàn)了。

asyncore是python標準庫中的一個良好的設(shè)計

在python的標準文檔中，有一個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.0rnrn' % 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()

運行這個函數(shù)，發(fā)現(xiàn)python.org的首頁被下載下來了，也就是說我們實現(xiàn)了一個http層的協(xié)議？但是我們用的僅僅是socket級別的API…那么來看看這幾行代碼的奧妙吧！

writable和readable在檢測到一個socket可以寫入或者檢測到數(shù)據(jù)到達的時候，被調(diào)用，并返回一個bool來決定是否handle_read或者handle_write

打開asyncore.py可以看到，dispatcher類中定義的方法writable和readable的定義相當(dāng)?shù)暮唵?#xff1a;

def readable(self):

return True

def writable(self):

return True

就是說，一旦檢測到可讀或可寫，就直接調(diào)用handle_read/handle_write，但是在上面的例子中，我們卻看到了一個重載(看上去像C++的虛函數(shù)，不是嗎？)

總結(jié)

以上是生活随笔為你收集整理的python模块用法教程_Python学习之asyncore模块用法实例教程的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。