Python異步通信模塊asyncore解讀

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

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

Python異步通信模塊asyncore

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

模塊主要包括

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

例子

下面看一個簡單的例子

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 - 響應服務器端程序，負責監(jiān)聽一個端口，并響應客戶端發(fā)送的消息然后原樣返回給客戶端。

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

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

EchoClient - 響應服務客戶端程序，負責連接響應服務器。其中