0

我制作了这个基本客户端来适应异步。

import asyncore, socket

class TestClient(asyncore.dispatcher):
    def __init__(self, host, port):
        asyncore.dispatcher.__init__(self)
        self.create_socket(socket.AF_INET, socket.SOCK_STREAM)
        self.connect((host, port))
        self.buffer = "madonna"

        def handle_connect(self):
            pass

        def handle_close(self):
            print "Close"
            self.close()

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

        def writable(self):
            print "Calling writable"
            return (len(self.buffer) > 0)

        def handle_write(self):
            print "Write"
            sent = self.send(self.buffer)
            self.buffer = self.buffer[sent:]

client = TestClient("127.0.0.1", 7899)
asyncore.loop()

我觉得我做的不对。我可以连接到服务器，但它不发送任何数据。因为buffer不是空的，不应该调用 Writable 来检查缓冲区，如果不是空的调用handle_write？

除了__init__方法之外，没有任何东西被调用。

4

1 回答 1

2

你应该重新缩进你的方法:)

于 2013-08-29T12:41:30.737 回答