如何防止errno 32 管道断裂？

问题描述：

目前我正在使用一个用python构建的应用程序。当我在个人电脑上运行它时，它运行正常。

但是，当我将其移至生产服务器时，它一直显示如下错误：

我做了一些研究，发现原因是当服务器仍忙于发送数据时，最终用户浏览器停止了连接。

我想知道为什么会发生这种情况，以及是什么根本原因导致它无法在生产服务器上正常运行，而在我的个人电脑上却可以正常运行。任何建议都值得赞赏

    Exception happened during processing of request from ('127.0.0.1', 34226)
Traceback (most recent call last):
  File "/usr/lib/python2.7/SocketServer.py", line 284, in
_handle_request_noblock
    self.process_request(request, client_address)
  File "/usr/lib/python2.7/SocketServer.py", line 310, in process_request
    self.finish_request(request, client_address)
  File "/usr/lib/python2.7/SocketServer.py", line 323, in finish_request
    self.RequestHandlerClass(request, client_address, self)
  File "/usr/lib/python2.7/SocketServer.py", line 641, in __init__
    self.finish()
  File "/usr/lib/python2.7/SocketServer.py", line 694, in finish
    self.wfile.flush()
  File "/usr/lib/python2.7/socket.py", line 303, in flush
    self._sock.sendall(view[write_offset:write_offset+buffer_size])
error: [Errno 32] Broken pipe

解决方案 1：

您的服务器进程已收到SIGPIPE对套接字的写入。这通常发生在您写入另一方（客户端）完全关闭的套接字时。当客户端程序没有等到收到来自服务器的所有数据，而是直接关闭套接字（使用close函数）时，可能会发生这种情况。

在 C 程序中，您通常会尝试设置为忽略SIGPIPE信号或为其设置虚拟信号处理程序。在这种情况下，写入已关闭的套接字时将返回一个简单的错误。在您的情况下，python 似乎会抛出一个异常，可以将其处理为客户端过早断开连接。

解决方案 2：

如果您的请求被阻塞或花费的时间太长，并且在请求端超时后，它会关闭连接，然后当响应端（服务器）尝试写入套接字时，它会抛出管道损坏错误。

解决方案 3：

这取决于您如何测试它，并且可能取决于个人计算机和服务器的 TCP 堆栈实现的差异。

例如，如果您sendall在个人电脑上总是立即（或非常快）完成，则发送过程中连接可能从未中断。如果您的浏览器在同一台机器上运行，则这种情况很可能发生（因为没有实际的网络延迟）。

一般来说，您只需要通过处理异常来处理客户端在您完成之前断开连接的情况。

请记住，TCP 通信是异步的，但这在物理远程连接上比在本地连接上更明显，因此这种情况很难在本地工作站上重现。具体而言，单台机器上的环回连接通常几乎是同步的。

解决方案 4：

在程序顶部尝试此代码：

from signal import signal, SIGPIPE, SIG_DFL
signal(SIGPIPE,SIG_DFL)

它应该可以解决这个问题。

解决方案 5：

这可能是因为您使用两种方法将数据插入数据库，从而导致网站速度变慢。

def add_subscriber(request, email=None):
    if request.method == 'POST':
        email = request.POST['email_field']
        e = Subscriber.objects.create(email=email).save()  <==== 
        return HttpResponseRedirect('/')
    else:
        return HttpResponseRedirect('/')

在上面的函数中，错误出现在箭头指向的地方。正确的实现如下：

def add_subscriber(request, email=None):
    if request.method == 'POST':
        email = request.POST['email_field']
        e = Subscriber.objects.create(email=email)
        return HttpResponseRedirect('/')
    else:
        return HttpResponseRedirect('/')

解决方案 6：

如果是 Python Web 应用程序或服务（例如 Flask 或 FastAPI），如果生产服务器配置为使耗时过长的请求超时，则可能会发生此错误。Gunicorn 和 Uvicorn 中有相关参数，例如 GRACEFUL_TIMEOUT 和 TIMEOUT，需要根据应用程序的需求进行配置。您可能还需要检查反向代理或网关超时阈值。

解决方案 7：

在主文件中尝试此代码：

def signal_handler(signal, frame):
      # Perform cleanup tasks here
      print("Ctrl+C pressed. Cleaning up and exiting...")

      ack_sock.close()
      perf_sock.close()
      sys.exit(0)


if __name__ == '__main__':
   # Register the signal handler
   signal.signal(signal.SIGINT, signal_handler)
   signal.signal(signal.SIGPIPE, signal_handler)