Python異步通信模塊asyncore解讀

更新時(shí)間：2023年11月10日 08:54:59 作者：kongxx

這篇文章主要介紹了Python異步通信模塊asyncore的使用,具有很好的參考價(jià)值,希望對(duì)大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教

Python異步通信模塊asyncore

Python的asyncore模塊提供了以異步的方式寫入套接字服務(wù)的客戶端和服務(wù)器的基礎(chǔ)結(jié)構(gòu)。

模塊主要包括

asyncore.loop(…) - 用于循環(huán)監(jiān)聽網(wǎng)絡(luò)事件。loop()函數(shù)負(fù)責(zé)檢測(cè)一個(gè)字典，字典中保存dispatcher的實(shí)例。
asyncore.dispatcher類 - 一個(gè)底層套接字對(duì)象的簡(jiǎn)單封裝。這個(gè)類有少數(shù)由異步循環(huán)調(diào)用的，用來(lái)事件處理的函數(shù)。
dispatcher類中的writable()和readable()在檢測(cè)到一個(gè)socket可以寫入或者數(shù)據(jù)到達(dá)的時(shí)候被調(diào)用，并返回一個(gè)bool值，決定是否調(diào)用handle_read或者h(yuǎn)andle_write。
asyncore.dispatcher_with_send類 - 一個(gè) dispatcher的子類，添加了簡(jiǎn)單的緩沖輸出能力，對(duì)簡(jiǎn)單的客戶端很有用。

例子

下面看一個(gè)簡(jiǎn)單的例子

import time
import asyncore
import socket
import threading


class EchoHandler(asyncore.dispatcher_with_send):

    def handle_read(self):
        data = self.recv(1024)
        if data:
            self.send(data)

class EchoServer(asyncore.dispatcher):

    def __init__(self, host, port):
        asyncore.dispatcher.__init__(self)
        self.create_socket(socket.AF_INET, socket.SOCK_STREAM)
        self.set_reuse_addr()
        self.bind((host, port))
        self.listen(5)

    def handle_accept(self):
        conn, addr = self.accept()
        print 'Incoming connection from %s' % repr(addr)
        self.handler = EchoHandler(conn)

class EchoClient(asyncore.dispatcher):

    def __init__(self, host, port):
        asyncore.dispatcher.__init__(self)
        self.messages = ['1', '2', '3', '4', '5', '6', '7', '8', '9', '10']
        self.create_socket(socket.AF_INET, socket.SOCK_STREAM)
        self.connect((host, port))

    def handle_connect(self):
        pass

    def handle_close(self):
        self.close()

    def handle_read(self):
        print self.recv(1024)

    def writable(self):
        return (len(self.messages) > 0)

    def handle_write(self):
        if len(self.messages) > 0: 
            self.send(self.messages.pop(0))

class EchoServerThread(threading.Thread):
    def __init__(self):
        threading.Thread.__init__(self)

    def run(self):
        server = EchoServer('localhost', 9999)
        asyncore.loop()

class EchoClientThread(threading.Thread):
    def __init__(self):
        threading.Thread.__init__(self)

    def run(self):
        client = EchoClient('localhost', 9999)
        asyncore.loop()

EchoServerThread().start()
time.sleep(2)
EchoClientThread().start()

EchoServer - 響應(yīng)服務(wù)器端程序，負(fù)責(zé)監(jiān)聽一個(gè)端口，并響應(yīng)客戶端發(fā)送的消息然后原樣返回給客戶端。

其中handle_accept()方法定義當(dāng)一個(gè)連接到來(lái)的時(shí)候要執(zhí)行的操作，這里指定了使用一個(gè)Handler來(lái)出來(lái)發(fā)送來(lái)的數(shù)據(jù)。

EchoHandler - 服務(wù)器端數(shù)據(jù)響應(yīng)類，接收數(shù)據(jù)并把數(shù)據(jù)原樣發(fā)回。

EchoClient - 響應(yīng)服務(wù)客戶端程序，負(fù)責(zé)連接響應(yīng)服務(wù)器。其中