python 异步连接

Question

有没有办法检查 asyncore 中是否建立了连接？

一旦调用 asyncore.loop() ，如何断开服务器之间的通信？

我可以简单地调用 close() 吗？

Answer 1

一旦调用 asyncore.loop()，控制权就会移交给运行的事件循环。

asyncore.loop() 之后的任何代码只有在事件循环关闭后才会被调用。

事件循环将对各种事件做出反应并调用处理程序。 要关闭事件循环，您必须在有意义的事件处理程序之一中调用 stop。

例如：请看以下示例。

代码来自： http://www.mechanicalcat.net/richard/log/Python/A_simple_asyncore__echo_server__example< /a>

import asyncore, socket

class Client(asyncore.dispatcher_with_send):
    def __init__(self, host, port, message):
        asyncore.dispatcher.__init__(self)
        self.create_socket(socket.AF_INET, socket.SOCK_STREAM)
        self.connect((host, port))
        self.out_buffer = message

    def handle_close(self):
        self.close()

    def handle_read(self):
        print 'Received', self.recv(1024)
        self.close()

c = Client('', 5007, 'Hello, world')
asyncore.loop()

self.close 在事件处理程序之一 -handle_read 内调用。在这种情况下，从服务器接收到数据后。它会自行断开连接。

参考文献：

• http://effbot.org/librarybook/asyncore.htm
• http://pymotw.com/2/asyncore/index.html#module-asyncore

Answer 2

有没有办法检查 asyncore 中是否建立了连接？

与套接字一起使用，您可以重载asyncore的handle_connect()方法。当套接字连接时调度程序运行：

import asyncore

class MyClientConnection(asyncore.dispatcher):
    def handle_connect(self):
        '''Socket is connected'''
        print "Connection is established"

如果您更喜欢轮询，请读取 asyncore.dispatcher 中的变量 connected ：

myclient = MyClientConnection()
isConnected = myClient.connected