UDP 数据接收上的 Python 套接字错误。 (10054)

Question

我目前在使用 UDP 和 Python 套接字模块时遇到问题。我们有服务器和客户端。当我们向用户发送数据时会出现问题。用户可能通过客户端崩溃、ISP 断开连接或其他一些不正确的方法关闭了与服务器的连接。因此，可以将数据发送到已关闭的套接字。

当然，对于 UDP，您无法判断数据是否真正到达或是否已关闭，因为它不关心(至少，它不会引发异常)。然而，如果你发送数据并且它被关闭，你会以某种方式取回数据(？？？)，这最终会在 sock.recvfrom 上给你一个套接字错误。 [Errno 10054] 现有连接被远程主机强行关闭。几乎像是来自连接的自动响应。

虽然这很好，并且可以通过 try:except: block 来处理(即使它会稍微降低服务器的性能)。问题是，我无法判断这是来自谁或哪个套接字已关闭。无论如何要找出“谁”(ip，套接字＃)发送了这个？这太棒了，因为我可以立即断开它们并将它们从数据中删除。有什么建议么？谢谢。

服务器:

import socket

class Server(object):
    def __init__(self):
        self.socket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
        self.socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
        self.connected = {}

    def connect(self):
        self.socket.bind(('127.0.0.1', 5579))

    def find_data(self):
        while 1:
            data, address = self.socket.recvfrom(1024)
            self.got_data(data,address)
            if self.connected.has_key(address):
                pass
            else:
                self.connected[address] = None

    def got_data(self, data, address):
        print "GOT",data,"FROM",address
        for people in self.connected:
            print people
            self.send_data('hi', people)

    def send_data(self, data, address):
        self.socket.sendto(data,address)


if __name__ == '__main__':
    server = Server()
    server.connect()
    print "NOW SEARCHING FOR DATA"
    server.find_data()

客户:

import socket, time

class Client(object):
    def __init__(self):
        self.socket = socket.socket(socket.AF_INET,socket.SOCK_DGRAM)

    def connect(self):
        self.socket.connect(('127.0.0.1', 5579))

    def send_data(self):
        self.socket.sendto('hi',('127.0.0.1', 5579))

    def got_data(self, data, address):
        print "GOT",data,"FROM",address


if __name__ == '__main__':
    client = Client()
    client.connect()
    while 1:
        client.send_data()
        time.sleep(5)

Answer 1

首先，这可能是特定于平台的，您没有提及您正在运行的平台；但是，10054 是 WSAECONNRESET，所以我猜是某种 Windows 平台。

其次，如前所述，与 UDP 无关。您在客户端调用 Connect() 只会导致客户端计算机上的网络代码允许您启动 Send() 调用而不是 SendTo() 调用并简单地默认发送数据的地址，当您发出 Send() 调用时提供给调用 Connect() 的地址。

第三，我很惊讶你得到的是 WSAECONNRESET 而不是 ERROR_PORT_UNREACHABLE；然而，根本原因可能是相同的。如果您要发送到的端口上没有打开的套接字，则远程计算机上的 UDP 堆栈可能会发送 ICMP 端口无法访问错误。因此，如果您的客户端发送数据然后关闭套接字，然后您的服务器将数据发送回客户端地址，您将得到一个无法访问的端口，并且某些版本的 Windows 可能会将其转换为连接重置错误...

这些 ICMP 端口不可达错误的问题在于，它们是通过 Winsock 代码通过挂起的 UDP Recv/RecvFrom 调用失败而报告的。正如我解释的那样 here和问题here UDP 堆栈显然知道生成无法访问的端口的地址，但它不会将该信息传递给调用者，因此您无法将这些消息映射到有用的东西。您可能在 Vista 之前的 Windows 版本上运行并且 UDP 堆栈正在对地址做一些有用的事情并且它正在向正确的套接字报告错误，但不要赌它。

你终于有问题了； ICMP 端口不可达错误没有可靠地传递，因此您不能确定如果您尝试将 UDP 数据发送到已经消失的客户端，您将收到错误。恕我直言，这意味着你不应该依赖它，即使它有时有效。

您显然是在尝试在 UDP 之上构建某种面向连接的协议(protocol)(否则为什么您的服务器会保留客户端的地址)。您必须做更多的工作才能通过 UDP 创建可行的伪连接，首先要意识到的事情之一是，您知道客户端何时离开的唯一方法是设置您自己的超时并“断开”您的连接如果您在一段时间内没有收到他们的消息，则为伪连接。

当然这不能回答您的问题；你如何避免异常。我希望你不能。异常的原因可能是来自 Recv() 或 RecvFrom() 调用的“失败”返回代码，python 网络代码可能正在将所有此类失败返回转换为异常(exception)给你。