亚洲免费在线-亚洲免费在线播放-亚洲免费在线观看-亚洲免费在线观看视频-亚洲免费在线看-亚洲免费在线视频

Python提示[Errno 32]Broken pipe導(dǎo)致線程crash

系統(tǒng) 1989 0

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

1. 錯誤現(xiàn)象
ThreadingHTTPServer 實(shí)現(xiàn)的 http 服務(wù),如果客戶端在服務(wù)器返回前,主動斷開連接,則服務(wù)器端會報 [Errno 32] Broken pipe 錯,并導(dǎo)致處理線程 crash.
下面先看個例子,python 版本: 2.7
示例代碼

復(fù)制代碼 代碼如下:
#!/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="" + self.path + "
" + str(self.server) + "
" + str(self.responses) +? ""
??????? ret_str="" + self.path + "
" + str(self.server) +? ""
????????
??????? 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
????
if __name__ == '__main__':
??? serveraddr = ('',9001)
?
??? ser = ThreadingHTTPServer(serveraddr,RequestHandler)
??? ser.serve_forever()
??? sys.exit(0)

運(yùn)行服務(wù)
./thread_http_server_error.py
第1次 curl ,等待返回
復(fù)制代碼 代碼如下:
[~]$curl -s 'http://10.232.41.142:9001/hello1′
/hello1
<__main__.ThreadingHTTPServer instance at 0x37483b0>[~]$
此時服務(wù)器端輸出日志如下:
$./thread_http_server_error.py
query: /hello1 thread=
search041142.sqa.cm4.tbsite.net ?C - [15/May/2014 15:02:27] “GET /hello1 HTTP/1.1″ 200 -
success prod query :/hello1

?第2次 curl ,不等待返回,ctrl +C 來模擬客戶端斷開
復(fù)制代碼 代碼如下:
[~]$curl -s 'http://10.232.41.142:9001/hello2′
[~]$ ctrl+C

