【问题标题】：Getting BrokenPipeError: [Errno 32] Broken pipe When Sending Second Socket MSG获取 BrokenPipeError：[Errno 32] 发送第二个套接字 MSG 时管道损坏
【发布时间】：2022-01-10 14:16:39
【问题描述】：

我正在尝试使用 Sockets 从 Django 网站向机器人（Raspberry Pi）发送指令，但每当我尝试从该网站发送第二条指令时，都会出现错误。如果您知道是什么原因造成的，那么帮助将是惊人的！网站发送视图：

def form_valid(self, form, **kwargs):
        robo_pk = self.kwargs['pk']
        robo = Robot.objects.get(pk=robo_pk)
        PORT = robo.port
        SERVER = robo.server
        ADDR = (SERVER, PORT)
        self.object = form.save()
        client = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
        client.connect(ADDR)

        def send(msg):
            message = msg.encode(FORMAT)
            msg_length = len(message)
            send_length = str(msg_length).encode(FORMAT)
            send_length += b' ' * (HEADER - len(send_length))
            client.send(send_length)
            client.send(message)

        send(form.cleaned_data['path_options'])
        send("MESSAGE SENT :) !")
        send(DISCONNECT_MESSAGE)
        return render(self.request, "dashboard-home/thank-you.html")

错误回溯：

Traceback (most recent call last):
  File "/usr/lib/python3.7/threading.py", line 917, in _bootstrap_inner
    self.run()
  File "/usr/lib/python3.7/threading.py", line 865, in run
    self._target(*self._args, **self._kwargs)
  File "main.py", line 46, in handle_client
    conn.send("MSG Received".encode(FORMAT))
BrokenPipeError: [Errno 32] Broken pipe

相关代码：

def handle_client(conn, addr):
    print(f"[NEW CONNECTION] {addr} connected")
    connected = True
    while connected:
        msg_length = conn.recv(HEADER).decode(FORMAT)
        if msg_length:
            msg_length = int(msg_length)
            msg = conn.recv(msg_length).decode(FORMAT)
            if msg == '!DISCONNECT!':
                connected = False
                print("disconnect")
                break
            else:
                my_queue.put(msg)
            print(f"[{ADDR}] {msg}")
            conn.send("MSG Received".encode(FORMAT))
    conn.close()
def start():
    server.listen()
    print(f"[LISTENING] Server Is Listening On {SERVER}")
    while True:
        print("before")
        conn,addr = server.accept()
        print("after")
        thread = threading.Thread(target=handle_client, args=(conn, addr))
        thread.start()
        print(f"[ACTIVE CONNECTIONS] {threading.activeCount()}")

print("[Starting] Server")
threading.Thread(target=start).start()

msg = my_queue.get()

【问题讨论】：

您是否在接收所有数据之前检查了 Raberry Pi 是否关闭了套接字？此链接可能对您有所帮助：stackoverflow.com/questions/11866792/…
@Hamed_gibago 我看到了这个问题，但我不完全确定它是如何关联的或这里的解决方案是什么？你能解释一下吗？
我认为你最好打开一个套接字进行测试，看看套接字何时会从网站关闭。另一种解决方案是，首先从网站接收所有数据，如果数据不大，只需将其保存到您的变量（ram）中，接收到所有数据后，关闭套接字，然后将其发送到您的 resberry Pi。

标签： python python-3.x sockets networking raspberry-pi

【解决方案1】：

在收到所有消息之前，您正在断开客户端。为了证明这一点，请在注释掉 conn.close 的情况下再次运行。您缺少额外的逻辑来确保在关闭连接之前已处理所有待处理的请求。

参考文献

https://stackoverflow.com/a/11866962/806876

【讨论】：

【解决方案2】：

django 客户端在发送 DISCONNECT_MESSAGE 后立即断开连接。服务器检测到连接关闭，使conn socket无效，导致异常。例如，这种失效可能发生在消息“MESSAGE SENT :)”的 recv() 和服务器对此的响应 (conn.send()) 之间。

更多信息请参见How to handle a broken pipe (SIGPIPE) in python?。

【讨论】：