使用asyncore读取套接字缓冲区

import asyncore
import socket

class EchoHandler(asyncore.dispatcher):
    def handle_read(self):
        data = self.recv(1024)
        if data:
            self.send(data)

    def handle_close(self):
        self.close()

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):
        pair = self.accept()
        if pair is not None:
            sock, addr = pair
            print("Incoming connection from %s" % repr(addr))
            EchoHandler(sock)

if __name__ == "__main__":
    server = EchoServer("localhost", 8080)
    asyncore.loop()