Node.js / Expressvideostream(HTTP 206部分内容)

我有一个数据库(MarkLogic)的二进制文件(MP4video文件)。 我正在使用数据库的Node.js API以块formsstream式传输文档。 设置看起来像这样:

html文件

<video controls="controls" width="600"> <source src="/video/myvideo.mp4" type="video/mp4"> </video> 

在expression式中,我设置了处理/ video /:parampath的路由(在数据库中,video具有唯一的标识符,即string'/video/myvideo.mp4')

的node.js

 // I'm only showing the relevant things in here const serveVideo = (req, res) => { var stream = db.documents.read('/gopro/malta.mp4').stream('chunked'); var chunks = []; var chunkBytes = 0; var start = 0; stream.on('data', (chunk) => { var headers; var range = req.headers.range; var total = 214335483; //total length of vid in bytes if (range) { var chunkSize = chunk.length; // (start === 0) ? start = 0 : start += chunkBytes; if (chunkBytes === 0) { start = 0 } else { start = chunkBytes + 1 } chunkBytes += chunkSize; headers = { 'Content-Range': 'bytes ' + start + '-' + chunkBytes + '/' + total, 'Accept-Ranges': 'bytes', 'Content-Length': chunkSize, 'Content-Type': 'video/mp4' }; res.writeHead(206, headers); chunks.push(chunk); } }); stream.on('end', () => { var allChunks = Buffer.concat(chunks); res.end(allChunks); }); }); router.route('/video/:uri').get(serveVideo); 

现在当然,上面的错误是'错误:发送后无法设置标题'。 这是公平和正义的。 但是我无法理解这一点 – .stream('chunked')调用强制数据库以大块的forms检索文档,而且我确实看到这些大块就好,但是怎样才能返回浏览器的206呢? 我不能在.on('data')中做这件事,因为数据正在stream式传输,所以头部会被多次发送。 我想我正在使用哪个数据库并不真正相关 – 我想理解这个概念,或者至less看看我做错了什么。

任何帮助表示赞赏。 所有的例子和其他讨论,我已经看到,使用Node.jsstreamvideo是从磁盘读取video文件。

更新

现在更改代码允许FF播放video而不是Chrome:

 let stream = db.documents.read({uris:'/gopro/malta.mp4'}).stream('chunked'); stream.pipe(res); 

Chrome的控制台没有错误。 这里是标题的细节 – 请注意,有两个mp4文件的请求:

1

 Response Headers Connection:keep-alive Date:Sat, 21 May 2016 17:05:30 GMT Transfer-Encoding:chunked X-Powered-By:Express Request Headers view source Accept:*/* Accept-Encoding:identity;q=1, *;q=0 Accept-Language:en-US,en;q=0.8,hu;q=0.6,ro;q=0.4,it;q=0.2 Cache-Control:no-cache Connection:keep-alive Cookie:__distillery=v20150227_a8e22306-65b3-4c2e-9a8a-159e308156ad; __smToken=7nYU8NYQY15mPowjjCZsS5D3 DNT:1 Host:localhost:8080 Pragma:no-cache Range:bytes=0- Referer:http://localhost:8080/ User-Agent:Mozilla/5.0 (Macintosh; Intel Mac OS X 10_11_4) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/50.0.2661.102 Safari/537.36 

第2

 Response Headers Connection:keep-alive Date:Sat, 21 May 2016 17:05:31 GMT Transfer-Encoding:chunked X-Powered-By:Express Request Headers view source Accept:*/* Accept-Encoding:identity;q=1, *;q=0 Accept-Language:en-US,en;q=0.8,hu;q=0.6,ro;q=0.4,it;q=0.2 Cache-Control:no-cache Connection:keep-alive Cookie:__distillery=v20150227_a8e22306-65b3-4c2e-9a8a-159e308156ad; __smToken=7nYU8NYQY15mPowjjCZsS5D3 DNT:1 Host:localhost:8080 Pragma:no-cache Range:bytes=28- Referer:http://localhost:8080/ User-Agent:Mozilla/5.0 (Macintosh; Intel Mac OS X 10_11_4) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/50.0.2661.102 Safari/537.36 

on('data')callback可以始终closures一个isFirstChunkvariables,该variables初始化为true,并进行testing,如果isFirstChunk为true,则发出头并将isFirstChunk设置为false。

如果可能的话,最好pipestream。 npm可能会提供一个stream库(甚至可能通过2()?),当第一个数据到达时有一个事件。

从长远来看,您可以合理地在stream的开始处为事件提交RFE。

希望有所帮助,

你很可能不需要所有的块的东西。 手动设置标题:

 res.status(206); 

然后只需pipe理响应:

 let stream = db.yourChunkStuff(); stream.pipe(res); 

最简单的方法是pipe道stream。