Python异步套接字接收未工作

Question

这里有一个简单的客户端，可以连接并发送文本消息：

class Client(asyncore.dispatcher):

    def __init__(self, host, port):
        asyncore.dispatcher.__init__(self)
        self.create_socket()
        self.connect( (host, port) )
        self.buffer = bytes("hello world", '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 writable(self):
        return True

    def handle_write(self):
        sent = self.send(self.buffer)
        print('Sent:', sent)
        self.buffer = self.buffer[sent:]


client = Client('localhost', 8080)
asyncore.loop()

这里是需要接收消息并将其回显的服务器：

class Server(asyncore.dispatcher):
    def __init__(self, host, port):
        asyncore.dispatcher.__init__(self)
        self.create_socket()
        self.set_reuse_addr()
        self.bind((host, port))
        self.listen(5)

    def handle_read(self):
        self.buffer = self.recv(4096)
        while True:
            partial = self.recv(4096)
            print('Partial', partial)
            if not partial:
                break
            self.buffer += partial

    def readable(self):
        return True

    def handle_write(self):
        pass

    def handle_accepted(self, sock, addr):
        print('Incoming connection from %s' % repr(addr))
        self.handle_read()
        print(self.buffer)


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

问题在于服务器没有读取任何内容。当我打印self.buffer时，输出结果是:

b''

我做错了什么？

- conquester

---

你的服务器代码中 self.accept() 在哪里？ - qvpham

我认为在异步套接字中不需要这个：https://docs.python.org/3/library/asyncore.html 我有来自最后一个示例的这段代码。并且连接被接受，因为handle_accepted中的打印语句将其打印出来。 - conquester

好的，我看到了。我已经阅读了Py 2的文档。但是我认为，你应该使用一个单独的类来处理与客户端的连接。如果你把所有东西都写在一起，它就不能是异步的。 - qvpham

Answer 1

首先，您需要两个处理程序：一个用于服务器套接字（您只期望accept），另一个用于实际通信套接字。此外，在handle_read中只能调用一次read；如果调用两次，则第二次调用可能会阻塞，这在异步编程中是不允许的。不过不要担心；如果您的读取没有获取所有内容，一旦您的读取处理程序返回，您将立即收到再次通知。

import asyncore

class Handler(asyncore.dispatcher):
    def __init__(self, sock):
        self.buffer = b''
        super().__init__(sock)

    def handle_read(self):
        self.buffer += self.recv(4096)
        print('current buffer: %r' % self.buffer)


class Server(asyncore.dispatcher):
    def __init__(self, host, port):
        asyncore.dispatcher.__init__(self)
        self.create_socket()
        self.set_reuse_addr()
        self.bind((host, port))
        self.listen(5)

    def handle_accepted(self, sock, addr):
        print('Incoming connection from %s' % repr(addr))
        Handler(sock)


if __name__ == "__main__":
    server = Server("localhost", 1234)
    asyncore.loop()

- phihag