此時服務(wù)器端輸出日志如下:
復(fù)制代碼 代碼如下:
query: /hello2 thread=
search041142.sqa.cm4.tbsite.net ?C - [15/May/2014 15:33:10] “GET /hello2 HTTP/1.1″ 200 -
socket.error : Connection broke. Aborting[Errno 32] Broken pipe
―――――――――――――-
Exception happened during processing of request from ('10.232.41.142′, 48769)
Traceback (most recent call last):
File “/home/wuzhu/tools/python_2_7_1/lib/python2.7/SocketServer.py”, line 582, in process_request_thread
self.finish_request(request, client_address)
File “/home/wuzhu/tools/python_2_7_1/lib/python2.7/SocketServer.py”, line 323, in finish_request
self.RequestHandlerClass(request, client_address, self)
File “/home/wuzhu/tools/python_2_7_1/lib/python2.7/SocketServer.py”, line 639, in __init__
self.handle()
File “/home/wuzhu/tools/python_2_7_1/lib/python2.7/BaseHTTPServer.py”, line 337, in handle
self.handle_one_request()
File “/home/wuzhu/tools/python_2_7_1/lib/python2.7/BaseHTTPServer.py”, line 326, in handle_one_request
?self.wfile.flush() #actually send the response if not already done.
File “/home/wuzhu/tools/python_2_7_1/lib/python2.7/socket.py”, line 303, in flush
self._sock.sendall(view[write_offset:write_offset+buffer_size])
AttributeError: 'NoneType' object has no attribute 'sendall'

2. 原因分析

“[Errno 32] Broken pipe “ 產(chǎn)生的原因還是比較明確的,由于 client 在服務(wù)器返回前主動斷開連接,所以服務(wù)器在返回時寫 socket 收到SIGPIPE報錯。雖然在我們的程序中也對異常進(jìn)行了處理,將handler 的 wfile._sock 對象close 掉 ,但python 的庫里BaseHTTPServer.py中BaseHTTPRequestHandler 類的成員函數(shù)handle_one_request還是會直接調(diào)用 wfile.flush ,而沒有判斷 wfile 是否已經(jīng) close。

復(fù)制代碼 代碼如下:
def handle_one_request(self):
??? """Handle a single HTTP request.
?
??? You normally don't need to override this method; see the class
??? __doc__ string for information on how to handle specific HTTP
??? commands such as GET and POST.
?
??? """
??? try:
??????? self.raw_requestline = self.rfile.readline(65537)
??????? if len(self.raw_requestline) > 65536:
??????????? self.requestline = ''
??????????? self.request_version = ''
??????????? self.command = ''
??????????? self.send_error(414)
??????????? return
??????? if not self.raw_requestline:
??????????? self.close_connection = 1
??????????? return
??????? if not self.parse_request():
??????????? # An error code has been sent, just exit
??????????? return
??????? mname = 'do_' + self.command
??????? if not hasattr(self, mname):
??????????? self.send_error(501, "Unsupported method (%r)" % self.command)
??????????? return
??????? method = getattr(self, mname)
??????? method()
??????? #沒有判斷 wfile 是否已經(jīng) close 就直接調(diào)用 flush()
??????? self.wfile.flush() #actually send the response if not already done.
??? except socket.timeout, e:
??????? #a read or a write timed out.? Discard this connection
??????? self.log_error("Request timed out: %r", e)
??????? self.close_connection = 1
??????? return

3. 解決辦法

只要在RequestHandler重載其基類BaseHTTPRequestHandler的成員函數(shù)handle_one_reques(),在調(diào)用 wfile.flush() 前加上 wfile 是否已經(jīng) close 即可。

復(fù)制代碼 代碼如下:
#!/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 handle_one_request(self):
??????? """Handle a single HTTP request.
?
??????? You normally don't need to override this method; see the class
??????? __doc__ string for information on how to handle specific HTTP
??????? commands such as GET and POST.
?
??????? """
??????? try:
??????????? self.raw_requestline = self.rfile.readline(65537)
??????????? if len(self.raw_requestline) > 65536:
??????????????? self.requestline = ''
??????????????? self.request_version = ''
??????????????? self.command = ''
??????????????? self.send_error(414)
??????????????? return
??????????? if not self.raw_requestline:
??????????????? self.close_connection = 1
??????????????? return
??????????? if not self.parse_request():
??????????????? # An error code has been sent, just exit
??????????????? return
??????????? mname = 'do_' + self.command
??????????? if not hasattr(self, mname):
??????????????? self.send_error(501, "Unsupported method (%r)" % self.command)
??????????????? return
??????????? method = getattr(self, mname)
??????????? print "before call do_Get"
??????????? method()
??????????? #增加 debug info 及 wfile 判斷是否已經(jīng) close
??????????? print "after call do_Get"
??????????? if not self.wfile.closed:
??????????????? self.wfile.flush() #actually send the response if not already done.
??????????? print "after wfile.flush()"
??????? except socket.timeout, e:
??????????? #a read or a write timed out.? Discard this connection
??????????? self.log_error("Request timed out: %r", e)
??????????? self.close_connection = 1
??????????? return
????
??? def do_GET(self):
??????? """
??????? 處理get請求
??????? """
??????? query=self.path
??????? print "query: %s thread=%s" % (query, str(threading.current_thread()))
?
??????? ret_str="" + self.path + "
" + str(self.server) +? ""
?
??????? 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()
??????????? self.wfile._sock=None
??????????? return False
???????
??????? print "success prod query :%s" % (query)
??????? return True
?
#多線程處理
class ThreadingHTTPServer(ThreadingMixIn,HTTPServer):
??? pass
????
if __name__ == '__main__':
??? serveraddr = ('',9001)
?
??? ser = ThreadingHTTPServer(serveraddr,RequestHandler)
??? ser.serve_forever()
??? sys.exit(0)


運(yùn)行服務(wù)
./thread_http_server.py
curl ,不等待返回,ctrl +C 來模擬客戶端斷開
復(fù)制代碼 代碼如下:
[~]$curl -s 'http://10.232.41.142:9001/hello2'
[~]$ ctrl+C

此時服務(wù)器端輸出日志如下:
復(fù)制代碼 代碼如下:
$./thread_http_server.pybefore call do_Get
query: /hello2 thread=
search041142.sqa.cm4.tbsite.net - - [15/May/2014 15:54:09] "GET /hello2 HTTP/1.1" 200 -
socket.error : Connection broke. Aborting[Errno 32] Broken pipe
after call do_Get
after wfile.flush()

希望本文所述對大家的Python程序設(shè)計有所幫助。


更多文章、技術(shù)交流、商務(wù)合作、聯(lián)系博主

微信掃碼或搜索:z360901061

微信掃一掃加我為好友

QQ號聯(lián)系: 360901061

您的支持是博主寫作最大的動力,如果您喜歡我的文章,感覺我的文章對您有幫助,請用微信掃描下面二維碼支持博主2元、5元、10元、20元等您想捐的金額吧,狠狠點(diǎn)擊下面給點(diǎn)支持吧,站長非常感激您!手機(jī)微信長按不能支付解決辦法:請將微信支付二維碼保存到相冊,切換到微信,然后點(diǎn)擊微信右上角掃一掃功能,選擇支付二維碼完成支付。

【本文對您有幫助就好】

您的支持是博主寫作最大的動力,如果您喜歡我的文章,感覺我的文章對您有幫助,請用微信掃描上面二維碼支持博主2元、5元、10元、自定義金額等您想捐的金額吧,站長會非常 感謝您的哦!!!

發(fā)表我的評論
最新評論 總共0條評論
主站蜘蛛池模板: 99视频九九精品视频在线观看 | 草久久久| 日本一级~片免费永久 | 国产一区二区在线 |播放 | 免费在线观看黄色毛片 | 亚洲欧洲一区二区三区久久 | 久久99热久久精品23 | 日本一区高清视频 | 99国产精品久久久久久久... | 99视频免费在线 | 性短视频在线观看免费不卡流畅 | 精品久久久久久久一区二区伦理 | 国产亚洲精品福利片 | 日本大片久久久高清免费看 | 豆奶视频污 | a一级特黄日本大片 s色 | 亚洲伦理中文字幕 | 日韩精品一区二区三区免费视频 | 国产欧美成人一区二区三区 | 免费一看一级毛片 | 色综合久久综精品 | 91精品国产麻豆国产自产在线 | 亚洲精品综合一区二区 | 久久久久久久亚洲精品 | 欧美国产成人一区二区三区 | 国产成人亚洲精品91专区手机 | 成人在线观看不卡 | 国产精品福利影院 | 色资源在线观看 | 波多野结衣与公中出中文字幕 | 婷婷日韩 | 婷婷的五月| 国产精品一区二区久久精品涩爱 | 尤物视频在线观看 | 97久久综合精品久久久综合 | 热re66久久精品国产99re | 精品精品国产欧美在线观看 | 久久综合九色综合亚洲小说 | 国产亚洲精品久久久久久久网站 | 国产不卡影院 | 国产成人综合日韩精品无 |