python中的asyncore.dispatcher:handle_何时关闭并执行handle_read？

Question

有两个文件：server.py和client.py，都是在asyncore.dispatcher的帮助下编写的

服务器.py

import asyncore, socket

class Server(asyncore.dispatcher):
    def __init__(self, host, port):
        asyncore.dispatcher.__init__(self)
        self.create_socket(socket.AF_INET, socket.SOCK_STREAM)
        self.bind(('', port))
        self.listen(1)
        print "Waiting for connection..."

    def handle_accept(self):
        socket, address = self.accept()
        print 'Connection by', address
        socket.send("Hello Server")

    def handle_read(self):
        print "Reading..."
        out_buffer = self.recv(1024)
        if not out_buffer:
            self.close()
        print out_buffer

    def handle_closed(self):
        print "Server: Connection Closed"
        self.close()

s = Server('0.0.0.0', 5007)
asyncore.loop()

客户端.py

import asyncore, socket

class Client(asyncore.dispatcher):
    def __init__(self, host, port):
        asyncore.dispatcher.__init__(self)
        self.create_socket(socket.AF_INET, socket.SOCK_STREAM)
        self.connect((host, port))
        print "Client Start..."

    def handle_close(self):
        print "Client: Connection Closed"
        self.close()

    def handle_read(self):
        data = self.recv(1024)
        if data:
            print "Received ", data
        self.send("Hello Client")

c = Client('127.0.0.1', 5007)
asyncore.loop()

结果：

执行server.py：

Waiting for connection...

那么client.py：

Client Start...
Received  Hello Server
Client: Connection Closed
Client: Connection Closed

最后client.py退出，在server.py的输出窗口中又显示了一行，服务器继续运行：

Connection by ('127.0.0.1', 58197)

有些事情我无法理解：

1. 为什么client.py中的函数handle_closed要执行两次？

2. 为什么在server.py中的函数handle_reading没有执行？client.py已发送消息（“Hello client”），但服务器为什么不能接收它？

3. 为什么在server.py中的函数handle_closed没有执行？我想在客户机退出时在server.py中执行一些代码，但它似乎与在server.py中执行无关？

Answer 1

异步通话

永远不会调用server.py中的handle_read()。

但为什么？！这是一个服务器类。。。

是的，但是Server类使用它的套接字来监听任何未建立的连接。它上的任何读取都会转到handle_accept()，在这里，实际的通道套接字（连接到某个端点）应该被赋予某些dispatcher继承类的新实例（最好）。在Server的handle_accept()方法中，由accept()获得的套接字是本地的，因此在退出此函数时将其删除，因此：接受新连接，发送文本，然后立即终止套接字。

阅读异步模块和my answer中的其他问题。

服务器

如我所说，您需要在server.py中为连接创建新类：

class ClientHandler(asyncore.dispatcher):
    def handle_read(self):
        data = self.recv(1024)
        if not data:
            return
        print "Received:", data

    def handle_close(self):
        print "Server: Connection Closed"
        self.close()

注意，当收到空值时，读取不需要手动关闭套接字-asyncore会正确关闭连接。

当建立连接时，您必须在Server中实例化它：

    def handle_accept(self):
        ...
        ClientHandler(socket)

您还在Server中犯了拼写错误-方法的正确名称是handle_close。尽管这没用。与客户端连接相关的所有内容都在ClientHandler中。

客户

在client.py中，只需修改handle_read()：

    if data:
        print "Received ", data

更改为：

    if not data:
        return
    print "Received ", data

为什么？如果没有这个，send()将被调用，即使套接字实际上是关闭的，这将导致handle_close()被asyncore第二次调用。就像我说的-asyncore处理这个。

注释

现在您可以为连接编写更复杂的服务器端类。您还可以学习操作系统级套接字的工作方式，这样就不会遇到麻烦。

asyncore本身是一个很好的套接字包装器，但是如果您想在某些事件驱动环境中执行更高级别的操作，比如HTTP或SMTP处理，那么Twisted库会让您感兴趣！