Python提示[Errno 32]Broken pipe導致線程crash錯誤解決方法

2020-02-23 06:10:14

字體：大中小

來源：轉載

供稿：網友

本文實例講述了Python提示[Errno 32]Broken pipe導致線程crash錯誤解決方法。分享給大家供大家參考。具體方法如下：

1. 錯誤現象
ThreadingHTTPServer 實現的 http 服務，如果客戶端在服務器返回前，主動斷開連接，則服務器端會報 [Errno 32] Broken pipe 錯，并導致處理線程 crash.
下面先看個例子,python 版本: 2.7
示例代碼
代碼如下:#!/usr/bin/env python
#!coding=utf-8

import os
import time
import socket
import threading
from BaseHTTPServer import HTTPServer ,BaseHTTPRequestHandler
from SocketServer import ThreadingMixIn

class RequestHandler(BaseHTTPRequestHandler):
    def do_GET(self):
        """
        處理get請求
        """
        query=self.path
        print "query: %s thread=%s" % (query, str(threading.current_thread()))

        #ret_str="<html>" + self.path + "<br>" + str(self.server) + "<br>" + str(self.responses) + "</html>"
        ret_str="<html>" + self.path + "<br>" + str(self.server) + "</html>"

        time.sleep(5)

        try:
            self.send_response(200)
            self.send_header('Content-type','text/html')
            self.end_headers()
            self.wfile.write(ret_str)
        except socket.error, e:
            print "socket.error : Connection broke. Aborting" + str(e)
            self.wfile._sock.close() # close socket
            self.wfile._sock=None
            return False

        print "success prod query :%s" % (query)
        return True

#多線程處理
class ThreadingHTTPServer(ThreadingMixIn,HTTPServer):
    pass