流期间管道破裂答案

【问题标题】：Broken pipe during stream流期间管道破裂
【发布时间】：2013-05-24 14:13:58
【问题描述】：

我有一个 Django 项目，我正在处理我想要流式传输一些 mp3 文件的地方。

我也有同样的问题： Streaming mp3 files with django, read from a page with <audio>

让我解释一下：我想用 Django 流一个 ogg，并在我的 html 页面中使用 <audio> 标记

我有一个类似domain.tld/song/show/X/ 的网址，其中X 是我歌曲的ID。我可以使用 VLC 进行流式传输（直接使用文件路径），我可以在测试期间进行流式传输（我将接收到的内容写入并使用 VLC 读取）。

但是当我打开浏览器并加载我的主页 domain.tld 和带有 url domain.tld/song/show/1/ 的 <\audio\> 应答器时，我得到一个大的破管道，就好像我的客户端关闭了连接一样。

我在其他帖子上读到，当他们将服务器投入生产时，一些问题得到了解决。所以我将我的应用程序推送到服务器上，使用 apache，使用 djangoproject.com 上的 django.wgsi。

我在 Debian 7 上使用 Django 版本 1.5 运行 python 2.7.3。那里有我的代码：

歌曲/views.py

def playAudioFile(request, pk):
    f = get_stream_song(pk)# return a pipe from pipes.Template
    l = f.read() # the file is an ogg get by pydub.com
    f.close()
    size_read = 550000
    sr = size_read
    while sr == size_read:
        print "rep"
        r = l[:size_read]
        l=l[size_read:]
        sr = len(r)
        yield r
    time.sleep(0.1) 

#url : ~/song/show/X/
#@login_required
def show_song(request, pk):
        return StreamingHttpResponse(playAudioFile(request, pk), mimetype='audio/ogg',)

在我的 HTML 中，我只有这样：

 <audio controls height="100" width="100" preload="auto">
    <source src="/.../song/show/1/" type="audio/ogg">
    <embed height="50" width="100" src="/.../song/show/1/">
  </audio>

错误看起来像：

Traceback (most recent call last):
  File "/usr/lib/python2.7/wsgiref/handlers.py", line 86, in run
    self.finish_response()
  File "/usr/lib/python2.7/wsgiref/handlers.py", line 127, in finish_response
    self.write(data)
  File "/usr/lib/python2.7/wsgiref/handlers.py", line 215, in write
    self._write(data)
  File "/usr/lib/python2.7/socket.py", line 324, in write
    self.flush()
  File "/usr/lib/python2.7/socket.py", line 303, in flush
    self._sock.sendall(view[write_offset:write_offset+buffer_size])
error: [Errno 104] Connection reset by peer
----------------------------------------
Exception happened during processing of request from ('127.0.0.1', 46392)
Traceback (most recent call last):
  File "/usr/lib/python2.7/SocketServer.py", line 593, in process_request_thread
    self.finish_request(request, client_address)
  File "/usr/lib/python2.7/SocketServer.py", line 334, in finish_request
    self.RequestHandlerClass(request, client_address, self)
  File "/home/lumy/SPhoque/SonoPhoque/SoPhoque/local/lib/python2.7/site-packages/django/core/servers/basehttp.py", line 150, in __init__
    super(WSGIRequestHandler, self).__init__(*args, **kwargs)
  File "/usr/lib/python2.7/SocketServer.py", line 651, in __init__
    self.finish()
  File "/usr/lib/python2.7/SocketServer.py", line 704, 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

我每次尝试流式传输时都会收到两次。

编辑 15h 29/05：

我按照 rahan 的建议做了：查看 Firebug 和 Firefox 调试器：

客户这样做：

GET 1   200 OK localhost:8000 537.1KB 4.71s

Headers
Response Headersview source
Date    Wed, 29 May 2013 13:08:54 GMT
Server  WSGIServer/0.1 Python/2.7.3
Content-Type    audio/ogg
Request Headersview source
Host    localhost:8000
User-Agent  Mozilla/5.0 (X11; Linux x86_64; rv:10.0.12) Gecko/20100101 Firefox/10.0.12 Iceweasel/10.0.12
Accept  audio/webm,audio/ogg,audio/wav,audio/*;q=0.9,application/ogg;q=0.7,video/*;q=0.6,*/*;q=0.5
Accept-Language en-us,en;q=0.5
Connection  keep-alive
Range   bytes=0-
Referer http://localhost:8000/

详细信息表明所有文档的总大小为 1 MB（缓存中的 526 KB）

【问题讨论】：

您的客户端/浏览器正在终止连接。你需要检查一下。
@Rohan 与wireshark ？在 Firefox 调试器上，获取 URL /.../song/show/1/ 的响应 200
可以使用wireshark，如果有问题也可以检查FF调试器。

标签： python django stream

【解决方案1】：

可能是我跨越了你现有的解决方案，我有一个建议，对于 mp3 流使用nginx/apache 服务器，这些天有一个称为sendfile 的解决方案，例如在你的情况下在 django 视图

def send_file_header(server_type):
    header = "X-Sendfile" if server_type == "apache" else "X-Accel-Redirect"
    return header

@login_required
def show_song(request, pk):
    res =  HttpResponse()
    path = "/path/to/secret/x.mp3"
    response[send_file_header('nginx')] = path
    response['Content-Type']= "application/octet-stream"
    response['Content-Disposition'] = "attachment; filename=\"x.mp3\""
    return response

【讨论】：